Package | Description |
---|---|
rsb.eventprocessing |
Contains classes handling the flow of events from Participants to the
transport implementations and vice versa.
|
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 | Method and Description |
---|---|
void |
DefaultPushInRouteConfigurator.addConnector(InPushConnector connector) |
boolean |
DefaultPushInRouteConfigurator.removeConnector(InPushConnector connector) |
Modifier and Type | Method and Description |
---|---|
InPushConnector |
TransportFactory.createInPushConnector(Properties properties,
ConverterSelectionStrategy<?> converters)
Creates an in connector for receiving events in an asynchronous fashion.
|
Modifier and Type | Class and Description |
---|---|
class |
InPushConnector
Implements a push-based connector for receiving events via the inprocess
transport.
|
Modifier and Type | Method and Description |
---|---|
InPushConnector |
InProcessFactory.createInPushConnector(Properties properties,
ConverterSelectionStrategy<?> converters) |
Modifier and Type | Class and Description |
---|---|
class |
SocketInPushConnector
An
InPushConnector for the socket-based transport. |
Modifier and Type | Method and Description |
---|---|
InPushConnector |
SocketFactory.createInPushConnector(Properties properties,
ConverterSelectionStrategy<?> converters) |
Modifier and Type | Class and Description |
---|---|
class |
MultiSpreadInPushConnector
A
SpreadInPushConnector which implement connection sharing by using a
SpreadMultiReceiver instance. |
class |
SpreadInPushConnector
An
InPushConnector for the spread daemon network. |
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) |
Copyright © 2018 CoR-Lab. All rights reserved.