Package | Description |
---|---|
com.caucho.jms.cluster | |
com.caucho.jms.file | |
com.caucho.jms.jdbc | |
com.caucho.jms.memory | |
com.caucho.jms.queue |
Modifier and Type | Method and Description |
---|---|
void |
ClusterQueueImpl.addMessageCallback(MessageCallback<E> callback,
boolean isAutoAck) |
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) |
void |
ClusterQueueImpl.removeMessageCallback(MessageCallback<E> callback) |
Modifier and Type | Method and Description |
---|---|
void |
FileTopicImpl.send(java.lang.String msgId,
E payload,
int priority,
long timeout,
java.lang.String publisher) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcQueue.send(java.lang.String msgId,
E payload,
int priority,
long expireTime,
java.lang.String publisherId)
Sends the message to the queue.
|
Modifier and Type | Method and Description |
---|---|
void |
MemoryTopicImpl.send(java.lang.String msgId,
E payload,
int priority,
long timeout,
java.lang.String publisherId) |
Modifier and Type | Method and Description |
---|---|
void |
MessageQueue.addMessageCallback(MessageCallback<E> messageCallback,
boolean isAutoAck)
Registers a message callback with the queue.
|
protected boolean |
AbstractMemoryQueue.listen(com.caucho.jms.queue.EntryCallback<E> callback) |
E |
MessageQueue.receive(long expireTime,
boolean isAutoAck)
Synchronous/blocking message receiving.
|
E |
AbstractQueue.receive(long expireTime,
boolean isAutoAcknowledge)
Receives a message, blocking until expireTime if no message is
available.
|
E |
AbstractQueue.receive(long expireTime,
boolean isAutoAcknowledge,
QueueEntrySelector selector) |
void |
AbstractMemoryQueue.receive(long expireTime,
boolean isAutoAck,
QueueEntrySelector selector,
MessageCallback callback) |
void |
AbstractQueue.receive(long expireTime,
boolean isAutoAck,
QueueEntrySelector selector,
MessageCallback callback) |
QE |
AbstractMemoryQueue.receiveEntry(long expireTime,
boolean isAutoAck)
Primary message receiving, registers a callback for any new
message.
|
QueueEntry<E> |
MessageQueue.receiveEntry(long expireTime,
boolean isAutoAck)
Synchronous/blocking message receiving.
|
QE |
AbstractMemoryQueue.receiveEntry(long expireTime,
boolean isAutoAck,
QueueEntrySelector selector) |
QueueEntry<E> |
AbstractQueue.receiveEntry(long expireTime,
boolean isAutoAck,
QueueEntrySelector selector) |
void |
AbstractMemoryQueue.send(java.lang.String msgId,
E payload,
int priority,
long expireTime,
java.lang.String publisherId)
Sends a message to the queue
|
void |
MessageQueue.send(java.lang.String msgId,
E msg,
int priority,
long expireTime,
java.lang.String publisherId)
Sends a message to the destination
|
void |
MessageTopicSubscriber.send(java.lang.String msgId,
E msg,
int priority,
long expireTime,
java.lang.String publisherId)
Sends a message to the destination
|
void |
AbstractDestination.send(java.lang.String msgId,
E msg,
int priority,
long expires,
java.lang.String publisherId)
Sends a message to the queue
|