public class PartitionBrokerPlugin extends Object implements BrokerPlugin
Modifier and Type | Field and Description |
---|---|
protected Partitioning |
config |
protected int |
minTransferCount |
Constructor and Description |
---|
PartitionBrokerPlugin() |
Modifier and Type | Method and 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) |
protected int minTransferCount
protected Partitioning config
public PartitionBrokerPlugin()
public Broker installPlugin(Broker broker) throws Exception
BrokerPlugin
installPlugin
in interface BrokerPlugin
Exception
public int getMinTransferCount()
public void setMinTransferCount(int minTransferCount)
public Partitioning getConfig()
public void setConfig(Partitioning config)
public void setConfigAsJson(String config) throws IOException
IOException
public String getBrokerURL(PartitionBroker partitionBroker, String id)
Copyright © 2005–2015 FuseSource, Corp.. All rights reserved.