com.caucho.jms.memory
Class MemoryQueue

java.lang.Object
  java.util.AbstractCollection<E>
      java.util.AbstractQueue
          com.caucho.jms.queue.AbstractDestination
              com.caucho.jms.queue.AbstractQueue
                  com.caucho.jms.memory.MemoryQueue

All Implemented Interfaces:

HandleAware, java.io.Serializable, java.lang.Iterable, java.util.Collection, java.util.concurrent.BlockingQueue, java.util.Queue, Destination

Direct Known Subclasses:

FileSubscriberQueue, MemorySubscriberQueue, TemporaryQueueImpl

public class MemoryQueue
extends AbstractQueue

Implements a memory queue.

See Also:

Serialized Form

Field Summary

Fields inherited from class com.caucho.jms.queue.AbstractDestination

_messageFactory

Constructor Summary

MemoryQueue()

Method Summary

void	acknowledge(java.lang.String msgId) Acknowledges the receipt of a message
java.util.ArrayList<MessageImpl>	getBrowserList()
int	getQueueSize() Returns the queue size
java.lang.String	getUrl() Returns the configuration URL.
boolean	hasMessage() Returns true if a message is available.
MessageImpl	receive(boolean isAutoAck) Polls the next message from the store.
void	rollback(java.lang.String msgId) Rolls back the receipt of a message
void	send(JmsSession session, MessageImpl msg, int priority, long expires) Adds the message to the persistent store.

Methods inherited from class com.caucho.jms.queue.AbstractQueue

addListenerException, addMessageAvailableListener, close, getConsumerCount, getListenerFailCountTotal, getListenerFailLastTime, init, notifyMessageAvailable, postConstruct, removeMessageAvailableListener, setQueueName, startPoll, stopPoll

Methods inherited from class com.caucho.jms.queue.AbstractDestination

drainTo, drainTo, generateMessageID, generateMessageID, getJMSDestination, getName, getQueueName, getReadConsumer, getTopicName, getWriteSession, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, setName, setSerializationHandle, size, take, toString

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.jms.Queue

getQueueName, toString

Methods inherited from interface java.util.concurrent.BlockingQueue

add, contains, remove

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, removeAll, retainAll, toArray, toArray

Constructor Detail

MemoryQueue

public MemoryQueue()

Method Detail

getUrl

public java.lang.String getUrl()

Returns the configuration URL.

Overrides:

getUrl in class AbstractDestination

getQueueSize

public int getQueueSize()

Returns the queue size

Overrides:

getQueueSize in class AbstractQueue

send

public void send(JmsSession session,
                 MessageImpl msg,
                 int priority,
                 long expires)

Adds the message to the persistent store. Called if there are no active listeners.

Specified by:

send in class AbstractDestination

hasMessage

public boolean hasMessage()

Returns true if a message is available.

Overrides:

hasMessage in class AbstractDestination

receive

public MessageImpl receive(boolean isAutoAck)

Polls the next message from the store.

Overrides:

receive in class AbstractDestination

Parameters:

isAutoAck - if true, automatically acknowledge the message

getBrowserList

public java.util.ArrayList<MessageImpl> getBrowserList()

Overrides:

getBrowserList in class AbstractQueue

acknowledge

public void acknowledge(java.lang.String msgId)

Acknowledges the receipt of a message

Overrides:

acknowledge in class AbstractDestination

Parameters:

msgId - message to acknowledge

rollback

public void rollback(java.lang.String msgId)

Rolls back the receipt of a message

Overrides:

rollback in class AbstractDestination