org.apache.activemq.partition.dto

Class Partitioning

java.lang.Object

org.apache.activemq.partition.dto.Partitioning

public class Partitioning
extends java.lang.Object

The main Configuration class for the PartitionBroker plugin

Field Summary

Fields

Modifier and Type	Field and Description
java.util.HashMap<java.lang.String,java.lang.String>	brokers Maps broker names to broker URLs.
java.util.HashMap<java.lang.String,Target>	byClientId If a client connects with a clientId which is listed in the map, then he will be immediately reconnected to the partition target immediately.
java.util.HashMap<java.lang.String,Target>	byQueue Used to map the preferred partitioning of queues across a set of brokers.
java.util.HashMap<java.lang.String,Target>	bySourceIp If a client connects with source ip which is listed in the map, then he will be immediately reconnected to the partition target immediately.
java.util.HashMap<java.lang.String,Target>	byTopic Used to map the preferred partitioning of topics across a set of brokers.
java.util.HashMap<java.lang.String,Target>	byUserName If a client connects with a user priciple which is listed in the map, then he will be immediately reconnected to the partition target immediately.
static org.codehaus.jackson.map.ObjectMapper	MAPPER
static org.codehaus.jackson.map.ObjectMapper	TO_STRING_MAPPER

Constructor Summary

Constructors

Constructor and Description
Partitioning()

Method Summary

Methods

Modifier and Type	Method and Description
java.util.HashMap<java.lang.String,java.lang.String>	getBrokers()
java.util.HashMap<java.lang.String,Target>	getByClientId()
java.util.HashMap<java.lang.String,Target>	getByQueue()
java.util.HashMap<java.lang.String,Target>	getBySourceIp()
java.util.HashMap<java.lang.String,Target>	getByTopic()
java.util.HashMap<java.lang.String,Target>	getByUserName()
void	setBrokers(java.util.HashMap<java.lang.String,java.lang.String> brokers)
void	setByClientId(java.util.HashMap<java.lang.String,Target> byClientId)
void	setByQueue(java.util.HashMap<java.lang.String,Target> byQueue)
void	setBySourceIp(java.util.HashMap<java.lang.String,Target> bySourceIp)
void	setByTopic(java.util.HashMap<java.lang.String,Target> byTopic)
void	setByUserName(java.util.HashMap<java.lang.String,Target> byUserName)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

MAPPER

public static final org.codehaus.jackson.map.ObjectMapper MAPPER

TO_STRING_MAPPER

public static final org.codehaus.jackson.map.ObjectMapper TO_STRING_MAPPER

byClientId

public java.util.HashMap<java.lang.String,Target> byClientId

If a client connects with a clientId which is listed in the map, then he will be immediately reconnected to the partition target immediately.

byUserName

public java.util.HashMap<java.lang.String,Target> byUserName

If a client connects with a user priciple which is listed in the map, then he will be immediately reconnected to the partition target immediately.

bySourceIp

public java.util.HashMap<java.lang.String,Target> bySourceIp

If a client connects with source ip which is listed in the map, then he will be immediately reconnected to the partition target immediately.

byQueue

public java.util.HashMap<java.lang.String,Target> byQueue

Used to map the preferred partitioning of queues across a set of brokers. Once a it is deemed that a connection mostly works with a set of targets configured in this map, the client will be reconnected to the appropriate target.

byTopic

public java.util.HashMap<java.lang.String,Target> byTopic

Used to map the preferred partitioning of topics across a set of brokers. Once a it is deemed that a connection mostly works with a set of targets configured in this map, the client will be reconnected to the appropriate target.

brokers

public java.util.HashMap<java.lang.String,java.lang.String> brokers

Maps broker names to broker URLs.

Constructor Detail

Partitioning

public Partitioning()

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getBrokers

public java.util.HashMap<java.lang.String,java.lang.String> getBrokers()

setBrokers

public void setBrokers(java.util.HashMap<java.lang.String,java.lang.String> brokers)

getByClientId

public java.util.HashMap<java.lang.String,Target> getByClientId()

setByClientId

public void setByClientId(java.util.HashMap<java.lang.String,Target> byClientId)

getByQueue

public java.util.HashMap<java.lang.String,Target> getByQueue()

setByQueue

public void setByQueue(java.util.HashMap<java.lang.String,Target> byQueue)

getBySourceIp

public java.util.HashMap<java.lang.String,Target> getBySourceIp()

setBySourceIp

public void setBySourceIp(java.util.HashMap<java.lang.String,Target> bySourceIp)

getByTopic

public java.util.HashMap<java.lang.String,Target> getByTopic()

setByTopic

public void setByTopic(java.util.HashMap<java.lang.String,Target> byTopic)

getByUserName

public java.util.HashMap<java.lang.String,Target> getByUserName()

setByUserName

public void setByUserName(java.util.HashMap<java.lang.String,Target> byUserName)