org.apache.activemq.partition.dto
Class Partitioning

java.lang.Object
  extended by org.apache.activemq.partition.dto.Partitioning

public class Partitioning
extends Object

The main Configuration class for the PartitionBroker plugin


Field Summary
 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 org.codehaus.jackson.map.ObjectMapper MAPPER
           
static org.codehaus.jackson.map.ObjectMapper TO_STRING_MAPPER
           
 
Constructor Summary
Partitioning()
           
 
Method Summary
 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()
           
 
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 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.


brokers

public HashMap<String,String> brokers
Maps broker names to broker URLs.

Constructor Detail

Partitioning

public Partitioning()
Method Detail

toString

public String toString()
Overrides:
toString in class Object

getBrokers

public HashMap<String,String> getBrokers()

setBrokers

public void setBrokers(HashMap<String,String> brokers)

getByClientId

public HashMap<String,Target> getByClientId()

setByClientId

public void setByClientId(HashMap<String,Target> byClientId)

getByQueue

public HashMap<String,Target> getByQueue()

setByQueue

public void setByQueue(HashMap<String,Target> byQueue)

getBySourceIp

public HashMap<String,Target> getBySourceIp()

setBySourceIp

public void setBySourceIp(HashMap<String,Target> bySourceIp)

getByTopic

public HashMap<String,Target> getByTopic()

setByTopic

public void setByTopic(HashMap<String,Target> byTopic)

getByUserName

public HashMap<String,Target> getByUserName()

setByUserName

public void setByUserName(HashMap<String,Target> byUserName)


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