com.caucho.jms.cluster
Class ClusterQueueSender

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

public class ClusterQueueSender
extends java.lang.Object

Sends cluster queue requests.

Constructor Summary

ClusterQueueSender(BamTriadSender bamSender, byte[] queueHash)

Method Summary

protected java.lang.String	getAddress()
protected BamTriadSender	getBamSender()
boolean	isPrimarySelf()
void	receive(long expireTime, boolean isAutoAck, QueueEntrySelector selector, MessageCallback<?> messageCallback)
void	send(java.lang.String msgId, java.io.Serializable payload, int priority, long expireTime)
void	sendSubscribeTopicMessage(SubscribeTopic subscribeMessage, TriadOwner topicOwner) Topic Publishers use this API for registering themself with the Topic running on the Triad Pod.
void	sendTriadTopicMessage(TriadTopicMessage triadTopicMessage) Topic Publishers use this API for publishing message to the Triad Pod.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterQueueSender

public ClusterQueueSender(BamTriadSender bamSender,
                          byte[] queueHash)

Method Detail

getBamSender

protected BamTriadSender getBamSender()

getAddress

protected java.lang.String getAddress()

isPrimarySelf

public boolean isPrimarySelf()

send

public void send(java.lang.String msgId,
                 java.io.Serializable payload,
                 int priority,
                 long expireTime)

receive

public void receive(long expireTime,
                    boolean isAutoAck,
                    QueueEntrySelector selector,
                    MessageCallback<?> messageCallback)

sendTriadTopicMessage

public void sendTriadTopicMessage(TriadTopicMessage triadTopicMessage)

Topic Publishers use this API for publishing message to the Triad Pod.

sendSubscribeTopicMessage

public void sendSubscribeTopicMessage(SubscribeTopic subscribeMessage,
                                      TriadOwner topicOwner)

Topic Publishers use this API for registering themself with the Topic running on the Triad Pod.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object