Package | Description |
---|---|
org.zeromq |
Provides high-level bindings for ØMQ.
|
zmq |
Provides low-level bindings for ØMQ.
|
zmq.io | |
zmq.poll | |
zmq.socket | |
zmq.socket.clientserver | |
zmq.socket.pipeline | |
zmq.socket.pubsub | |
zmq.socket.radiodish | |
zmq.socket.reqrep | |
zmq.socket.scattergather |
Modifier and Type | Field and Description |
---|---|
private Ctx |
ZMQ.Context.ctx |
private Ctx |
ManagedContext.ctx |
Modifier and Type | Field and Description |
---|---|
private Ctx |
Signaler.ctx |
private Ctx |
ZObject.ctx |
Modifier and Type | Method and Description |
---|---|
static Ctx |
ZMQ.createContext() |
protected Ctx |
ZObject.getCtx() |
static Ctx |
ZMQ.init(int ioThreads) |
Modifier and Type | Method and Description |
---|---|
private static void |
ZMQ.checkContext(Ctx ctx) |
private static void |
ZMQ.destroyContext(Ctx ctx) |
static int |
ZMQ.getContextOption(Ctx ctx,
int option) |
static void |
ZMQ.setContextOption(Ctx ctx,
int option,
int optval) |
static SocketBase |
ZMQ.socket(Ctx ctx,
int type) |
static void |
ZMQ.term(Ctx ctx) |
Constructor and Description |
---|
Mailbox(Ctx ctx,
java.lang.String name,
int tid) |
MailboxSafe(Ctx ctx,
java.util.concurrent.locks.ReentrantLock sync,
java.lang.String name) |
Own(Ctx parent,
int tid) |
Reaper(Ctx ctx,
int tid) |
Signaler(Ctx ctx,
int pid,
Errno errno) |
SocketBase(Ctx parent,
int tid,
int sid) |
SocketBase(Ctx parent,
int tid,
int sid,
boolean threadSafe) |
ZObject(Ctx ctx,
int tid) |
Constructor and Description |
---|
IOThread(Ctx ctx,
int tid) |
Modifier and Type | Field and Description |
---|---|
private Ctx |
Poller.ctx |
Constructor and Description |
---|
Poller(Ctx ctx,
java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
(package private) abstract SocketBase |
Sockets.create(Ctx parent,
int tid,
int sid) |
static SocketBase |
Sockets.create(int socketType,
Ctx parent,
int tid,
int sid) |
Constructor and Description |
---|
Channel(Ctx parent,
int tid,
int sid) |
Pair(Ctx parent,
int tid,
int sid) |
Peer(Ctx parent,
int tid,
int sid) |
Raw(Ctx parent,
int tid,
int sid) |
Stream(Ctx parent,
int tid,
int sid) |
Constructor and Description |
---|
Client(Ctx parent,
int tid,
int sid) |
Server(Ctx parent,
int tid,
int sid) |
Constructor and Description |
---|
Pull(Ctx parent,
int tid,
int sid) |
Push(Ctx parent,
int tid,
int sid) |
Constructor and Description |
---|
Pub(Ctx parent,
int tid,
int sid) |
Sub(Ctx parent,
int tid,
int sid) |
XPub(Ctx parent,
int tid,
int sid) |
XSub(Ctx parent,
int tid,
int sid) |
Constructor and Description |
---|
Dish(Ctx parent,
int tid,
int sid) |
Radio(Ctx parent,
int tid,
int sid) |
Constructor and Description |
---|
Dealer(Ctx parent,
int tid,
int sid) |
Rep(Ctx parent,
int tid,
int sid) |
Req(Ctx parent,
int tid,
int sid) |
Router(Ctx parent,
int tid,
int sid) |
Constructor and Description |
---|
Gather(Ctx parent,
int tid,
int sid) |
Scatter(Ctx parent,
int tid,
int sid) |