com.caucho.jms.file
Class FileSubscriberQueue<E>

java.lang.Object
  java.util.AbstractCollection<E>
      java.util.AbstractQueue<E>
          com.caucho.jms.queue.AbstractDestination<E>
              com.caucho.jms.queue.AbstractQueue<E>
                  com.caucho.jms.queue.AbstractMemoryQueue<E,MemoryQueueEntry<E>>
                      com.caucho.jms.memory.MemoryQueueImpl<E>
                          com.caucho.jms.file.FileSubscriberQueue<E>

All Implemented Interfaces:

HandleAware, MessageQueue<E>, MessageTopicSubscriber<E>, java.io.Serializable, java.lang.Iterable<E>, java.util.Collection<E>, java.util.concurrent.BlockingQueue<E>, java.util.Queue<E>, Destination

public class FileSubscriberQueue<E>
extends MemoryQueueImpl<E>
implements MessageTopicSubscriber<E>

Implements a file queue.

See Also:

Serialized Form

Method Summary

void	send(java.lang.String msgId, E msg, int priority, long timeout, java.lang.String publisherId) Sends a message to the queue
java.lang.String	toString()

Methods inherited from class com.caucho.jms.memory.MemoryQueueImpl

acknowledge, getUrl, writeEntry

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

acknowledge, addMessageCallback, addQueueEntry, dispatchMessage, getBrowserList, getConsumerCount, getMessageIds, getQueueSize, getQueueSizeMax, getReceiverCount, hasMessage, listen, readEntry, readEntry, readPayload, receive, receiveEntry, receiveEntry, removeEntry, removeMessageCallback, rollback, setQueueSizeMax

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

addListenerException, close, drainTo, drainTo, getListenerFailCountTotal, getListenerFailLastTime, init, iterator, offer, offer, peek, poll, poll, postConstruct, put, receive, receive, remainingCapacity, setQueueName, size, take

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

generateMessageID, generateMessageID, getJMSDestination, getName, getQueueName, getTopicName, setName, setSerializationHandle

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, wait, wait, wait

Methods inherited from interface javax.jms.Queue

getQueueName

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

Method Detail

send

public void send(java.lang.String msgId,
                 E msg,
                 int priority,
                 long timeout,
                 java.lang.String publisherId)

Description copied from class: AbstractMemoryQueue

Sends a message to the queue

Specified by:

send in interface MessageQueue<E>

Specified by:

send in interface MessageTopicSubscriber<E>

Overrides:

send in class AbstractMemoryQueue<E,MemoryQueueEntry<E>>

toString

public java.lang.String toString()

Overrides:

toString in class AbstractDestination<E>