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

Constructors

Constructor and Description
ClusterQueueActor(CloudServer server)

Method Summary

Modifier and Type	Method and Description
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()