public class ClusterMessageListener extends Object implements org.springframework.amqp.core.MessageListener
byte[]
making up the message payload must the format as used by the SpringAMQPTerminal
.Constructor and Description |
---|
ClusterMessageListener(Cluster initialCluster,
AMQPMessageConverter messageConverter)
Initializes a ClusterMessageListener with given
initialCluster that uses given
serializer to deserialize the message's contents into an EventMessage. |
Modifier and Type | Method and Description |
---|---|
void |
addCluster(Cluster cluster)
Registers an additional cluster.
|
void |
onMessage(org.springframework.amqp.core.Message message) |
public ClusterMessageListener(Cluster initialCluster, AMQPMessageConverter messageConverter)
initialCluster
that uses given
serializer
to deserialize the message's contents into an EventMessage.initialCluster
- The first cluster to assign to the listenermessageConverter
- The message converter to use to convert AMQP Messages to Event Messagespublic void onMessage(org.springframework.amqp.core.Message message)
onMessage
in interface org.springframework.amqp.core.MessageListener
public void addCluster(Cluster cluster)
cluster
- the cluster to add to the listenerCopyright © 2010-2013. All Rights Reserved.