com.caucho.jms.memory
Class MemoryTopicImpl<E>
java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractQueue<E>
com.caucho.jms.queue.AbstractDestination<E>
com.caucho.jms.queue.AbstractTopic<E>
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
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 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 |
MemoryTopicImpl
public MemoryTopicImpl()
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>