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.filter |
Contains implementations of filters used when receiving events.
|
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.protocol |
Contains classes dealing with the internal protocol of RSB used for sending
and receiving events.
|
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.
|
rsb.util |
Contains general utility and helper classes.
|
Modifier and Type | Method and Description |
---|---|
Event |
Informer.publish(DataType data)
Publish data (of type DataType) to all subscribed participants.
|
Event |
Informer.publish(Event event)
Publish an
Event to all subscribed participants. |
Event |
Informer.send(DataType data)
Deprecated.
Use
Informer.publish(Object) instead to be consistent across
implementations |
Event |
Informer.send(Event event)
Deprecated.
Use
Informer.publish(Event) instead to be consistent across
implementations |
Modifier and Type | Method and Description |
---|---|
abstract void |
AbstractEventHandler.handleEvent(Event event)
Shall implement the real handling logic for an event.
|
void |
Handler.internalNotify(Event event)
Internal notification with a received event.
|
void |
AbstractEventHandler.internalNotify(Event event) |
void |
AbstractDataHandler.internalNotify(Event event) |
void |
FilteringHandler.internalNotify(Event event) |
Event |
Informer.publish(Event event)
Publish an
Event to all subscribed participants. |
Event |
Informer.send(Event event)
Deprecated.
Use
Informer.publish(Event) instead to be consistent across
implementations |
Modifier and Type | Method and Description |
---|---|
void |
SingleThreadEventReceivingStrategy.handle(Event event) |
void |
UnorderedParallelEventReceivingStrategy.handle(Event event) |
void |
OutRouteConfigurator.publishSync(Event event)
Sends an event.
|
void |
DefaultOutRouteConfigurator.publishSync(Event event) |
Modifier and Type | Method and Description |
---|---|
abstract Event |
AbstractFilter.transform(Event event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
MethodFilter.match(Event event) |
boolean |
Filter.match(Event event)
Tells whether the given event matches the filter and hence shall be
dispatched or not.
|
boolean |
ScopeFilter.match(Event event) |
boolean |
AbstractFilter.match(Event event)
Deprecated.
|
boolean |
OriginFilter.match(Event event) |
boolean |
TypeFilter.match(Event event) |
boolean |
CauseFilter.match(Event event) |
abstract Event |
AbstractFilter.transform(Event event)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ProtocolHandler.handleEvent(Event query) |
Modifier and Type | Method and Description |
---|---|
Event |
RemoteServer.call(String name)
Calls a method of the server without request parameter using the method
name.
|
Event |
RemoteServer.call(String name,
double timeout)
Calls a method of the server without request parameter using the method
name.
|
Event |
RemoteServer.call(String name,
Event event)
Calls a method of the server using the method name and request data
encapsulated in an
Event instance. |
Event |
RemoteServer.call(String name,
Event event,
double timeout)
Calls a method of the server using the method name and request data
encapsulated in an
Event instance. |
Event |
EventCallback.internalInvoke(Event request) |
Event |
Callback.internalInvoke(Event request)
Method to invoke the
Callback 's functionality. |
Event |
DataCallback.internalInvoke(Event request) |
abstract Event |
EventCallback.invoke(Event request)
This method is called to invoke the actual behavior of an exposed method.
|
Modifier and Type | Method and Description |
---|---|
Future<Event> |
RemoteServer.callAsync(String name)
Calls a method of the server without request parameter using the method
name.
|
Future<Event> |
RemoteServer.callAsync(String name,
Event event)
Calls a method of the server using the method name and request data
encapsulated in an
Event instance. |
Modifier and Type | Method and Description |
---|---|
Event |
RemoteServer.call(String name,
Event event)
Calls a method of the server using the method name and request data
encapsulated in an
Event instance. |
Event |
RemoteServer.call(String name,
Event event,
double timeout)
Calls a method of the server using the method name and request data
encapsulated in an
Event instance. |
Future<Event> |
RemoteServer.callAsync(String name,
Event event)
Calls a method of the server using the method name and request data
encapsulated in an
Event instance. |
Event |
EventCallback.internalInvoke(Event request) |
Event |
Callback.internalInvoke(Event request)
Method to invoke the
Callback 's functionality. |
Event |
DataCallback.internalInvoke(Event request) |
void |
RemoteMethod.internalNotify(Event event) |
abstract Event |
EventCallback.invoke(Event request)
This method is called to invoke the actual behavior of an exposed method.
|
abstract void |
RemoteMethod.FuturePreparator.result(Event resultEvent)
This method needs to be implemented with the conversion logic from
the
Event instance with the result to the final
Future interface. |
Modifier and Type | Method and Description |
---|---|
static Event |
ProtocolConversion.fromNotification(NotificationType.Notification notification)
Build event from RSB Notification.
|
static Event |
ProtocolConversion.fromNotification(NotificationType.Notification notification,
ByteBuffer serializedData,
ConverterSelectionStrategy<ByteBuffer> converters)
Builds an
Event instance from a
NotificationType.Notification and a
ByteBuffer containing the event payload. |
Modifier and Type | Method and Description |
---|---|
static void |
ProtocolConversion.fillNotificationHeader(NotificationType.Notification.Builder notificationBuilder,
Event event,
String wireSchema)
Fills the notification header in a builder instance.
|
static WireContents<ByteBuffer> |
ProtocolConversion.serializeEventData(Event event,
ConverterSelectionStrategy<ByteBuffer> converters)
Serializes the payload contained in an
Event instance using a
specified ConverterSelectionStrategy . |
Modifier and Type | Method and Description |
---|---|
void |
EventHandler.handle(Event event)
The callback method.
|
void |
OutConnector.push(Event event)
Synchronously sends and event over the transport.
|
Modifier and Type | Method and Description |
---|---|
void |
InPushConnector.handle(Event event) |
void |
OutConnector.push(Event event) |
void |
Bus.push(Event event)
Dispatch an event to all registered handlers.
|
Modifier and Type | Method and Description |
---|---|
void |
SocketOutConnector.push(Event event) |
Modifier and Type | Method and Description |
---|---|
void |
SpreadOutConnector.push(Event event) |
Modifier and Type | Method and Description |
---|---|
BlockingQueue<Event> |
EventQueueAdapter.getQueue()
Provides access to the queue filled by this queue adapter.
|
Modifier and Type | Method and Description |
---|---|
boolean |
TimeLimitedQueue.add(Event event) |
void |
EventQueueAdapter.handleEvent(Event event) |
Constructor and Description |
---|
EventQueueAdapter(BlockingQueue<Event> queue)
Creates an adapter with the given queue implementation.
|
Copyright © 2018 CoR-Lab. All rights reserved.