Added a cluster field to each message so that each message can be persisted to a unique set of brokers working together as a master slave cluster.
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/Message.java