Package | Description |
---|---|
rsb |
The base package of RSB containing the user-level API.
|
rsb.eventprocessing |
Contains classes handling the flow of events from Participants to the
transport implementations and vice versa.
|
rsb.introspection |
Contains the implementation of the introspection mechanism of RSB.
|
rsb.patterns |
Contains objects implementing additional communication patterns on the basis
of the standard publish subscribe.
|
rsb.util |
Contains general utility and helper classes.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDataHandler<DataType>
A handler that receives the user payload of an event by extracting the data
and casting them to the specified type.
|
class |
AbstractEventHandler
An interface for handlers that are interested in whole
Event
instances. |
class |
FilteringHandler
A decorator for
Handler s that allows additional filtering for each
handler. |
Modifier and Type | Method and Description |
---|---|
Iterator<Handler> |
Listener.getHandlerIterator()
Returns an interator over all handlers attached to this listener.
|
List<Handler> |
Listener.getHandlers()
Returns a list of handlers attached to this listener.
|
Modifier and Type | Method and Description |
---|---|
void |
Listener.addHandler(Handler handler,
boolean wait)
Register an event handler on this Listener to be notified about incoming
events.
|
void |
Listener.removeHandler(Handler handler,
boolean wait)
Remove an event listener from this Listener.
|
Constructor and Description |
---|
FilteringHandler(Handler decorated,
Filter filter)
Creates a filtering handler that wraps another handler and takes one
additional filter.
|
FilteringHandler(Handler decorated,
Set<Filter> filters)
Creates a filtering handler that wraps another handler and takes a set of
filters to apply.
|
Modifier and Type | Method and Description |
---|---|
void |
SingleThreadEventReceivingStrategy.addHandler(Handler handler,
boolean wait) |
void |
UnorderedParallelEventReceivingStrategy.addHandler(Handler handler,
boolean wait) |
void |
EventReceivingStrategy.addHandler(Handler handler,
boolean wait)
Registers a handler that will be informed in case of received events.
|
void |
DefaultPushInRouteConfigurator.handlerAdded(Handler handler,
boolean wait) |
void |
PushInRouteConfigurator.handlerAdded(Handler handler,
boolean wait)
Called in case a
Handler was added to the participant for which
the route is being configured. |
boolean |
DefaultPushInRouteConfigurator.handlerRemoved(Handler handler,
boolean wait) |
boolean |
PushInRouteConfigurator.handlerRemoved(Handler handler,
boolean wait)
Called in case a
Handler was remove from the participant for
which the route is being configured. |
void |
SingleThreadEventReceivingStrategy.removeHandler(Handler handler,
boolean wait) |
void |
UnorderedParallelEventReceivingStrategy.removeHandler(Handler handler,
boolean wait) |
void |
EventReceivingStrategy.removeHandler(Handler handler,
boolean wait)
Removes a handler from the event dispatching.
|
Modifier and Type | Class and Description |
---|---|
class |
ProtocolHandler
Implementation of the introspection protocol using RSB patterns.
|
Modifier and Type | Class and Description |
---|---|
class |
RemoteMethod
Objects of this class represent methods provided by a remote server.
|
Modifier and Type | Class and Description |
---|---|
class |
EventQueueAdapter
An adapter similar to the
QueueAdapter that provides access to a
queue of RSB Event s instead of directly to the payload data. |
class |
QueueAdapter<DataType>
Synchronized queue implementing the rsb.DataHandler interface.
|
Copyright © 2018 CoR-Lab. All rights reserved.