Struct QueueMessage 

pub struct QueueMessage {
    pub topic: String,
    pub partition: i32,
    pub offset: i64,
    pub value: Option<Bytes>,
    pub headers: Vec<(String, Option<Bytes>)>,
    pub delivery_count: i32,
}

Acquired queue message.

Fields

topic: String

Topic name.

partition: i32

Partition index.

offset: i64

Record offset.

value: Option<Bytes>

Record value, or None for a Kafka tombstone.

headers: Vec<(String, Option<Bytes>)>

Headers in delivery order.

delivery_count: i32

Gateway delivery count.

Implementations

impl QueueMessage

pub fn message_id(&self) -> String

Stable conformance message id.

Trait Implementations

impl Clone for QueueMessage

fn clone(&self) -> QueueMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for QueueMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for QueueMessage

impl From<QueuedMessage> for QueueMessage

fn from(value: QueuedMessage) -> Self

Converts to this type from the input type.

impl PartialEq for QueueMessage

fn eq(&self, other: &QueueMessage) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for QueueMessage