zmq.io

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 and Description
static class	StreamEngine.ErrorReason

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	acceptEvent()
void	connectEvent()
void	destroy()
void	inEvent()
void	outEvent()
void	plug(IOThread ioThread, SessionBase session)
void	restartInput()
void	restartOutput()
void	terminate()
void	timerEvent(int id)
String	toString()
void	zapMsgAvailable()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamEngine

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

Method Detail

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()

Specified by:

inEvent in interface IPollEvents

outEvent

public void outEvent()

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)

Specified by:

timerEvent in interface IPollEvents

connectEvent

public void connectEvent()

Specified by:

connectEvent in interface IPollEvents

acceptEvent

public void acceptEvent()

Specified by:

acceptEvent in interface IPollEvents

toString

public String toString()

Overrides:

toString in class Object