org.apache.activemq.partition

Class ZooKeeperPartitionBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

org.apache.activemq.partition.PartitionBroker

org.apache.activemq.partition.ZooKeeperPartitionBroker

All Implemented Interfaces:

Broker, Region, Service

public class ZooKeeperPartitionBroker
extends PartitionBroker

Field Summary

Fields

Modifier and Type	Field and Description
protected Partitioning	config
protected CountDownLatch	configAcquired
protected static Logger	LOG
protected org.apache.activemq.leveldb.replicated.groups.ZKClient	zk_client

Fields inherited from class org.apache.activemq.partition.PartitionBroker

monitors, plugin, reloadConfigOnPoll

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

next

Constructor Summary

Constructors

Constructor and Description
ZooKeeperPartitionBroker(Broker broker, ZooKeeperPartitionBrokerPlugin plugin)

Method Summary

Modifier and Type	Method and Description
protected Partitioning	getConfig()
protected void	onMonitorStop()
protected ZooKeeperPartitionBrokerPlugin	plugin()
protected void	reloadConfiguration()
void	start()
protected void	zkConnect()
protected void	zkDisconnect()

Methods inherited from class org.apache.activemq.partition.PartitionBroker

addConnection, checkTarget, getConnectionString, getTarget, monitorWait, monitorWakeup, onMonitorStart, pickBestBroker, removeConnection, runPartitionMonitor, send

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

acknowledge, addBroker, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, 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, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, stop

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final Logger LOG

zk_client

protected volatile org.apache.activemq.leveldb.replicated.groups.ZKClient zk_client

config

protected volatile Partitioning config

configAcquired

protected final CountDownLatch configAcquired

Constructor Detail

ZooKeeperPartitionBroker

public ZooKeeperPartitionBroker(Broker broker,
                                ZooKeeperPartitionBrokerPlugin plugin)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface Service

Overrides:

start in class PartitionBroker

Throws:

Exception

onMonitorStop

protected void onMonitorStop()

Overrides:

onMonitorStop in class PartitionBroker

getConfig

protected Partitioning getConfig()

Overrides:

getConfig in class PartitionBroker

plugin

protected ZooKeeperPartitionBrokerPlugin plugin()

zkConnect

protected void zkConnect()
                  throws Exception

Throws:

Exception

zkDisconnect

protected void zkDisconnect()

reloadConfiguration

protected void reloadConfiguration()
                            throws Exception

Overrides:

reloadConfiguration in class PartitionBroker

Throws:

Exception