com.caucho.jms
Class ClusterQueue<X extends java.io.Serializable>

java.lang.Object
  extended by java.util.AbstractCollection<E>
      extended by java.util.AbstractQueue<E>
          extended by com.caucho.jms.queue.AbstractDestination<E>
              extended by com.caucho.jms.queue.AbstractQueue<E>
                  extended by com.caucho.jms.cluster.ClusterQueueImpl<X>
                      extended by com.caucho.jms.ClusterQueue<X>
All Implemented Interfaces:
HandleAware, MessageQueue<X>, java.io.Serializable, java.lang.Iterable<X>, java.util.Collection<X>, java.util.concurrent.BlockingQueue<X>, java.util.Queue<X>, Destination

@Service
@Configurable
public class ClusterQueue<X extends java.io.Serializable>
extends ClusterQueueImpl<X>

ClusterQueue provides reliable point to point transfer of messages.

ClusterQueue runs on the Triad pod to provide clustered, uninterrupted services. Nodes in the cluster uses com.caucho.jms.RemoteQueue to communicate with the ClusterQueue running on the Triad.

Send Message Workflow:

Receive Message Workflow:

Asynchronous Receive Message Workflow:

It is configured as:
 <web-app xmlns="http://caucho.com/ns/resin"
             xmlns:jms="urn:java:com.caucho.jms">

        <jms:ClusterQueue>
           <jms:name>test</jms:name>
        </jms:ClusterQueue>   

 </web-app>
 

See Also:
Serialized Form

Constructor Summary
ClusterQueue()
           
ClusterQueue(java.lang.String name)
           
 
Method Summary
 
Methods inherited from class com.caucho.jms.cluster.ClusterQueueImpl
acknowledge, addMessageCallback, close, getConsumerCount, getQueueOwner, getQueueSize, hasMessage, hasMessage, init, isBackup, receive, receive, receiveEntry, receiveEntry, removeMessageCallback, rollback, send, setBackup, setCluster
 
Methods inherited from class com.caucho.jms.queue.AbstractQueue
addListenerException, drainTo, drainTo, getBrowserList, getListenerFailCountTotal, getListenerFailLastTime, getReceiverCount, iterator, offer, offer, peek, poll, poll, postConstruct, put, receive, remainingCapacity, setQueueName, size, take
 
Methods inherited from class com.caucho.jms.queue.AbstractDestination
generateMessageID, generateMessageID, getJMSDestination, getName, getQueueName, getTopicName, getUrl, setName, setSerializationHandle, toString
 
Methods inherited from class java.util.AbstractQueue
add, addAll, clear, element, remove
 
Methods inherited from class java.util.AbstractCollection
contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface javax.jms.Queue
getQueueName, toString
 
Methods inherited from interface java.util.concurrent.BlockingQueue
add, contains, remove
 
Methods inherited from interface java.util.Queue
element, remove
 
Methods inherited from interface java.util.Collection
addAll, clear, containsAll, equals, hashCode, isEmpty, removeAll, retainAll, toArray, toArray
 

Constructor Detail

ClusterQueue

public ClusterQueue()

ClusterQueue

public ClusterQueue(java.lang.String name)