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.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 |
Informer<DataType>
This class offers a method to publish events to a channel, reaching all
participating Listeners.
|
class |
Listener
This class implements the receiving part of the Inform-Listen (n:m)
communication pattern offered by RSB.
|
class |
Participant
Base class for all bus participants with an associated scope.
|
Modifier and Type | Interface and Description |
---|---|
interface |
EventReceivingStrategy
An interface for strategies that dispatch received events to
Handler
s. |
interface |
InRouteConfigurator<ConnectorType extends InConnector>
Implementing classes provide outgoing communication routes for
Participant s. |
interface |
OutRouteConfigurator
Implementing classes provide outgoing communication routes for
Participant s. |
interface |
PushInRouteConfigurator
Instances of this class set up routes to receive events with asynchronous
notifications for new events.
|
interface |
RouteConfigurator<ConnectorType extends Connector>
Abstract interface for classes setting up event receiving or sending routes
from
Participant instances to the concrete transport
implementations. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultOutRouteConfigurator
Class implementing the basic out route configuration based on a push
strategy.
|
class |
DefaultPushInRouteConfigurator
Default implementation of a
PushInRouteConfigurator . |
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 | Class and Description |
---|---|
class |
ProtocolHandler
Implementation of the introspection protocol using RSB patterns.
|
Modifier and Type | Class and Description |
---|---|
class |
LocalServer
Objects of this class associate a collection of method objects which are
implemented by callback functions with a scope under which these methods are
exposed for remote clients.
|
class |
Method
Objects of this class are methods which are associated to a local or remote
server.
|
class |
RemoteMethod
Objects of this class represent methods provided by a remote server.
|
class |
RemoteServer
Objects of this class represent remote servers in a way that allows calling
methods on them as if they were local.
|
class |
Server<MethodType extends Method>
Objects of this class represent local or remote serves.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Connector
A generic interface for classes providing connection to a specific transport
mechanism.
|
interface |
InConnector
Implements receiving
Event s from a specific transport. |
interface |
InPushConnector
Interface for receiving connectors which asynchronously notify handlers about
newly received events.
|
interface |
OutConnector
Enables sending
Event s via a specific transport. |
Modifier and Type | Class and Description |
---|---|
class |
InPushConnector
Implements a push-based connector for receiving events via the inprocess
transport.
|
class |
OutConnector
OutConnector implementation for the inprocess
transport. |
Modifier and Type | Interface and Description |
---|---|
interface |
Bus
Instances of this class provide access to a socket-based bus.
|
interface |
BusConnection
Interface for connections to the socket based transport.
|
Modifier and Type | Class and Description |
---|---|
class |
BusBase
A utility base class for the implementation of the
Bus interface. |
class |
BusClient
A
Bus implementation which acts as a client to an existing server
implementation. |
class |
BusClientConnection
Instances of this class implement connections to a socket-based bus in the
form of a client.
|
class |
BusConnectionBase
Utility base class for the implementation of the
BusConnection
interface. |
class |
BusServer
Instances of this class provide access to a socket-based bus for remote bus
clients.
|
class |
BusServerConnection
Instances of this class implement connections to a socket-based bus in the
form of a server.
|
class |
RefCountingBus
A reference counting decorator for
Bus instances. |
class |
SocketInPushConnector
An
InPushConnector for the socket-based transport. |
class |
SocketOutConnector
An
OutConnector instance for the socket transport. |
Modifier and Type | Interface and Description |
---|---|
interface |
SpreadWrapper
Interface for classes that encapsulate and manages a connection to the spread
daemon.
|
Modifier and Type | Class and Description |
---|---|
class |
MultiSpreadInPushConnector
A
SpreadInPushConnector which implement connection sharing by using a
SpreadMultiReceiver instance. |
class |
RefCountingSpreadWrapper
A facade for
SpreadWrapper instances which counts calls to
RefCountingSpreadWrapper.activate() and RefCountingSpreadWrapper.deactivate() and only passes these calls
down to a wrapped instance of SpreadWrapper in case they are the
first or the last. |
class |
SpreadInPushConnector
An
InPushConnector for the spread daemon network. |
class |
SpreadOutConnector
An
OutConnector for the spread daemon network. |
class |
SpreadReceiver
Implements a spread connection which is used to receive data via a single
receiving thread.
|
class |
SpreadWrapperImpl
This class encapsulates and manages a connection to the spread daemon.
|
Copyright © 2018 CoR-Lab. All rights reserved.