Package | Description |
---|---|
rsb.converter |
Contains converters for the serialization and deserialization of data.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
PredicateConverterSelectionStrategy<WireType>
A converter selection strategy that uses predicates to select converters.
|
class |
UnambiguousConverterMap<WireType> |
Modifier and Type | Method and Description |
---|---|
ConverterSelectionStrategy<WireType> |
DefaultConverterRepository.getConvertersForDeserialization() |
ConverterSelectionStrategy<WireType> |
ConverterRepository.getConvertersForDeserialization()
This method queries the converter map for deseralizable data types and
returns an UnambiguousConverterMap for the chosen WireType to the
caller.
|
ConverterSelectionStrategy<WireType> |
DefaultConverterRepository.getConvertersForSerialization() |
ConverterSelectionStrategy<WireType> |
ConverterRepository.getConvertersForSerialization()
This method queries the converter map for seralizable data types and
returns an UnambiguousConverterMap for the chosen WireType to the
caller.
|
Modifier and Type | Method and Description |
---|---|
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. |
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 |
---|---|
InPushConnector |
TransportFactory.createInPushConnector(Properties properties,
ConverterSelectionStrategy<?> converters)
Creates an in connector for receiving events in an asynchronous fashion.
|
OutConnector |
TransportFactory.createOutConnector(Properties properties,
ConverterSelectionStrategy<?> converters)
Creates an out connector for sending events.
|
Modifier and Type | Method and Description |
---|---|
InPushConnector |
InProcessFactory.createInPushConnector(Properties properties,
ConverterSelectionStrategy<?> converters) |
OutConnector |
InProcessFactory.createOutConnector(Properties properties,
ConverterSelectionStrategy<?> converters) |
Modifier and Type | Method and Description |
---|---|
ConverterSelectionStrategy<ByteBuffer> |
SocketConnectorUtility.getConverters()
Returns the contained converters to use.
|
Modifier and Type | Method and Description |
---|---|
InPushConnector |
SocketFactory.createInPushConnector(Properties properties,
ConverterSelectionStrategy<?> converters) |
OutConnector |
SocketFactory.createOutConnector(Properties properties,
ConverterSelectionStrategy<?> converters) |
Constructor and Description |
---|
SocketConnectorUtility(SocketOptions socketOptions,
ServerMode serverMode,
ConverterSelectionStrategy<ByteBuffer> converters)
Constructor.
|
SocketInPushConnector(SocketOptions socketOptions,
ServerMode serverMode,
ConverterSelectionStrategy<ByteBuffer> converters)
Constructor.
|
SocketOutConnector(SocketOptions socketOptions,
ServerMode serverMode,
ConverterSelectionStrategy<ByteBuffer> converters)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
InPushConnector |
IndividualInPushConnectorFactory.create(Properties properties,
ConverterSelectionStrategy<?> converters) |
InPushConnector |
InPushConnectorFactory.create(Properties properties,
ConverterSelectionStrategy<?> converters)
Creates a new instance of a
SpreadInPushConnector based on the
provided options. |
InPushConnector |
SharedInPushConnectorFactory.create(Properties properties,
ConverterSelectionStrategy<?> converters) |
InPushConnector |
SpreadFactory.createInPushConnector(Properties properties,
ConverterSelectionStrategy<?> converters) |
OutConnector |
SpreadFactory.createOutConnector(Properties properties,
ConverterSelectionStrategy<?> converters) |
Constructor and Description |
---|
SpreadInPushConnector(SpreadWrapper spread,
ConverterSelectionStrategy<ByteBuffer> converters)
Creates a new connector.
|
SpreadOutConnector(SpreadWrapper spread,
ConverterSelectionStrategy<ByteBuffer> outStrategy,
QualityOfServiceSpec qos)
Constructs a new
SpreadOutConnector . |
SpreadReceiver(SpreadWrapper spread,
ConverterSelectionStrategy<ByteBuffer> converters)
Creates a new instance.
|
Copyright © 2018 CoR-Lab. All rights reserved.