Package org.apache.activemq.partition

Class PartitionBrokerPlugin

java.lang.Object

org.apache.activemq.partition.PartitionBrokerPlugin

All Implemented Interfaces:

BrokerPlugin

Direct Known Subclasses:

ZooKeeperPartitionBrokerPlugin

public class PartitionBrokerPlugin
extends Object
implements BrokerPlugin

A BrokerPlugin which partitions client connections over a cluster of brokers.

Field Summary

Fields

Modifier and Type	Field	Description
protected Partitioning	config
protected int	minTransferCount

Constructor Summary

Constructors

Constructor	Description
PartitionBrokerPlugin()

Method Summary

Modifier and Type	Method	Description
String	getBrokerURL(PartitionBroker partitionBroker, String id)
Partitioning	getConfig()
int	getMinTransferCount()
Broker	installPlugin(Broker broker)	Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.
void	setConfig(Partitioning config)
void	setConfigAsJson(String config)
void	setMinTransferCount(int minTransferCount)

Methods inherited from class java.lang.Object

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

Field Detail

minTransferCount

protected int minTransferCount

config

protected Partitioning config

Constructor Detail

PartitionBrokerPlugin

public PartitionBrokerPlugin()

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

Throws:

Exception

getMinTransferCount

public int getMinTransferCount()

setMinTransferCount

public void setMinTransferCount(int minTransferCount)

getConfig

public Partitioning getConfig()

setConfig

public void setConfig(Partitioning config)

setConfigAsJson

public void setConfigAsJson(String config)
                     throws IOException

Throws:

IOException

getBrokerURL

public String getBrokerURL(PartitionBroker partitionBroker,
                           String id)