| Constructor and Description |
|---|
DaemonClientInputForwarder(InputStream inputStream,
BuildClientMetaData clientMetadata,
Dispatch<? super IoCommand> dispatch) |
DaemonClientInputForwarder(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(Executor executor,
Dispatch<? super T> dispatch) |
AsyncDispatch(Executor executor,
Dispatch<? super T> dispatch,
int maxQueueSize) |
AsyncReceive(Executor executor,
Dispatch<? super T> dispatch) |
AsyncReceive(Executor executor,
Dispatch<? super T> dispatch,
Runnable onReceiversExhausted) |
ContextClassLoaderDispatch(Dispatch<? super T> dispatch,
ClassLoader contextClassLoader) |
FailureHandlingDispatch(Dispatch<? super T> dispatch,
DispatchFailureHandler<? super T> handler) |
ProxyDispatchAdapter(Dispatch<? super MethodInvocation> dispatch,
Class<T> type,
Class<?>... extraTypes) |
| Modifier and Type | Method and Description |
|---|---|
void |
ObjectConnection.addIncoming(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<Object> |
MessageHub.addMulticastOutgoing(String channel) |
Dispatch<T> |
MultiChannelConnection.addOutgoingChannel(String channelKey)
Adds a destination for outgoing messages on the given channel.
|
Dispatch<Object> |
MessageHub.addUnicastOutgoing(String channel) |
| Modifier and Type | Method and Description |
|---|---|
void |
IncomingMethodInvocationHandler.addIncoming(Class<?> type,
Dispatch<? super MethodInvocation> dispatch) |
void |
DefaultObjectConnection.addIncoming(Class<?> type,
Dispatch<? super MethodInvocation> dispatch) |
void |
MessageHub.addIncoming(String channel,
Dispatch<Object> dispatch) |
void |
MultiChannelConnection.addIncomingChannel(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(String group,
Dispatch<? super DiscoveryMessage> dispatch) |
MethodInvocationMarshallingDispatch(Dispatch<? super Message> dispatch) |
MethodInvocationUnmarshallingDispatch(Dispatch<? super Message> dispatch,
ClassLoader classLoader) |
WorkerProtocol(Dispatch<Object> worker) |
| Modifier and Type | Class and Description |
|---|---|
class |
MulticastConnection<T> |
class |
SocketConnection<T> |
Copyright © 2013. All rights reserved