com.caucho.jms.cluster
Class ClusterQueueActor

java.lang.Object
  extended by com.caucho.bam.stream.AbstractMessageStream
      extended by com.caucho.bam.actor.SimpleActor
          extended by com.caucho.cloud.bam.AbstractCloudActor
              extended by com.caucho.jms.cluster.ClusterQueueActor
All Implemented Interfaces:
Actor, ActorHolder, ManagedActor, MessageStream
Direct Known Subclasses:
ClusterQueueTriadActor

public class ClusterQueueActor
extends AbstractCloudActor

Implements a cluster send queue.


Constructor Summary
ClusterQueueActor(CloudServer server)
           
 
Method Summary
 ClusterQueueSender createMessageSender(CloudPod pod, byte[] queueHash)
           
 void processTopicMessage(java.lang.String to, java.lang.String from, TopicMessage msg)
          Topic Subscribers receives the message from the Triad Pod.
 void start()
           
 void stop()
           
 
Methods inherited from class com.caucho.cloud.bam.AbstractCloudActor
dbgId, getBamSender, getMailboxType, getManagedBroker, getPod, registerActor
 
Methods inherited from class com.caucho.bam.actor.SimpleActor
getActor, getAddress, getBroker, getMailbox, getSender, setAddress, setBroker, setMailbox
 
Methods inherited from class com.caucho.bam.stream.AbstractMessageStream
isClosed, message, messageError, query, queryError, queryResult, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.caucho.bam.stream.MessageStream
isClosed, message, messageError, query, queryError, queryResult
 

Constructor Detail

ClusterQueueActor

public ClusterQueueActor(CloudServer server)
Method Detail

createMessageSender

public ClusterQueueSender createMessageSender(CloudPod pod,
                                              byte[] queueHash)

processTopicMessage

@Message
public void processTopicMessage(java.lang.String to,
                                        java.lang.String from,
                                        TopicMessage msg)
Topic Subscribers receives the message from the Triad Pod. Received message is sent to the locally running Topic.


start

public void start()

stop

public void stop()