org.apache.activemq.partition

Class ZooKeeperPartitionBrokerPlugin

java.lang.Object

org.apache.activemq.partition.PartitionBrokerPlugin

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

Constructors

Constructor and Description
ZooKeeperPartitionBrokerPlugin()

Method Summary

Modifier and Type	Method and Description
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)