org.apache.activemq.partition
Class ZooKeeperPartitionBroker

java.lang.Object
  extended by org.apache.activemq.broker.BrokerFilter
      extended by org.apache.activemq.partition.PartitionBroker
          extended by org.apache.activemq.partition.ZooKeeperPartitionBroker
All Implemented Interfaces:
Broker, Region, Service

public class ZooKeeperPartitionBroker
extends PartitionBroker


Field Summary
protected  Partitioning config
           
protected  CountDownLatch configAcquired
           
protected static Logger LOG
           
protected  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
ZooKeeperPartitionBroker(Broker broker, ZooKeeperPartitionBrokerPlugin plugin)
           
 
Method Summary
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, 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, 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 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


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.