com.caucho.jms.file
Class FileTopicImpl<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.file.FileTopicImpl<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:
- FileTopic, FileTopic
public class FileTopicImpl<E>
- extends AbstractTopic<E>
Implements a file topic.
- See Also:
- Serialized Form
Methods inherited from class com.caucho.jms.queue.AbstractTopic |
drainTo, drainTo, 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 |
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 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 |
FileTopicImpl
public FileTopicImpl()
FileTopicImpl
protected FileTopicImpl(Path path,
java.lang.String name,
java.lang.String serverId)
setPath
public void setPath(Path path)
- Sets the path to the backing database
getUrl
public java.lang.String getUrl()
- Returns the JMS configuration url.
- Overrides:
getUrl
in class AbstractDestination<E>
init
public void init()
- Overrides:
init
in class AbstractTopic<E>
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>
send
public void send(java.lang.String msgId,
E payload,
int priority,
long timeout,
java.lang.String publisher)
throws MessageException
- Description copied from class:
AbstractDestination
- Sends a message to the queue
- Overrides:
send
in class AbstractDestination<E>
- Throws:
MessageException
toString
public java.lang.String toString()
- Specified by:
toString
in interface Topic
- Overrides:
toString
in class AbstractDestination<E>