com.caucho.jms.cluster
Class ClientTopic

java.lang.Object
  com.caucho.jms.queue.AbstractDestination
      com.caucho.jms.queue.AbstractTopic
          com.caucho.jms.queue.PollingTopic
              com.caucho.jms.cluster.ClientTopic

All Implemented Interfaces:

AlarmListener, java.util.EventListener, Destination, Topic

public class ClientTopic
extends PollingTopic

Implements a cluster send topic.

Field Summary

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

_messageFactory

Constructor Summary

ClientTopic()

ClientTopic(java.lang.String name)

Method Summary

void	addHost(java.lang.String host)
void	closeSubscriber(AbstractQueue queue)
AbstractQueue	createSubscriber(JmsSession session, java.lang.String name, boolean noLocal)
void	generateMessageID(java.lang.StringBuilder sb)
void	init()
protected void	run()
void	send(JmsSession session, MessageImpl msg, long timeout)
void	setCluster(java.lang.String clusterName)
void	setName(java.lang.String name)

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

handleAlarm, isPolling, setPollPeriod, startPoll, stopPoll

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

getTopicName, postConstruct, receive, setTopicName, toString

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

acknowledge, addConsumer, close, generateMessageID, getJMSDestination, getName, getQueueName, getUrl, hasMessage, receive, removeConsumer, rollback, writeReplace

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ClientTopic

public ClientTopic()

ClientTopic

public ClientTopic(java.lang.String name)

Method Detail

setName

public void setName(java.lang.String name)

Overrides:

setName in class AbstractDestination

setCluster

public void setCluster(java.lang.String clusterName)

addHost

public void addHost(java.lang.String host)

init

public void init()

Overrides:

init in class AbstractTopic

generateMessageID

public void generateMessageID(java.lang.StringBuilder sb)

Overrides:

generateMessageID in class AbstractDestination

send

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

Specified by:

send in class AbstractDestination

Throws:

JMSException

run

protected void run()

Overrides:

run in class PollingTopic

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