Package rsb.transport.spread

Contains the implementation of the spread-based transport.

See: Description

Interface Summary

Interface	Description
InPushConnectorFactory	Interface for strategies used to create SpreadInPushConnector instances depending on the client's needs.
SpreadWrapper	Interface for classes that encapsulate and manages a connection to the spread daemon.

Class Summary

Class	Description
AssemblyPool	A class that assembles fragmented messages received over spread in form of NotificationType.Notifications.
DataMessage	Encapsulates a message containing data to be sent via spread.
IndividualInPushConnectorFactory	A InPushConnectorFactory implementation assigning an individual connector to each creation request.
InPushConnectorFactoryRegistry	Deprecated this is more or less a hack until the configuration system supports a better structured way to specify the factory instances.
MembershipMessage
MultiSpreadInPushConnector	A SpreadInPushConnector which implement connection sharing by using a SpreadMultiReceiver instance.
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.
SharedInPushConnectorFactory	An implementation which tries to reuse underlying SpreadWrapper instances of the connectors in case options match.
SpreadFactory	A TransportFactory implementation for the spread transport.
SpreadInPushConnector	An InPushConnector for the spread daemon network.
SpreadMultiReceiver	A class that encapsulates the logic to correctly handle multiple parallel clients of a SpreadReceiver by synchronizing the required access and calculating the effective scopes to join.
SpreadMultiReceiver.Subscription	Subscription information for a single client of this class.
SpreadOptions	Encapsulates options required to make a connection to a spread daemon.
SpreadOutConnector	An OutConnector for the spread daemon network.
SpreadReceiver	Implements a spread connection which is used to receive data via a single receiving thread.
SpreadUtilities	Utility methods for the spread-based transport.
SpreadWrapperImpl	This class encapsulates and manages a connection to the spread daemon.

Enum Summary

Enum	Description
SpreadWrapper.State	Describes the current state of the underlying connection.

Exception Summary

Exception	Description
ConnectionLostException	Indicates that the connection with the spread daemon was lost.
SendException	Exception indicating an error while sending something via a spread connection.
SerializeException	Indicates an error with the serialization.

Package rsb.transport.spread Description

Contains the implementation of the spread-based transport.

Author:

jwienke