| Package | Description |
|---|---|
| zmq |
| Modifier and Type | Class and Description |
|---|---|
static class |
Dealer.DealerSession |
static class |
Pair.PairSession |
static class |
Pub.PubSession |
static class |
Pull.PullSession |
static class |
Push.PushSession |
static class |
Rep.RepSession |
static class |
Req.ReqSession |
static class |
Router.RouterSession |
static class |
Sub.SubSession |
static class |
XPub.XPubSession |
static class |
XSub.XSubSession |
| Modifier and Type | Field and Description |
|---|---|
private SessionBase |
StreamEngine.session |
private SessionBase |
TcpConnecter.session |
| Modifier and Type | Method and Description |
|---|---|
static SessionBase |
SessionBase.create(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
| Modifier and Type | Method and Description |
|---|---|
private DecoderBase |
StreamEngine.newDecoder(int size,
long max,
SessionBase session,
int version) |
private EncoderBase |
StreamEngine.newEncoder(int size,
SessionBase session,
int version) |
void |
IEngine.plug(IOThread ioThread,
SessionBase session) |
void |
StreamEngine.plug(IOThread ioThread,
SessionBase session) |
protected void |
ZObject.sendAttach(SessionBase destination,
IEngine engine) |
protected void |
ZObject.sendAttach(SessionBase destination,
IEngine engine,
boolean incSeqnum) |
| Constructor and Description |
|---|
IpcConnecter(IOThread ioThread,
SessionBase session,
Options options,
Address addr,
boolean wait) |
TcpConnecter(IOThread ioThread,
SessionBase session,
Options options,
Address addr,
boolean delayedStart) |