public class StreamEngine extends Object implements IEngine, IPollEvents, IMsgSink
Constructor and Description |
---|
StreamEngine(SocketChannel handle,
Options options,
String endpoint) |
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) |
public StreamEngine(SocketChannel handle, Options options, String endpoint)
public void destroy()
public void plug(IOThread ioThread, zmq.SessionBase session)
public void inEvent()
inEvent
in interface IPollEvents
public void outEvent()
outEvent
in interface IPollEvents
public void connectEvent()
connectEvent
in interface IPollEvents
public void acceptEvent()
acceptEvent
in interface IPollEvents
public void timerEvent(int id)
timerEvent
in interface IPollEvents
public void activateOut()
activateOut
in interface IEngine
public void activateIn()
activateIn
in interface IEngine
Copyright © 2016. All rights reserved.