org.apache.activemq.broker.cluster

Class ConnectionSplitBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

org.apache.activemq.broker.cluster.ConnectionSplitBroker

All Implemented Interfaces:

Broker, Region, Service

public class ConnectionSplitBroker
extends BrokerFilter

Monitors for client connections that may fail to another broker - but this broker isn't aware they've gone. Can occur with network glitches or client error

Field Summary

Fields inherited from class org.apache.activemq.broker.BrokerFilter

next

Constructor Summary

Constructors

Constructor and Description
ConnectionSplitBroker(Broker next)

Method Summary

Methods

Modifier and Type	Method and Description
Subscription	addConsumer(ConnectionContext context, ConsumerInfo info) Adds a consumer.
void	removeConsumer(ConnectionContext context, ConsumerInfo info) Removes a consumer.

Methods inherited from class org.apache.activemq.broker.BrokerFilter

acknowledge, addBroker, addConnection, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, reapplyInterceptor, removeBroker, removeConnection, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectionSplitBroker

public ConnectionSplitBroker(Broker next)

Method Detail

addConsumer

public Subscription addConsumer(ConnectionContext context,
                       ConsumerInfo info)
                         throws java.lang.Exception

Description copied from interface: Region

Adds a consumer.

Specified by:

addConsumer in interface Region

Overrides:

addConsumer in class BrokerFilter

Parameters:

context - the environment the operation is being executed under.

Returns:

TODO

Throws:

java.lang.Exception - TODO

removeConsumer

public void removeConsumer(ConnectionContext context,
                  ConsumerInfo info)
                    throws java.lang.Exception

Description copied from interface: Region

Removes a consumer.

Specified by:

removeConsumer in interface Region

Overrides:

removeConsumer in class BrokerFilter

Parameters:

context - the environment the operation is being executed under.

Throws:

java.lang.Exception - TODO