| Constructor and Description |
|---|
DaemonClientInputForwarder(java.io.InputStream inputStream,
BuildClientMetaData clientMetadata,
Dispatch<? super IoCommand> dispatch) |
DaemonClientInputForwarder(java.io.InputStream inputStream,
BuildClientMetaData clientMetadata,
Dispatch<? super IoCommand> dispatch,
ExecutorFactory executorFactory,
int bufferSize) |
| Modifier and Type | Class and Description |
|---|---|
class |
AsyncListenerBroadcast<T>
An
AsyncListenerBroadcast is a ListenerBroadcast which dispatches events to listeners asynchronously
to the generation of the events. |
class |
ListenerBroadcast<T>
Manages a set of listeners of type T.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ListenerBroadcast.add(Dispatch<MethodInvocation> dispatch)
Adds a
Dispatch to receive events from this broadcast. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
Actor
An
Actor dispatches method calls to a target object in a thread-safe manner. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
StoppableDispatch<T> |
| Modifier and Type | Class and Description |
|---|---|
class |
AsyncDispatch<T>
A
Dispatch implementation which delivers messages asynchronously. |
class |
BroadcastDispatch<T> |
class |
ContextClassLoaderDispatch<T> |
class |
FailureHandlingDispatch<T> |
class |
QueuingDispatch<T>
Queues messages until a receiver has been connected.
|
class |
ReflectionDispatch |
| Modifier and Type | Method and Description |
|---|---|
void |
BroadcastDispatch.add(Dispatch<MethodInvocation> dispatch) |
void |
QueuingDispatch.dispatchTo(Dispatch<? super T> dispatch)
Dispatches to the given handler.
|
void |
AsyncReceive.dispatchTo(Dispatch<? super T> dispatch)
Starts dispatching to the given dispatch.
|
void |
AsyncDispatch.dispatchTo(Dispatch<? super T> dispatch)
Starts dispatching messages to the given handler.
|
| Constructor and Description |
|---|
AsyncDispatch(java.util.concurrent.Executor executor,
Dispatch<? super T> dispatch) |
AsyncDispatch(java.util.concurrent.Executor executor,
Dispatch<? super T> dispatch,
int maxQueueSize) |
AsyncReceive(java.util.concurrent.Executor executor,
Dispatch<? super T> dispatch) |
AsyncReceive(java.util.concurrent.Executor executor,
Dispatch<? super T> dispatch,
java.lang.Runnable onReceiversExhausted) |
ContextClassLoaderDispatch(Dispatch<? super T> dispatch,
java.lang.ClassLoader contextClassLoader) |
FailureHandlingDispatch(Dispatch<? super T> dispatch,
DispatchFailureHandler<? super T> handler) |
ProxyDispatchAdapter(Dispatch<? super MethodInvocation> dispatch,
java.lang.Class<T> type,
java.lang.Class<?>... extraTypes) |
| Modifier and Type | Method and Description |
|---|---|
void |
ObjectConnection.addIncoming(java.lang.Class<?> type,
Dispatch<? super MethodInvocation> dispatch)
Registers a handler for incoming messages on the given type.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
AsyncConnection<T>
A messaging endpoint which allows push-style dispatch and receive.
|
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. |
| Modifier and Type | Class and Description |
|---|---|
class |
AsyncConnectionAdapter<T>
Adapts a
Connection into an AsyncConnection. |
class |
DelegatingConnection<T> |
class |
DisconnectAwareConnectionDecorator<T>
A
DisconnectAwareConnection implementation that decorates an existing connection, adding disconnect awareness. |
class |
GroupMessageFilter
Filters messages for unknown groups.
|
class |
MethodInvocationMarshallingDispatch |
class |
MethodInvocationUnmarshallingDispatch |
class |
SynchronizedDispatch<T>
Connection decorator that synchronizes dispatching.
|
| Modifier and Type | Method and Description |
|---|---|
Dispatch<java.lang.Object> |
MessageHub.addMulticastOutgoing(java.lang.String channel) |
Dispatch<T> |
MultiChannelConnection.addOutgoingChannel(java.lang.String channelKey)
Adds a destination for outgoing messages on the given channel.
|
Dispatch<java.lang.Object> |
MessageHub.addUnicastOutgoing(java.lang.String channel) |
| Modifier and Type | Method and Description |
|---|---|
void |
IncomingMethodInvocationHandler.addIncoming(java.lang.Class<?> type,
Dispatch<? super MethodInvocation> dispatch) |
void |
DefaultObjectConnection.addIncoming(java.lang.Class<?> type,
Dispatch<? super MethodInvocation> dispatch) |
void |
MessageHub.addIncoming(java.lang.String channel,
Dispatch<java.lang.Object> dispatch) |
void |
MultiChannelConnection.addIncomingChannel(java.lang.String channelKey,
Dispatch<T> dispatch)
Adds a handler for incoming messages on the given channel.
|
void |
AsyncConnectionAdapter.dispatchTo(Dispatch<? super T> handler) |
void |
AsyncConnection.dispatchTo(Dispatch<? super T> handler)
Adds a handler to receive incoming messages.
|
| Constructor and Description |
|---|
GroupMessageFilter(java.lang.String group,
Dispatch<? super DiscoveryMessage> dispatch) |
MethodInvocationMarshallingDispatch(Dispatch<? super Message> dispatch) |
MethodInvocationUnmarshallingDispatch(Dispatch<? super Message> dispatch,
java.lang.ClassLoader classLoader) |
WorkerProtocol(Dispatch<java.lang.Object> worker) |
| Modifier and Type | Class and Description |
|---|---|
class |
MulticastConnection<T> |
class |
SocketConnection<T> |
Copyright © 2013. All rights reserved