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 | Class and Description |
---|---|
class |
LoopAdapter
An abstract class for implementing a
LoopHandler . |
Modifier and Type | Method and Description |
---|---|
void |
Reactor.addPollable(Pollable pollable,
LoopHandler handler)
Add a new Pollable to this Reactor.
|
void |
Reactor.addTimer(long initialDelay,
int numIterations,
LoopHandler handler)
Add a new ReactorTimer to this Reactor.
|
void |
Reactor.cancel(LoopHandler handler)
Cancel an existing Pollable or ReactorTimer and remove the corresponding
LoopHandler from executing.
|
void |
BinaryStarReactor.setActiveHandler(LoopHandler handler)
Register a handler to be called each time there's a state change.
|
void |
BinaryStarReactor.setPassiveHandler(LoopHandler handler)
Register a handler to be called each time there's a state change.
|
void |
BinaryStarReactor.setVoterHandler(LoopHandler handler)
Register a voter handler to be called each time the application receives a message.
|
Modifier and Type | Field and Description |
---|---|
LoopHandler |
BinaryStarReactorBuilder.Spec.activeHandler |
LoopHandler |
BinaryStarReactorBuilder.Spec.passiveHandler |
LoopHandler |
BinaryStarReactorBuilder.Spec.voterHandler |
Modifier and Type | Method and Description |
---|---|
void |
BinaryStarReactorImpl.setActiveHandler(LoopHandler handler)
Register handlers to be called each time there's a state change.
|
void |
BinaryStarReactorImpl.setPassiveHandler(LoopHandler handler)
Register handlers to be called each time there's a state change.
|
void |
BinaryStarReactorImpl.setVoterHandler(LoopHandler handler)
Register handlers to be called each time there's a state change.
|
BinaryStarReactorBuilder |
BinaryStarReactorBuilder.withActiveHandler(LoopHandler activeHandler) |
BinaryStarReactorBuilder |
BinaryStarReactorBuilder.withPassiveHandler(LoopHandler passiveHandler) |
BinaryStarReactorBuilder |
BinaryStarReactorBuilder.withVoterHandler(LoopHandler voterHandler) |
Copyright © 2019. All rights reserved.