com.caucho.jms.cluster
Class JmsHmuxClient

java.lang.Object
  com.caucho.jms.cluster.JmsHmuxClient

public class JmsHmuxClient
extends java.lang.Object

Implements a cluster send queue.

Constructor Summary

JmsHmuxClient()

Method Summary

void	acknowledge(java.lang.String msgId)
void	addHost(java.lang.String host)
protected java.lang.String	dbgId()
protected void	enqueue(java.lang.String queueName, MessageImpl msg, int priority, long expires) Adds the message to the persistent store.
void	generateMessageID(java.lang.StringBuilder cb)
java.lang.String	getName()
void	init()
MessageImpl	receive(java.lang.String queueName, boolean isAutoAck, java.lang.String subscriber) Polls the next message from the store.
void	rollback(java.lang.String msgId)
void	setCluster(java.lang.String clusterName)
void	setName(java.lang.String name)

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsHmuxClient

public JmsHmuxClient()

Method Detail

setName

public void setName(java.lang.String name)

getName

public java.lang.String getName()

setCluster

public void setCluster(java.lang.String clusterName)

addHost

public void addHost(java.lang.String host)

init

public void init()

generateMessageID

public void generateMessageID(java.lang.StringBuilder cb)

enqueue

protected void enqueue(java.lang.String queueName,
                       MessageImpl msg,
                       int priority,
                       long expires)
                throws JMSException

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

Throws:

JMSException

receive

public MessageImpl receive(java.lang.String queueName,
                           boolean isAutoAck,
                           java.lang.String subscriber)
                    throws JMSException

Polls the next message from the store.

Throws:

JMSException

acknowledge

public void acknowledge(java.lang.String msgId)

rollback

public void rollback(java.lang.String msgId)

dbgId

protected java.lang.String dbgId()