Package | Description |
---|---|
org.zeromq | |
org.zeromq.api | |
org.zeromq.jzmq.bstar | |
org.zeromq.jzmq.reactor |
Modifier and Type | Method and Description |
---|---|
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.
|
static Reactor |
Sockets.newReactor(LoopHandler handler,
long interval,
TimeUnit unit)
Create a ØMQ Reactor with a single LoopHandler which initially handles
a repeating timer with the given interval.
|
static Reactor |
Sockets.newReactor(LoopHandler handler,
SelectableChannel... channels)
Create a ØMQ Reactor with a single LoopHandler which handles incoming
messages from the given SelectableChannels.
|
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.
|
Modifier and Type | Method and Description |
---|---|
Reactor |
BinaryStarReactor.getReactor()
Get the underlying
Reactor . |
Modifier and Type | Method and Description |
---|---|
void |
LoopHandler.execute(Reactor reactor,
Pollable pollable)
Execute a loop operation.
|
void |
LoopAdapter.execute(Reactor reactor,
Pollable pollable) |
protected void |
LoopAdapter.execute(Reactor reactor,
SelectableChannel channel) |
protected void |
LoopAdapter.execute(Reactor reactor,
Socket socket) |
Modifier and Type | Method and Description |
---|---|
Reactor |
BinaryStarReactorImpl.getReactor()
This method returns the underlying Reactor, so we can add
additional timers and readers.
|
Modifier and Type | Class and Description |
---|---|
class |
ReactorImpl |
Modifier and Type | Method and Description |
---|---|
Reactor |
ReactorBuilder.build() |
Copyright © 2019. All rights reserved.