public class CorrelableOutboundMessage<T> extends OutboundMessage
Sender
and may contain (unserialized)
correlated metadata.Constructor and Description |
---|
CorrelableOutboundMessage(String exchange,
String routingKey,
AMQP.BasicProperties properties,
byte[] body,
T correlationMetadata)
Constructs a new message which is described by the body, the target exchange and the routing key which
can be used for smart routing after the message is published to the exchange.
|
CorrelableOutboundMessage(String exchange,
String routingKey,
byte[] body,
T correlationMetadata)
Constructs a new message which is described by the body, the target exchange and the routing key which
can be used for smart routing after the message is published to the exchange.
|
Modifier and Type | Method and Description |
---|---|
T |
getCorrelationMetadata()
Defines the "correlation" metadata associated with a sent OutboundMessage
|
String |
toString() |
getBody, getExchange, getProperties, getRoutingKey
public CorrelableOutboundMessage(String exchange, String routingKey, byte[] body, T correlationMetadata)
exchange
- The name of the target exchange.routingKey
- The routing key to be used if the message has to be routed in a specific way towards a queue.body
- The main body of the message.correlationMetadata
- The (unserialized) metadata correlated with this Message.public CorrelableOutboundMessage(String exchange, String routingKey, @Nullable AMQP.BasicProperties properties, byte[] body, T correlationMetadata)
exchange
- The name of the target exchange.routingKey
- The routing key to be used if the message has to be routed in a specific way towards a queue.properties
- AMQP compatible properties that will be used during the publishing of the message.body
- The main body of the message.correlationMetadata
- The (unserialized) metadata correlated with this Message.public T getCorrelationMetadata()
public String toString()
toString
in class OutboundMessage