Package | Description |
---|---|
org.zeromq | |
org.zeromq.api | |
org.zeromq.jzmq | |
org.zeromq.jzmq.bstar | |
org.zeromq.jzmq.clone | |
org.zeromq.jzmq.poll | |
org.zeromq.jzmq.reactor | |
org.zeromq.jzmq.sockets |
Modifier and Type | Method and Description |
---|---|
static Socket |
Sockets.bind(SocketType socketType,
String url)
Create a ØMQ Socket and bind it to a given url.
|
static Socket |
Sockets.connect(SocketType socketType,
String url)
Create a ØMQ Socket and connect it to a given url.
|
static Socket |
Sockets.fork(Backgroundable backgroundable)
Run a background thread with an inproc PAIR socket for communication.
|
static Socket |
Patterns.newBinaryStarSocket(String primaryUrl,
String backupUrl)
Create a ØMQ DEALER Socket, backed by a background agent that is connected
to a BinaryStarReactor HA-pair.
|
Modifier and Type | Method and Description |
---|---|
static void |
Sockets.forward(Socket frontEnd,
Socket backEnd)
Create a ØMQ proxy and start it up on another thread that exits when the
context is closed.
|
static Poller |
Sockets.newPoller(PollListener listener,
Socket... sockets)
Create a ØMQ Poller with a single PollListener which handles incoming
messages from the given ØMQ Sockets.
|
static Poller |
Sockets.newPoller(PollListener listener,
Socket socket,
SelectableChannel channel)
Create a ØMQ Poller with a single PollListener which handles incoming
messages from the given ØMQ Socket and SelectableChannel.
|
static Reactor |
Sockets.newReactor(LoopHandler handler,
Socket... sockets)
Create a ØMQ Reactor with a single LoopHandler which handles incoming
messages from the given ØMQ Sockets.
|
static Reactor |
Sockets.newReactor(LoopHandler handler,
Socket socket,
SelectableChannel channel)
Create a ØMQ Reactor with a single LoopHandler which handles incoming
messages from the given ØMQ Socket and SelectableChannel.
|
static void |
Sockets.proxy(Socket frontEnd,
Socket backEnd)
Create a ØMQ proxy and start it up.
|
Modifier and Type | Method and Description |
---|---|
static Poller |
Sockets.newPoller(PollListener listener,
List<Socket> sockets,
List<SelectableChannel> channels)
Create a ØMQ Poller with a single PollListener which handles incoming
messages from the given ØMQ Sockets and SelectableChannels.
|
static Reactor |
Sockets.newReactor(LoopHandler handler,
List<Socket> sockets,
List<SelectableChannel> channels)
Create a ØMQ Reactor with a single LoopHandler which handles incoming
messages from the given ØMQ Sockets and SelectableChannels.
|
Modifier and Type | Method and Description |
---|---|
Socket |
Bindable.bind(String url)
Bind to a url.
|
Socket |
Bindable.bind(String url,
String... additionalUrls)
Bind to a url.
|
Socket |
Connectable.connect(String url)
Connect to a url.
|
Socket |
Connectable.connect(String url,
String... additionalUrls)
Connect to a url.
|
Socket |
Context.fork(Backgroundable backgroundable)
Run a background thread with an inproc PAIR socket for communication.
|
Socket |
Pollable.getSocket()
Get the socket (if any) for this poll item.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Poller.disable(Socket socket)
Disable a socket in the poller, preventing it from waking up the thread
when messages are received on it.
|
int |
Poller.enable(Socket socket)
Enable a socket in the poller after it has been disabled.
|
protected void |
LoopAdapter.execute(Reactor reactor,
Socket socket) |
void |
Context.fork(Socket socket,
Backgroundable backgroundable)
Run a background thread using the given socket for communication.
|
void |
Context.forward(Socket frontEnd,
Socket backEnd)
Create a ØMQ proxy and start it up on another thread that exits when the
context is closed.
|
protected void |
PollAdapter.handleError(Socket socket) |
protected void |
PollAdapter.handleIn(Socket socket) |
protected void |
PollAdapter.handleOut(Socket socket) |
Pollable |
Context.newPollable(Socket socket,
PollerType... options)
Create a new Pollable from the socket, with the requested options.
|
void |
Context.proxy(Socket frontEnd,
Socket backEnd)
Create a ØMQ proxy and start it up.
|
void |
Context.queue(Socket frontEnd,
Socket backEnd)
|
void |
BinaryStarReactor.registerVoterSocket(Socket socket)
Register a client voter socket.
|
void |
Backgroundable.run(Context context,
Socket socket)
Run a background thread communicating over the given socket.
|
boolean |
Poller.unregister(Socket socket)
Unregister a socket from the poller.
|
Modifier and Type | Class and Description |
---|---|
class |
ManagedSocket
Managed JZMQ Socket
|
Modifier and Type | Method and Description |
---|---|
Socket |
ManagedContext.fork(Backgroundable backgroundable) |
Modifier and Type | Method and Description |
---|---|
Collection<Socket> |
ManagedContext.getSockets() |
Modifier and Type | Method and Description |
---|---|
void |
ManagedContext.destroySocket(Socket socket) |
void |
ManagedContext.fork(Socket socket,
Backgroundable backgroundable) |
void |
ManagedContext.forward(Socket frontEnd,
Socket backEnd) |
Pollable |
ManagedContext.newPollable(Socket socket,
PollerType... options) |
void |
ManagedContext.proxy(Socket frontEnd,
Socket backEnd) |
void |
ManagedContext.queue(Socket frontEnd,
Socket backEnd) |
Modifier and Type | Field and Description |
---|---|
Socket |
BinaryStarReactorBuilder.Spec.voter |
Modifier and Type | Method and Description |
---|---|
Socket |
BinaryStarSocketBuilder.bind(String url,
String... additionalUrls) |
Socket |
BinaryStarSocketBuilder.connect(String url,
String... additionalUrls) |
Modifier and Type | Method and Description |
---|---|
void |
BinaryStarReactorImpl.registerVoterSocket(Socket socket)
This method registers a client voter socket.
|
BinaryStarReactorBuilder |
BinaryStarReactorBuilder.withVoterSocket(Socket voter) |
Modifier and Type | Method and Description |
---|---|
void |
CloneClientAgent.run(Context context,
Socket pipe) |
Modifier and Type | Method and Description |
---|---|
Socket |
PollableImpl.getSocket() |
Modifier and Type | Method and Description |
---|---|
boolean |
PollerImpl.disable(Socket socket) |
int |
PollerImpl.enable(Socket socket) |
boolean |
PollerImpl.unregister(Socket socket) |
PollerBuilder |
PollerBuilder.withAllPollable(Socket socket,
PollListener listener) |
PollerBuilder |
PollerBuilder.withErrorPollable(Socket socket,
PollListener listener) |
PollerBuilder |
PollerBuilder.withInOutPollable(Socket socket,
PollListener listener) |
PollerBuilder |
PollerBuilder.withInPollable(Socket socket,
PollListener listener) |
PollerBuilder |
PollerBuilder.withOutPollable(Socket socket,
PollListener listener) |
Constructor and Description |
---|
PollableImpl(Socket socket,
PollerType... options) |
Modifier and Type | Method and Description |
---|---|
ReactorBuilder |
ReactorBuilder.withAllPollable(Socket socket,
LoopHandler handler) |
ReactorBuilder |
ReactorBuilder.withErrorPollable(Socket socket,
LoopHandler handler) |
ReactorBuilder |
ReactorBuilder.withInOutPollable(Socket socket,
LoopHandler handler) |
ReactorBuilder |
ReactorBuilder.withInPollable(Socket socket,
LoopHandler handler) |
ReactorBuilder |
ReactorBuilder.withOutPollable(Socket socket,
LoopHandler handler) |
Modifier and Type | Method and Description |
---|---|
Socket |
SocketBuilder.bind(String url)
Bind to a url.
|
Socket |
RouterSocketBuilder.bind(String url,
String... additionalUrls) |
Socket |
SubSocketBuilder.bind(String url,
String... additionalUrls) |
Socket |
SocketBuilder.bind(String url,
String... additionalUrls) |
Socket |
SocketBuilder.connect(String url)
Connect to a url.
|
Socket |
RouterSocketBuilder.connect(String url,
String... additionalUrls) |
Socket |
SubSocketBuilder.connect(String url,
String... additionalUrls) |
Socket |
SocketBuilder.connect(String url,
String... additionalUrls) |
protected Socket |
SocketBuilder.newManagedSocket(org.zeromq.ZMQ.Socket socket) |
Copyright © 2019. All rights reserved.