| Interface | Description |
|---|---|
| RemoteQueueAPI<E extends java.io.Serializable> |
API for the remote queues
|
| ServerDestination<E extends java.io.Serializable> |
Implements a cluster receive queue.
|
| Class | Description |
|---|---|
| ClusterQueueActor |
Implements a cluster send queue.
|
| ClusterQueueHandle |
Implements a cluster receive queue.
|
| ClusterQueueImpl<E extends java.io.Serializable> |
Implements a cluster receive queue.
|
| ClusterQueueSender |
Sends cluster queue requests.
|
| ClusterQueueTriadActor |
Implements a cluster send queue.
|
| ClusterTopicImpl<E extends java.io.Serializable> |
Workflow
ClusterTopic sends out a
SubscribeTopic message to Triad
Traid stores all the topic subscriptions
Message Producer sends out a TriadTopicMessage to the Triad
Triad node sends out TriadTopicMessage to all the topic subscribers
|
| MessageSystem |
Service for handling the cluster heartbeat messages
|
| PollQuery |
Implements a cluster receive queue.
|
| PollResult |
Implements a cluster receive queue.
|
| ReceiveQuery |
Implements a cluster receive queue.
|
| RemoteConsumer | |
| RemoveMessage |
Notification that a message has been received from the queue
|
| SendMessage |
Implements a cluster receive queue.
|
| SubscribeTopic |
Topic Subscriber sends this object to Triad Pod to
register itself with the Triad pod.
|
| TopicMessage |
Topic Subscribers receives the message from the Triad Pod.
|
| TriadReceiveQuery |
Implements a cluster receive queue.
|
| TriadSendMessage |
Implements a cluster receive queue.
|
| TriadTopicMessage |
Implements a cluster receive queue.
|