org.jboss.messaging.core.plugin.contract
Interface ClusteredPostOffice

All Superinterfaces:

MessagingComponent, Peer, PostOffice

All Known Implementing Classes:

DefaultClusteredPostOffice

public interface ClusteredPostOffice

extends PostOffice, Peer

Version:

$Revision: 2319 $ $Id: ClusteredPostOffice.java 2319 2007-02-15 07:16:11Z ovidiu.feodorov@jboss.com $

Author:

Tim Fox, Clebert Suconic

Field Summary

static java.lang.String	FAILOVER_COMPLETED_NOTIFICATION
static java.lang.String	VIEW_CHANGED_NOTIFICATION

Method Summary

Binding	bindClusteredQueue(Condition condition, LocalClusteredQueue queue) Bind a queue to the post office under a specific condition such that it is available across the cluster.
java.util.Collection	listAllBindingsForCondition(Condition condition)
Binding	unbindClusteredQueue(java.lang.String queueName) Unbind a clustered queue from the post office.

Methods inherited from interface org.jboss.messaging.core.plugin.contract.PostOffice

bindQueue, getBindingforChannelId, getBindingForQueueName, getBindingsForCondition, getOfficeName, isLocal, route, unbindQueue

Methods inherited from interface org.jboss.messaging.core.plugin.contract.MessagingComponent

start, stop

Methods inherited from interface org.jboss.messaging.core.plugin.postoffice.cluster.Peer

getNodeIDView

Field Detail

VIEW_CHANGED_NOTIFICATION

public static final java.lang.String VIEW_CHANGED_NOTIFICATION

See Also:

Constant Field Values

FAILOVER_COMPLETED_NOTIFICATION

public static final java.lang.String FAILOVER_COMPLETED_NOTIFICATION

See Also:

Constant Field Values

Method Detail

bindClusteredQueue

public Binding bindClusteredQueue(Condition condition,
                                  LocalClusteredQueue queue)
                           throws java.lang.Exception

Bind a queue to the post office under a specific condition such that it is available across the cluster.

Parameters:

condition - - the condition to be used when routing references.

Throws:

java.lang.Exception

unbindClusteredQueue

public Binding unbindClusteredQueue(java.lang.String queueName)
                             throws java.lang.Throwable

Unbind a clustered queue from the post office.

Parameters:

queueName - - the unique name of the queue.

Throws:

java.lang.Throwable

listAllBindingsForCondition

public java.util.Collection listAllBindingsForCondition(Condition condition)
                                                 throws java.lang.Exception

Throws:

java.lang.Exception