Struct KafkaTestMessage 

pub struct KafkaTestMessage { /* private fields */ }

One in-process delivery.

Trait Implementations

impl Debug for KafkaTestMessage

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

Formats the value using the given formatter.

impl Drop for KafkaTestMessage

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl IncomingMessage for KafkaTestMessage

fn partition_key(&self) -> Option<&[u8]>

The partition key from the PARTITION_KEY_HEADER, mirroring the real message so keyed worker lanes behave the same in-process.

async fn ack(self) -> Result<(), AckError>

Finalizes the delivery.

Errors

Never fails; the in-process transport has no position to store.

async fn nack(self, requeue: bool) -> Result<(), AckError>

Re-enqueues to the same subscription (requeue = true) or drops (requeue = false).

Errors

Never fails; the in-process transport has no position to store.

fn payload(&self) -> &[u8]

Returns the raw payload of the message.

fn headers(&self) -> &Headers

Returns the headers attached to the message.

fn supports_nack_after(&self) -> bool

Reports whether this transport can honor nack_after natively.

fn nack_after( self, delay: Duration, ) -> impl Future<Output = Result<(), AckError>> + Send

where Self: Sized,

Negatively acknowledges the message, asking the broker to redeliver it no sooner than delay from now.

impl Partitioned for KafkaTestMessage

fn partition_key(&self) -> Option<&[u8]>

The partition key from the PARTITION_KEY_HEADER, mirroring the real message.