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

Constructor Summary

Constructors

Constructor and Description
MemoryTopicImpl()

Method Summary

Modifier and Type	Method and Description
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, 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, parallelStream, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

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>