Class Partitioning
- java.lang.Object
-
- org.apache.activemq.partition.dto.Partitioning
-
public class Partitioning extends Object
The main Configuration class for the PartitionBroker plugin
-
-
Field Summary
Fields Modifier and Type Field Description HashMap<String,String>brokersMaps broker names to broker URLs.HashMap<String,Target>byClientIdIf a client connects with a clientId which is listed in the map, then he will be immediately reconnected to the partition target immediately.HashMap<String,Target>byQueueUsed to map the preferred partitioning of queues across a set of brokers.HashMap<String,Target>bySourceIpIf a client connects with source ip which is listed in the map, then he will be immediately reconnected to the partition target immediately.HashMap<String,Target>byTopicUsed to map the preferred partitioning of topics across a set of brokers.HashMap<String,Target>byUserNameIf 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 com.fasterxml.jackson.databind.ObjectMapperMAPPERstatic com.fasterxml.jackson.databind.ObjectMapperTO_STRING_MAPPER
-
Constructor Summary
Constructors Constructor Description Partitioning()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description HashMap<String,String>getBrokers()HashMap<String,Target>getByClientId()HashMap<String,Target>getByQueue()HashMap<String,Target>getBySourceIp()HashMap<String,Target>getByTopic()HashMap<String,Target>getByUserName()voidsetBrokers(HashMap<String,String> brokers)voidsetByClientId(HashMap<String,Target> byClientId)voidsetByQueue(HashMap<String,Target> byQueue)voidsetBySourceIp(HashMap<String,Target> bySourceIp)voidsetByTopic(HashMap<String,Target> byTopic)voidsetByUserName(HashMap<String,Target> byUserName)StringtoString()
-
-
-
Field Detail
-
MAPPER
public static final com.fasterxml.jackson.databind.ObjectMapper MAPPER
-
TO_STRING_MAPPER
public static final com.fasterxml.jackson.databind.ObjectMapper TO_STRING_MAPPER
-
byClientId
public HashMap<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 HashMap<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 HashMap<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 HashMap<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 HashMap<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.
-
-