Package | Description |
---|---|
rsb.eventprocessing |
Contains classes handling the flow of events from Participants to the
transport implementations and vice versa.
|
rsb.transport |
Contains the different transport implementations for RSB as well as
interfaces and helpers for this purpose.
|
rsb.transport.inprocess |
Contains the implementation of the local in-memory transport.
|
rsb.transport.socket |
Contains the implementation of the TCP socket transport.
|
rsb.transport.spread |
Contains the implementation of the spread-based transport.
|
Modifier and Type | Interface and Description |
---|---|
interface |
EventReceivingStrategy
An interface for strategies that dispatch received events to
Handler
s. |
Modifier and Type | Class and Description |
---|---|
class |
SingleThreadEventReceivingStrategy
An
EventReceivingStrategy that uses a single thread for all handlers. |
class |
UnorderedParallelEventReceivingStrategy
An
EventReceivingStrategy that dispatches Event s using a
thread pool but without any ordering guarantees. |
Modifier and Type | Method and Description |
---|---|
void |
InPushConnector.addHandler(EventHandler handler)
Adds a handler which will be notified about newly received events.
|
boolean |
InPushConnector.removeHandler(EventHandler handler)
Removes a registered handler so that it won't be notified anymore.
|
Modifier and Type | Class and Description |
---|---|
class |
InPushConnector
Implements a push-based connector for receiving events via the inprocess
transport.
|
Modifier and Type | Method and Description |
---|---|
void |
InPushConnector.addHandler(EventHandler handler) |
void |
Bus.addHandler(EventHandler handler)
Add a handler to receive new events.
|
boolean |
InPushConnector.removeHandler(EventHandler handler) |
void |
Bus.removeHandler(EventHandler handler)
Removes a handler from the event receiving.
|
Modifier and Type | Method and Description |
---|---|
void |
SocketInPushConnector.addHandler(EventHandler handler) |
boolean |
SocketInPushConnector.removeHandler(EventHandler handler) |
Modifier and Type | Method and Description |
---|---|
EventHandler |
SpreadMultiReceiver.Subscription.getHandler()
Returns the handler to call with new events on the scope provide by
SpreadMultiReceiver.Subscription.getScope() . |
Modifier and Type | Method and Description |
---|---|
void |
SpreadReceiver.addHandler(EventHandler handler)
Adds a handler to be called on every new event received.
|
void |
MultiSpreadInPushConnector.addHandler(EventHandler handler) |
void |
SpreadInPushConnector.addHandler(EventHandler handler) |
boolean |
SpreadReceiver.removeHandler(EventHandler handler)
Removes a handler from set of registered handlers.
|
boolean |
MultiSpreadInPushConnector.removeHandler(EventHandler handler) |
boolean |
SpreadInPushConnector.removeHandler(EventHandler handler) |
Constructor and Description |
---|
SpreadMultiReceiver.Subscription(Scope scope,
EventHandler handler)
Constructor.
|
Copyright © 2018 CoR-Lab. All rights reserved.