Package | Description |
---|---|
rsb |
The base package of RSB containing the user-level API.
|
rsb.converter |
Contains converters for the serialization and deserialization of data.
|
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.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 | Class and Description |
---|---|
class |
InitializeException
An InitializeException indicates erroneous situations during the setup of the
communication infrastructure.
|
Modifier and Type | Method and Description |
---|---|
void |
Listener.activate() |
void |
Activatable.activate()
Activates all resources that belong to a specific object.
|
void |
Activatable.State.activate() |
void |
Participant.activate() |
void |
Informer.activate() |
void |
Listener.deactivate() |
void |
Activatable.deactivate()
Deactivate all resources that are owned by a specific object in order to
correctly tear down.
|
void |
Activatable.State.deactivate() |
void |
Participant.deactivate() |
void |
Informer.deactivate() |
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 | Class and Description |
---|---|
class |
ConversionException
An exception that indicates a conversion error in a
Converter . |
Modifier and Type | Method and Description |
---|---|
void |
UnorderedParallelEventReceivingStrategy.activate() |
void |
DefaultPushInRouteConfigurator.activate() |
void |
RouteConfiguratorUtility.activate()
Activate the managed connectors.
|
void |
DefaultOutRouteConfigurator.activate() |
void |
DefaultPushInRouteConfigurator.deactivate() |
void |
RouteConfiguratorUtility.deactivate()
Deactivate the managed connectors.
|
void |
DefaultOutRouteConfigurator.deactivate() |
void |
OutRouteConfigurator.publishSync(Event event)
Sends an event.
|
void |
DefaultOutRouteConfigurator.publishSync(Event event) |
Modifier and Type | Method and Description |
---|---|
void |
ProtocolHandler.activate() |
void |
ProtocolHandler.deactivate() |
Modifier and Type | Class and Description |
---|---|
static class |
Callback.UserCodeException
Exception to be thrown by callbacks to indicate an error while processing
the user code.
|
Modifier and Type | Method and Description |
---|---|
void |
Server.activate() |
void |
Method.activate() |
void |
LocalServer.addMethod(String name,
Callback callback)
Adds a new method to the server which can be called via
RemoteServer instances. |
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. |
<ReplyType,RequestType> |
RemoteServer.call(String name,
RequestType data)
Calls a method of the server using the method name and plain request
data.
|
<ReplyType,RequestType> |
RemoteServer.call(String name,
RequestType data,
double timeout)
Calls a method of the server using the method name and plain request
data.
|
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. |
<ReplyType,RequestType> |
RemoteServer.callAsync(String name,
RequestType data)
Calls a method of the server using the method name and plain request
data.
|
void |
Server.deactivate() |
void |
Method.deactivate() |
Modifier and Type | Method and Description |
---|---|
void |
OutConnector.push(Event event)
Synchronously sends and event over the transport.
|
Modifier and Type | Method and Description |
---|---|
void |
InPushConnector.activate() |
void |
OutConnector.push(Event event) |
Modifier and Type | Method and Description |
---|---|
void |
BusClientConnection.activate() |
void |
SocketOutConnector.activate() |
void |
RefCountingBus.activate() |
void |
SocketConnectorUtility.activate()
Acquires a new
Bus instance and activates it respecting the
requested ServerMode . |
void |
SocketInPushConnector.activate() |
void |
BusConnectionBase.activate() |
void |
BusServer.activate() |
void |
BusClient.activate() |
void |
SocketOutConnector.deactivate() |
void |
RefCountingBus.deactivate() |
void |
SocketConnectorUtility.deactivate()
Deactivates the underlying bus instance.
|
void |
SocketInPushConnector.deactivate() |
void |
BusConnectionBase.deactivate() |
void |
BusBase.deactivate() |
void |
BusServer.deactivate() |
void |
BusClient.deactivate() |
protected void |
BusBase.handleGlobally(NotificationType.Notification notification)
Dispatches the notification to registered connections.
|
protected void |
BusBase.handleGlobally(NotificationType.Notification notification,
BusConnection ignoreConnection)
Dispatches the notification to registered connections.
|
void |
BusBase.handleIncoming(NotificationType.Notification notification)
Implement this method to specify the behavior in case of an incoming
notification received from a connection.
|
abstract void |
BusBase.handleIncoming(NotificationType.Notification notification,
BusConnection sourceConnection)
Implement this method to specify the behavior in case of an incoming
notification received from a connection.
|
void |
BusServer.handleIncoming(NotificationType.Notification notification,
BusConnection sourceConnection) |
void |
BusClient.handleIncoming(NotificationType.Notification notification,
BusConnection source) |
protected void |
BusBase.handleLocally(NotificationType.Notification notification)
Dispatches the specified notifications to all registered
Bus.NotificationReceiver s. |
void |
RefCountingBus.handleOutgoing(NotificationType.Notification notification) |
void |
BusBase.handleOutgoing(NotificationType.Notification notification) |
void |
Bus.handleOutgoing(NotificationType.Notification notification)
Handles a notification to be sent over the bus.
|
protected void |
BusClientConnection.handshake()
Perform simple handshake as specified in RSB socket protocol.
|
protected void |
BusServerConnection.handshake() |
protected abstract void |
BusConnectionBase.handshake()
Performs the handshake step of the protocol.
|
void |
SocketOutConnector.push(Event event) |
Modifier and Type | Class and Description |
---|---|
class |
SerializeException
Indicates an error with the serialization.
|
Modifier and Type | Method and Description |
---|---|
void |
SpreadReceiver.activate() |
void |
MultiSpreadInPushConnector.activate() |
void |
RefCountingSpreadWrapper.activate() |
void |
SpreadInPushConnector.activate() |
void |
SpreadOutConnector.activate() |
void |
SpreadWrapperImpl.deactivate() |
void |
SpreadReceiver.deactivate() |
void |
MultiSpreadInPushConnector.deactivate() |
void |
RefCountingSpreadWrapper.deactivate() |
void |
SpreadInPushConnector.deactivate() |
void |
SpreadOutConnector.deactivate() |
void |
SpreadReceiver.join(String groupName)
Join a spread group.
|
void |
SpreadReceiver.leave(String groupName)
Leave a previously joined group.
|
void |
SpreadOutConnector.push(Event event) |
boolean |
SpreadMultiReceiver.subscribe(SpreadMultiReceiver.Subscription subscription)
Register a new client.
|
boolean |
SpreadMultiReceiver.unsubscribe(SpreadMultiReceiver.Subscription subscription)
Unregister an existing client.
|
Copyright © 2018 CoR-Lab. All rights reserved.