}
}
@Override
public void onClusterCreated(final Cluster cluster) {
ClusterMetaData clusterMetaData = cluster.getMetaData();
AMQPConsumerConfiguration config;
if (clusterMetaData.getProperty(AMQP_CONFIG_PROPERTY) instanceof AMQPConsumerConfiguration) {
config = (AMQPConsumerConfiguration) clusterMetaData.getProperty(AMQP_CONFIG_PROPERTY);
} else {
config = new DefaultAMQPConsumerConfiguration(cluster.getName());
}
getListenerContainerLifecycleManager().registerCluster(cluster, config, messageConverter);
}