Package io.vertx.rxjava3.rabbitmq
Class RabbitMQMessage
- java.lang.Object
-
- io.vertx.rxjava3.rabbitmq.RabbitMQMessage
-
-
Field Summary
Fields Modifier and Type Field Description static io.vertx.lang.rx.TypeArg<RabbitMQMessage>
__TYPE_ARG
-
Constructor Summary
Constructors Constructor Description RabbitMQMessage(RabbitMQMessage delegate)
RabbitMQMessage(Object delegate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Buffer
body()
String
consumerTag()
com.rabbitmq.client.Envelope
envelope()
boolean
equals(Object o)
RabbitMQMessage
getDelegate()
int
hashCode()
Integer
messageCount()
static RabbitMQMessage
newInstance(RabbitMQMessage arg)
com.rabbitmq.client.BasicProperties
properties()
String
toString()
-
-
-
Field Detail
-
__TYPE_ARG
public static final io.vertx.lang.rx.TypeArg<RabbitMQMessage> __TYPE_ARG
-
-
Constructor Detail
-
RabbitMQMessage
public RabbitMQMessage(RabbitMQMessage delegate)
-
RabbitMQMessage
public RabbitMQMessage(Object delegate)
-
-
Method Detail
-
getDelegate
public RabbitMQMessage getDelegate()
-
body
public Buffer body()
- Returns:
- the message body
-
consumerTag
public String consumerTag()
- Returns:
- the consumer tag associated with the consumer
-
messageCount
public Integer messageCount()
- Returns:
- the message count for messages obtained with
RabbitMQClient.basicGet(java.lang.String, boolean)
-
envelope
public com.rabbitmq.client.Envelope envelope()
- Returns:
- packaging data for the message
-
properties
public com.rabbitmq.client.BasicProperties properties()
- Returns:
- content header data for the message
-
newInstance
public static RabbitMQMessage newInstance(RabbitMQMessage arg)
-
-