com.caucho.jms.cluster
Class ClientQueue

java.lang.Object
  com.caucho.jms.queue.AbstractDestination
      com.caucho.jms.queue.AbstractQueue
          com.caucho.jms.queue.PollingQueue
              com.caucho.jms.cluster.ClientQueue

All Implemented Interfaces:

AlarmListener, java.util.EventListener, Destination, Queue

public class ClientQueue
extends PollingQueue

Implements a cluster send queue.

Field Summary

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

_messageFactory

Constructor Summary

ClientQueue()

ClientQueue(java.lang.String name)

Method Summary

void	acknowledge(java.lang.String msgId) Acknowledge receipt of the message.
void	addHost(java.lang.String host)
void	generateMessageID(java.lang.StringBuilder sb)
void	init()
protected void	poll()
MessageImpl	receive(boolean isAutoAck) Polls the next message from the store.
void	rollback(java.lang.String msgId) Rollback the message read.
void	send(JmsSession session, MessageImpl msg, long expires) Adds the message to the persistent store.
void	setCluster(java.lang.String clusterName)
void	setName(java.lang.String name)

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

handleAlarm, setPollPeriod, startPoll, stopPoll

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

addConsumer, addListenerException, close, createBrowser, getConsumerCount, getListenerFailCountTotal, getListenerFailLastTime, getQueueSize, notifyMessageAvailable, postConstruct, removeConsumer, setQueueName, toString

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

generateMessageID, getJMSDestination, getName, getQueueName, getTopicName, getUrl, hasMessage, writeReplace

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jms.Queue

getQueueName

Constructor Detail

ClientQueue

public ClientQueue()

ClientQueue

public ClientQueue(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 AbstractQueue

generateMessageID

public void generateMessageID(java.lang.StringBuilder sb)

Overrides:

generateMessageID in class AbstractDestination

send

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

Adds the message to the persistent store. Called if there are no active listeners.

Specified by:

send in class AbstractDestination

Throws:

JMSException

receive

public MessageImpl receive(boolean isAutoAck)
                    throws JMSException

Polls the next message from the store. If no message is available, wait for the timeout.

Overrides:

receive in class AbstractDestination

Parameters:

isAutoAck - if true, automatically acknowledge the message

Throws:

JMSException

poll

protected void poll()

Overrides:

poll in class PollingQueue

acknowledge

public void acknowledge(java.lang.String msgId)

Description copied from class: AbstractDestination

Acknowledge receipt of the message.

Overrides:

acknowledge in class AbstractDestination

rollback

public void rollback(java.lang.String msgId)

Description copied from class: AbstractDestination

Rollback the message read.

Overrides:

rollback in class AbstractDestination