com.caucho.jms.hemp
Class HempTopic

java.lang.Object
  java.util.AbstractCollection<E>
      java.util.AbstractQueue
          com.caucho.jms.queue.AbstractDestination
              com.caucho.jms.queue.AbstractTopic
                  com.caucho.jms.hemp.HempTopic

All Implemented Interfaces:

HandleAware, java.io.Serializable, java.lang.Iterable, java.util.Collection, java.util.concurrent.BlockingQueue, java.util.Queue, Destination, Topic

public class HempTopic
extends AbstractTopic

Implements an hemp topic.

See Also:

Serialized Form

Field Summary

Fields inherited from class com.caucho.jms.queue.AbstractDestination

_messageFactory

Constructor Summary

HempTopic()

Method Summary

void	closeSubscriber(AbstractQueue queue)
AbstractQueue	createSubscriber(JmsSession session, java.lang.String name, boolean noLocal)
java.lang.String	getUrl() Returns the configuration URL.
void	init()
void	send(JmsSession session, MessageImpl msg, int priority, long timeout) Sends a message to the queue
void	sendMessage(java.lang.String to, java.lang.String from, java.io.Serializable value)
void	sendMessageError(java.lang.String to, java.lang.String from, java.io.Serializable value, BamError error)
void	setBroker(BamBroker broker) Sets the broker

Methods inherited from class com.caucho.jms.queue.AbstractTopic

postConstruct, receive, setTopicName

Methods inherited from class com.caucho.jms.queue.AbstractDestination

acknowledge, addMessageAvailableListener, close, drainTo, drainTo, generateMessageID, generateMessageID, getJMSDestination, getName, getQueueName, getReadConsumer, getTopicName, getWriteSession, hasMessage, iterator, offer, offer, peek, poll, poll, put, receive, remainingCapacity, removeMessageAvailableListener, rollback, setName, setSerializationHandle, size, take, 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

HempTopic

public HempTopic()

Method Detail

setBroker

public void setBroker(BamBroker broker)

Sets the broker

getUrl

public java.lang.String getUrl()

Returns the configuration URL.

Overrides:

getUrl in class AbstractDestination

init

public void init()

Overrides:

init in class AbstractTopic

createSubscriber

public AbstractQueue createSubscriber(JmsSession session,
                                      java.lang.String name,
                                      boolean noLocal)

Specified by:

createSubscriber in class AbstractTopic

closeSubscriber

public void closeSubscriber(AbstractQueue queue)

Specified by:

closeSubscriber in class AbstractTopic

sendMessage

public void sendMessage(java.lang.String to,
                        java.lang.String from,
                        java.io.Serializable value)

sendMessageError

public void sendMessageError(java.lang.String to,
                             java.lang.String from,
                             java.io.Serializable value,
                             BamError error)

send

public void send(JmsSession session,
                 MessageImpl msg,
                 int priority,
                 long timeout)
          throws JMSException

Description copied from class: AbstractDestination

Sends a message to the queue

Specified by:

send in class AbstractDestination

Throws:

JMSException