Interface | Description |
---|---|
Channel<T> |
Combined suscriber and publisher interface.
|
Converter<T,K> |
Interface to convert from T to K.
|
Publisher<T> |
Interface for components that allow messages to be published to them
|
Request<R,V> |
User: mrettig
Date: Jan 31, 2009
Time: 10:25:53 AM
|
RequestChannel<R,V> |
User: mrettig
Date: Jan 31, 2009
Time: 10:23:38 AM
|
Session |
Uniquely identifies a request/reply session.
|
SessionClosed<R> |
Message sent when a request session is closed.
|
Subscribable<T> |
Interface to subscribe to events on producing thread(s).
|
Subscriber<T> |
Interface for components that allow for message subscriptions
|
Class | Description |
---|---|
AsyncRequest<R,V> |
User: mrettig
Date: Jan 31, 2009
Time: 1:31:46 PM
|
BaseSubscription<T> |
Base implementation for all producer thread subscriptions.
|
BatchSubscriber<T> |
Batches events for the consuming thread.
|
ChannelSubscription<T> |
Subscription for events on a channel.
|
CompositeChannel<T> |
User: mrettig
Date: Sep 6, 2009
|
KeyedBatchSubscriber<K,T> |
Channel subscription that drops duplicates based upon a key.
|
LastSubscriber<T> |
Subscribes to last event received on the channel.
|
MemoryChannel<T> |
Conduit for exchanging messages between threads.
|
MemoryRequestChannel<R,V> |
User: mrettig
Date: Jan 31, 2009
Time: 10:42:42 AM
|
RecyclingBatchSubscriber<T> |
Batches events for the consuming thread.
|
SubscriberList<T> |
User: mrettig
Date: Aug 29, 2009
|
Copyright © 2017. All Rights Reserved.