org.apache.activemq.partition
Class ZooKeeperPartitionBrokerPlugin

java.lang.Object
  extended by org.apache.activemq.partition.PartitionBrokerPlugin
      extended by org.apache.activemq.partition.ZooKeeperPartitionBrokerPlugin
All Implemented Interfaces:
BrokerPlugin

public class ZooKeeperPartitionBrokerPlugin
extends PartitionBrokerPlugin

A PartitionBrokerPlugin which gets it's configuration from ZooKeeper.


Field Summary
 
Fields inherited from class org.apache.activemq.partition.PartitionBrokerPlugin
config, minTransferCount
 
Constructor Summary
ZooKeeperPartitionBrokerPlugin()
           
 
Method Summary
 String getZkAddress()
           
 String getZkPassword()
           
 String getZkPath()
           
 String getZkSessionTmeout()
           
 Broker installPlugin(Broker broker)
          Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.
 void setZkAddress(String zkAddress)
           
 void setZkPassword(String zkPassword)
           
 void setZkPath(String zkPath)
           
 void setZkSessionTmeout(String zkSessionTmeout)
           
 
Methods inherited from class org.apache.activemq.partition.PartitionBrokerPlugin
getBrokerURL, getConfig, getMinTransferCount, setConfig, setConfigAsJson, setMinTransferCount
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ZooKeeperPartitionBrokerPlugin

public ZooKeeperPartitionBrokerPlugin()
Method Detail

installPlugin

public Broker installPlugin(Broker broker)
                     throws Exception
Description copied from interface: BrokerPlugin
Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.

Specified by:
installPlugin in interface BrokerPlugin
Overrides:
installPlugin in class PartitionBrokerPlugin
Throws:
Exception

getZkAddress

public String getZkAddress()

setZkAddress

public void setZkAddress(String zkAddress)

getZkPassword

public String getZkPassword()

setZkPassword

public void setZkPassword(String zkPassword)

getZkPath

public String getZkPath()

setZkPath

public void setZkPath(String zkPath)

getZkSessionTmeout

public String getZkSessionTmeout()

setZkSessionTmeout

public void setZkSessionTmeout(String zkSessionTmeout)


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