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

java.lang.Object
  extended by java.util.AbstractCollection<E>
      extended by java.util.AbstractQueue<E>
          extended by com.caucho.jms.queue.AbstractDestination<E>
              extended by com.caucho.jms.queue.AbstractQueue<E>
                  extended by com.caucho.jms.queue.AbstractMemoryQueue<E,MemoryQueueEntry<E>>
                      extended by com.caucho.jms.memory.MemoryQueueImpl<E>
                          extended by 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>