com.caucho.jms.memory
Class MemoryTopicImpl<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.AbstractTopic<E>
                  extended by com.caucho.jms.memory.MemoryTopicImpl<E>
All Implemented Interfaces:
HandleAware, java.io.Serializable, java.lang.Iterable<E>, java.util.Collection<E>, java.util.concurrent.BlockingQueue<E>, java.util.Queue<E>, Destination, Topic
Direct Known Subclasses:
MemoryTopic, MemoryTopic

public class MemoryTopicImpl<E>
extends AbstractTopic<E>

Implements a memory topic.

See Also:
Serialized Form

Constructor Summary
MemoryTopicImpl()
           
 
Method Summary
 void closeSubscriber(AbstractQueue<E> queue)
           
 AbstractQueue<E> createSubscriber(java.lang.String publisher, java.lang.String name, boolean noLocal)
           
 java.lang.String getUrl()
          Returns the configuration URL.
 void send(java.lang.String msgId, E payload, int priority, long timeout, java.lang.String publisherId)
          Sends a message to the queue
 
Methods inherited from class com.caucho.jms.queue.AbstractTopic
drainTo, drainTo, init, iterator, offer, offer, peek, poll, poll, postConstruct, put, receive, remainingCapacity, setTopicName, size, take
 
Methods inherited from class com.caucho.jms.queue.AbstractDestination
acknowledge, close, generateMessageID, generateMessageID, getJMSDestination, getName, getQueueName, getTopicName, hasMessage, rollback, setName, setSerializationHandle, 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.Topic
getTopicName, 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

MemoryTopicImpl

public MemoryTopicImpl()
Method Detail

getUrl

public java.lang.String getUrl()
Returns the configuration URL.

Overrides:
getUrl in class AbstractDestination<E>

send

public void send(java.lang.String msgId,
                 E payload,
                 int priority,
                 long timeout,
                 java.lang.String publisherId)
          throws MessageException
Description copied from class: AbstractDestination
Sends a message to the queue

Overrides:
send in class AbstractDestination<E>
Throws:
MessageException

createSubscriber

public AbstractQueue<E> createSubscriber(java.lang.String publisher,
                                         java.lang.String name,
                                         boolean noLocal)
Specified by:
createSubscriber in class AbstractTopic<E>

closeSubscriber

public void closeSubscriber(AbstractQueue<E> queue)
Specified by:
closeSubscriber in class AbstractTopic<E>