com.caucho.jms.cluster
Class ClusterQueueActor

java.lang.Object
  com.caucho.bam.stream.AbstractMessageStream
      com.caucho.bam.actor.SimpleActor
          com.caucho.cloud.bam.AbstractCloudActor
              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()