| Modifier and Type | Interface and Description |
|---|---|
interface |
StoppableExecutor |
| Modifier and Type | Class and Description |
|---|---|
class |
AsyncDispatch<T>
A
Dispatch implementation which delivers messages asynchronously. |
class |
AsyncReceive<T>
Receives messages asynchronously.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ObjectConnection
Manages a set of incoming and outgoing channels between 2 peers.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
Connection<T>
A messaging endpoint which allows push-style dispatch and pull-style receive.
|
interface |
DisconnectAwareConnection<T>
A
DisconnectAwareConnection is a connection capable of executing an action when
the other side of connection disconnects before the stop method is called on this connection. |
interface |
MultiChannelConnection<T> |
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultObjectConnection |
class |
DelegatingConnection<T> |
class |
DisconnectAwareConnectionDecorator<T>
A
DisconnectAwareConnection implementation that decorates an existing connection, adding disconnect awareness. |
class |
EagerReceiveBuffer<T>
Continuously consumes from on or more receivers, serialising to an in memory buffer for synchronous consumption.
|
class |
MessageHub |
class |
ProtocolStack<T> |
class |
SynchronizedDispatch<T>
Connection decorator that synchronizes dispatching.
|
| Constructor and Description |
|---|
DefaultObjectConnection(Addressable addressable,
AsyncStoppable stopControl,
OutgoingMethodInvocationHandler outgoing,
IncomingMethodInvocationHandler incoming) |
| Modifier and Type | Class and Description |
|---|---|
class |
MulticastConnection<T> |
class |
SocketConnection<T> |
class |
TcpIncomingConnector<T> |
Copyright © 2013. All rights reserved