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>
brokers
Maps broker names to broker URLs.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.HashMap<String,Target>
byQueue
Used to map the preferred partitioning of queues across a set of brokers.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.HashMap<String,Target>
byTopic
Used to map the preferred partitioning of topics across a set of brokers.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.static com.fasterxml.jackson.databind.ObjectMapper
MAPPER
static com.fasterxml.jackson.databind.ObjectMapper
TO_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()
void
setBrokers(HashMap<String,String> brokers)
void
setByClientId(HashMap<String,Target> byClientId)
void
setByQueue(HashMap<String,Target> byQueue)
void
setBySourceIp(HashMap<String,Target> bySourceIp)
void
setByTopic(HashMap<String,Target> byTopic)
void
setByUserName(HashMap<String,Target> byUserName)
String
toString()
-
-
-
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.
-
-