com.caucho.jms.cluster
Class ClusterQueueSender

java.lang.Object
  extended by 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