io.micronaut.configuration.rabbitmq.bind

Class RabbitConsumerState

java.lang.Object

io.micronaut.configuration.rabbitmq.bind.RabbitConsumerState

@Immutable
public class RabbitConsumerState
extends Object

Stores the state of a RabbitMQ message to be consumed.

Since:

1.1.0

Author:

James Kleeh

Constructor Summary

Constructors

Constructor and Description
RabbitConsumerState(com.rabbitmq.client.Envelope envelope, com.rabbitmq.client.AMQP.BasicProperties properties, byte[] body, com.rabbitmq.client.Channel channel) Default constructor.

Method Summary

Modifier and Type	Method and Description
byte[]	getBody()
com.rabbitmq.client.Channel	getChannel() This channel is being used exclusively by the consumer that consumed this message.
com.rabbitmq.client.Envelope	getEnvelope()
com.rabbitmq.client.AMQP.BasicProperties	getProperties()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RabbitConsumerState

public RabbitConsumerState(com.rabbitmq.client.Envelope envelope,
                           com.rabbitmq.client.AMQP.BasicProperties properties,
                           byte[] body,
                           com.rabbitmq.client.Channel channel)

Default constructor.

Parameters:

envelope - The envelope

properties - The properties

body - The body

channel - The channel that consumed the message

Method Detail

getBody

public byte[] getBody()

Returns:

The body

getProperties

@Nonnull
public com.rabbitmq.client.AMQP.BasicProperties getProperties()

Returns:

The properties

getEnvelope

@Nonnull
public com.rabbitmq.client.Envelope getEnvelope()

Returns:

The envelope

getChannel

public com.rabbitmq.client.Channel getChannel()

This channel is being used exclusively by the consumer that consumed this message. Attempts to use this channel for any purpose other than acknowledgement may result in errors because channels are not thread safe.

Returns:

The channel