Class StreamEngine

java.lang.Object

zmq.io.StreamEngine

All Implemented Interfaces:

IEngine, IPollEvents

public class StreamEngine
extends Object
implements IEngine, IPollEvents

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	StreamEngine.ErrorReason

Constructor Summary

Constructors

Constructor	Description
StreamEngine(SocketChannel fd, Options options, String endpoint)

Method Summary

Modifier and Type	Method	Description
void	destroy()
String	getEndPoint()
void	inEvent()	Called by I/O thread when file descriptor is ready for reading.
void	outEvent()	Called by I/O thread when file descriptor is ready for writing.
void	plug(IOThread ioThread, SessionBase session)
void	restartInput()
void	restartOutput()
void	terminate()
void	timerEvent(int id)	Called when timer expires.
String	toString()
void	zapMsgAvailable()

Methods inherited from class Object

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

Methods inherited from interface IPollEvents

acceptEvent, connectEvent

Constructor Details

StreamEngine

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

Method Details

destroy

public void destroy()

plug

public void plug(IOThread ioThread,
 SessionBase session)

Specified by:

plug in interface IEngine

terminate

public void terminate()

Specified by:

terminate in interface IEngine

inEvent

public void inEvent()

Description copied from interface: IPollEvents

Called by I/O thread when file descriptor is ready for reading.

Specified by:

inEvent in interface IPollEvents

outEvent

public void outEvent()

Description copied from interface: IPollEvents

Called by I/O thread when file descriptor is ready for writing.

Specified by:

outEvent in interface IPollEvents

restartOutput

public void restartOutput()

Specified by:

restartOutput in interface IEngine

restartInput

public void restartInput()

Specified by:

restartInput in interface IEngine

zapMsgAvailable

public void zapMsgAvailable()

Specified by:

zapMsgAvailable in interface IEngine

timerEvent

public void timerEvent(int id)

Description copied from interface: IPollEvents

Called when timer expires.

Specified by:

timerEvent in interface IPollEvents

Parameters:

id - the ID of the expired timer.

getEndPoint

public String getEndPoint()

Specified by:

getEndPoint in interface IEngine

toString

public String toString()

Overrides:

toString in class Object