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.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 | Method and Description |
---|---|
<DataType> Informer<DataType> |
Factory.createInformer(InformerCreateArgs args)
Creates a new informer instance.
|
<DataType> Informer<DataType> |
Factory.createInformer(Scope scope)
Creates a new informer instance.
|
<DataType> Informer<DataType> |
Factory.createInformer(Scope scope,
Class<?> type)
Creates a new informer instance.
|
<DataType> Informer<DataType> |
Factory.createInformer(Scope scope,
Class<?> type,
ParticipantConfig config)
Creates a new informer instance.
|
<DataType> Informer<DataType> |
Factory.createInformer(Scope scope,
ParticipantConfig config)
Creates a new informer instance.
|
<DataType> Informer<DataType> |
Factory.createInformer(String scope)
Creates a new informer instance.
|
<DataType> Informer<DataType> |
Factory.createInformer(String scope,
Class<?> type)
Creates a new informer instance.
|
<DataType> Informer<DataType> |
Factory.createInformer(String scope,
Class<?> type,
ParticipantConfig config)
Creates a new informer instance.
|
<DataType> Informer<DataType> |
Factory.createInformer(String scope,
ParticipantConfig config)
Creates a new informer instance.
|
Listener |
Factory.createListener(ListenerCreateArgs args)
Creates a new listener instance.
|
Listener |
Factory.createListener(Scope scope)
Creates a new listener instance.
|
Listener |
Factory.createListener(Scope scope,
ParticipantConfig config)
Creates a new listener instance.
|
Listener |
Factory.createListener(String scope)
Creates a new listener instance.
|
Listener |
Factory.createListener(String scope,
ParticipantConfig config)
Creates a new listener instance.
|
Modifier and Type | Method and Description |
---|---|
EventReceivingStrategy |
UnorderedParallelFactory.create() |
EventReceivingStrategy |
EventReceivingStrategyFactory.create()
Create a new instance.
|
EventReceivingStrategy |
SingleThreadFactory.create() |
Constructor and Description |
---|
RemoteMethod(ParticipantCreateArgs<?> args)
Create a new RemoteMethod object that represent the remote method named @a
name provided by @a server.
|
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 |
---|---|
InPushConnector |
SocketFactory.createInPushConnector(Properties properties,
ConverterSelectionStrategy<?> converters) |
OutConnector |
SocketFactory.createOutConnector(Properties properties,
ConverterSelectionStrategy<?> converters) |
Modifier and Type | Method and Description |
---|---|
void |
SpreadWrapperImpl.activate() |
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) |
Copyright © 2018 CoR-Lab. All rights reserved.