zmq

Class StreamEngine

java.lang.Object

zmq.StreamEngine

All Implemented Interfaces:

IEngine, IMsgSink, IPollEvents

public class StreamEngine
extends Object
implements IEngine, IPollEvents, IMsgSink

Constructor Summary

Constructors

Constructor and Description
StreamEngine(SocketChannel handle, Options options, String endpoint)

Method Summary

Modifier and Type	Method and Description
void	acceptEvent()
void	activateIn()
void	activateOut()
void	connectEvent()
void	destroy()
void	inEvent()
void	outEvent()
void	plug(IOThread ioThread, zmq.SessionBase session)
int	pushMsg(Msg msg)
void	terminate()
void	timerEvent(int id)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamEngine

public StreamEngine(SocketChannel handle,
                    Options options,
                    String endpoint)

Method Detail

destroy

public void destroy()

plug

public void plug(IOThread ioThread,
                 zmq.SessionBase session)

Specified by:

plug in interface IEngine

terminate

public void terminate()

Specified by:

terminate in interface IEngine

inEvent

public void inEvent()

Specified by:

inEvent in interface IPollEvents

outEvent

public void outEvent()

Specified by:

outEvent in interface IPollEvents

connectEvent

public void connectEvent()

Specified by:

connectEvent in interface IPollEvents

acceptEvent

public void acceptEvent()

Specified by:

acceptEvent in interface IPollEvents

timerEvent

public void timerEvent(int id)

Specified by:

timerEvent in interface IPollEvents

activateOut

public void activateOut()

Specified by:

activateOut in interface IEngine

activateIn

public void activateIn()

Specified by:

activateIn in interface IEngine

pushMsg

public int pushMsg(Msg msg)

Specified by:

pushMsg in interface IMsgSink