Package | Description |
---|---|
com.caucho.jms.cluster | |
com.caucho.jms.file | |
com.caucho.jms.memory | |
com.caucho.jms.queue |
Modifier and Type | Method and Description |
---|---|
QueueEntry<E> |
ClusterQueueImpl.receiveEntry(long expireTime,
boolean isAutoAck)
Primary message receiving, registers a callback for any new
message.
|
QueueEntry<E> |
ClusterQueueImpl.receiveEntry(long expireTime,
boolean isAutoAck,
QueueEntrySelector selector) |
Modifier and Type | Class and Description |
---|---|
class |
FileQueueEntry<E>
Entry in a file queue
|
Modifier and Type | Class and Description |
---|---|
class |
MemoryQueueEntry<E>
Entry in a memory queue.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMemoryQueue<E,QE extends QueueEntry<E>>
Provides abstract implementation for a memory queue.
|
Modifier and Type | Method and Description |
---|---|
QueueEntry<E> |
MessageQueue.receiveEntry(long expireTime,
boolean isAutoAck)
Synchronous/blocking message receiving.
|
QueueEntry<E> |
AbstractQueue.receiveEntry(long expireTime,
boolean isAutoAck)
Primary message receiving, registers a callback for any new
message.
|
QueueEntry<E> |
AbstractQueue.receiveEntry(long expireTime,
boolean isAutoAck,
QueueEntrySelector selector) |
Modifier and Type | Method and Description |
---|---|
java.util.ArrayList<? extends QueueEntry<E>> |
AbstractQueue.getBrowserList() |