Package io.vertx.rxjava3.rabbitmq
Class RabbitMQMessage
- java.lang.Object
- 
- io.vertx.rxjava3.rabbitmq.RabbitMQMessage
 
- 
- All Implemented Interfaces:
- io.vertx.lang.rx.RxDelegate
 
 public class RabbitMQMessage extends Object implements io.vertx.lang.rx.RxDelegate Represent a message received message received in a rabbitmq-queue.NOTE: This class has been automatically generated from the originalnon RX-ified interface using Vert.x codegen.
- 
- 
Field SummaryFields Modifier and Type Field Description static io.vertx.lang.rx.TypeArg<RabbitMQMessage>__TYPE_ARG
 - 
Constructor SummaryConstructors Constructor Description RabbitMQMessage(RabbitMQMessage delegate)RabbitMQMessage(Object delegate)
 - 
Method SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Bufferbody()StringconsumerTag()com.rabbitmq.client.Envelopeenvelope()booleanequals(Object o)RabbitMQMessagegetDelegate()inthashCode()IntegermessageCount()static RabbitMQMessagenewInstance(RabbitMQMessage arg)com.rabbitmq.client.BasicPropertiesproperties()StringtoString()
 
- 
- 
- 
Field Detail- 
__TYPE_ARGpublic static final io.vertx.lang.rx.TypeArg<RabbitMQMessage> __TYPE_ARG 
 
- 
 - 
Constructor Detail- 
RabbitMQMessagepublic RabbitMQMessage(RabbitMQMessage delegate) 
 - 
RabbitMQMessagepublic RabbitMQMessage(Object delegate) 
 
- 
 - 
Method Detail- 
getDelegatepublic RabbitMQMessage getDelegate() - Specified by:
- getDelegatein interface- io.vertx.lang.rx.RxDelegate
 
 - 
bodypublic Buffer body() - Returns:
- the message body
 
 - 
consumerTagpublic String consumerTag() - Returns:
- the consumer tag associated with the consumer
 
 - 
messageCountpublic Integer messageCount() - Returns:
- the message count for messages obtained with RabbitMQClient.basicGet(java.lang.String, boolean)
 
 - 
envelopepublic com.rabbitmq.client.Envelope envelope() - Returns:
- packaging data for the message
 
 - 
propertiespublic com.rabbitmq.client.BasicProperties properties() - Returns:
- content header data for the message
 
 - 
newInstancepublic static RabbitMQMessage newInstance(RabbitMQMessage arg) 
 
- 
 
-