* @param broker
* @throws JBIException
*/
public void init(Broker broker, String subType) throws JBIException {
super.init(broker, subType);
ClusterFactory fac = new ActiveMQClusterFactory();
try {
this.cluster = fac.createCluster(clusterDestination);
this.cluster.addClusterListener(this);
MessageConsumer consumer = this.cluster.createConsumer(cluster.getDestination());
consumer.setMessageListener(this);
consumer = this.cluster.createConsumer(cluster.getLocalNode().getDestination());
consumer.setMessageListener(this);