| Package | Description |
|---|---|
| com.caucho.jms | |
| com.caucho.jms.cluster | |
| com.caucho.jms.connection | |
| com.caucho.jms.file | |
| com.caucho.jms.jdbc | |
| com.caucho.jms.memory | |
| com.caucho.jms.queue |
| Modifier and Type | Class and Description |
|---|---|
class |
ClusterQueue<X extends java.io.Serializable>
ClusterQueue provides reliable point to point transfer of messages.
|
class |
ClusterTopic<X extends java.io.Serializable>
ClusterTopic provides reliable Publish/Subscribe message model
communication between the nodes in the Resin cluster.
Following example shows how to make two nodes in resin cluster
communicate between each other using cluster topic.
|
class |
FileQueue<X extends java.io.Serializable>
A JMS queue backed by a file-based database.
|
class |
FileTopic<E>
A JMS topic backed by a file-based database.
|
class |
MemoryQueue<X>
A JMS queue stored in memory.
|
class |
MemoryTopic
A JMS topic stored in memory.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ClusterQueueImpl<E extends java.io.Serializable>
Implements a cluster receive queue.
|
class |
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
|
| Modifier and Type | Class and Description |
|---|---|
class |
TemporaryQueueImpl
A temporary queue
|
class |
TemporaryTopicImpl
A basic topic.
|
| Modifier and Type | Field and Description |
|---|---|
protected AbstractDestination |
MessageProducerImpl._queue |
| Modifier and Type | Method and Description |
|---|---|
protected AbstractDestination<E> |
MessageConsumerImpl.getDestination()
Returns the destination
|
| Modifier and Type | Method and Description |
|---|---|
void |
JmsSession.send(AbstractDestination queue,
Message appMessage,
int deliveryMode,
int priority,
long timeout)
Adds a message to the session message queue.
|
| Constructor and Description |
|---|
MessageProducerImpl(JmsSession session,
AbstractDestination queue) |
| Modifier and Type | Class and Description |
|---|---|
class |
FileQueueImpl<E extends java.io.Serializable>
A JMS queue backed by a file-based database.
|
class |
FileSubscriberQueue<E>
Implements a file queue.
|
class |
FileTopicImpl<E>
Implements a file topic.
|
| Modifier and Type | Class and Description |
|---|---|
class |
JdbcDestination
Represents a JDBC destination.
|
class |
JdbcQueue<E>
A jdbc queue.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MemoryQueueImpl<E>
Implements a memory queue.
|
class |
MemorySubscriberQueue<E>
Implements a memory queue.
|
class |
MemoryTopicImpl<E>
Implements a memory topic.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractMemoryQueue<E,QE extends QueueEntry<E>>
Provides abstract implementation for a memory queue.
|
class |
AbstractQueue<E>
Implements an abstract queue.
|
class |
AbstractTopic<E>
Implements an abstract topic.
|
class |
PollingQueue<E>
Implements an queue which polls the data periodically.
|
class |
PollingTopic<E>
Implements an topic which polls the data periodically.
|