org.apache.activemq.partition
Class PartitionBrokerPlugin

java.lang.Object
  extended by 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
protected  Partitioning config
           
protected  int minTransferCount
           
 
Constructor Summary
PartitionBrokerPlugin()
           
 
Method Summary
 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)


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