Package org.apache.activemq.partition
Class ZooKeeperPartitionBroker
- java.lang.Object
-
- org.apache.activemq.broker.BrokerFilter
-
- org.apache.activemq.partition.PartitionBroker
-
- org.apache.activemq.partition.ZooKeeperPartitionBroker
-
public class ZooKeeperPartitionBroker extends PartitionBroker
-
-
Field Summary
Fields Modifier and Type Field Description protected Partitioning
config
protected CountDownLatch
configAcquired
protected static org.slf4j.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
Constructors Constructor Description ZooKeeperPartitionBroker(Broker broker, ZooKeeperPartitionBrokerPlugin plugin)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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, getNext, 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, virtualDestinationAdded, virtualDestinationRemoved
-
-
-
-
Field Detail
-
LOG
protected static final org.slf4j.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 interfaceService
- Overrides:
start
in classPartitionBroker
- Throws:
Exception
-
onMonitorStop
protected void onMonitorStop()
- Overrides:
onMonitorStop
in classPartitionBroker
-
getConfig
protected Partitioning getConfig()
- Overrides:
getConfig
in classPartitionBroker
-
plugin
protected ZooKeeperPartitionBrokerPlugin plugin()
-
zkDisconnect
protected void zkDisconnect()
-
reloadConfiguration
protected void reloadConfiguration() throws Exception
- Overrides:
reloadConfiguration
in classPartitionBroker
- Throws:
Exception
-
-