public class Message extends Object implements Serializable, Comparable<Message>
Modifier and Type | Field and Description |
---|---|
(package private) byte[] |
body |
(package private) String |
exchange |
(package private) AMQP.Basic.BasicProperties |
properties |
(package private) long |
queueMsgId |
(package private) String |
queueName |
(package private) int |
queueSize |
(package private) boolean |
redelivered |
(package private) String |
routingKey |
private static long |
serialVersionUID
define serialVersionUID for interoperability
|
Constructor and Description |
---|
Message(String exchange,
String routingKey,
AMQP.Basic.BasicProperties properties,
byte[] body,
long deliveryTag,
boolean redelivered) |
private static final long serialVersionUID
String exchange
String routingKey
AMQP.Basic.BasicProperties properties
byte[] body
long queueMsgId
boolean redelivered
int queueSize
String queueName
public Message(String exchange, String routingKey, AMQP.Basic.BasicProperties properties, byte[] body, long deliveryTag, boolean redelivered)
properties
- body
- public int compareTo(Message o)
compareTo
in interface Comparable<Message>
Copyright © 2021 ScalAgent D.T.. All rights reserved.