| 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 |
FileQueue<X extends java.io.Serializable>
A JMS queue backed by a file-based database.
|
class |
MemoryQueue<X>
A JMS queue stored in memory.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ClusterQueueImpl<E extends java.io.Serializable>
Implements a cluster receive queue.
|
| Modifier and Type | Method and Description |
|---|---|
AbstractQueue<E> |
ClusterTopicImpl.createSubscriber(java.lang.String publisher,
java.lang.String name,
boolean noLocal) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterTopicImpl.closeSubscriber(AbstractQueue<E> queue) |
| Modifier and Type | Class and Description |
|---|---|
class |
TemporaryQueueImpl
A temporary queue
|
| Modifier and Type | Field and Description |
|---|---|
protected AbstractQueue |
QueueBrowserImpl._queue |
| Constructor and Description |
|---|
MessageBrowserImpl(JmsSession session,
AbstractQueue queue,
java.lang.String messageSelector) |
QueueSenderImpl(JmsSession session,
AbstractQueue 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.
|
| Modifier and Type | Method and Description |
|---|---|
AbstractQueue<E> |
FileTopicImpl.createSubscriber(java.lang.String publisher,
java.lang.String name,
boolean noLocal) |
| Modifier and Type | Method and Description |
|---|---|
void |
FileTopicImpl.closeSubscriber(AbstractQueue<E> queue) |
| Modifier and Type | Class and Description |
|---|---|
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.
|
| Modifier and Type | Method and Description |
|---|---|
AbstractQueue<E> |
MemoryTopicImpl.createSubscriber(java.lang.String publisher,
java.lang.String name,
boolean noLocal) |
| Modifier and Type | Method and Description |
|---|---|
void |
MemoryTopicImpl.closeSubscriber(AbstractQueue<E> queue) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractMemoryQueue<E,QE extends QueueEntry<E>>
Provides abstract implementation for a memory queue.
|
class |
PollingQueue<E>
Implements an queue which polls the data periodically.
|
| Modifier and Type | Method and Description |
|---|---|
abstract AbstractQueue<E> |
AbstractTopic.createSubscriber(java.lang.String publisher,
java.lang.String name,
boolean noLocal) |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
AbstractTopic.closeSubscriber(AbstractQueue<E> subscriber) |
| Constructor and Description |
|---|
QueueAdmin(AbstractQueue queue) |