Struct RedisListPublisher 

pub struct RedisListPublisher { /* private fields */ }

Publishes onto a list with LPUSH, so right-popping consumers see FIFO order: a RedisListPublish policy paired with a connection.

Obtain it from ConnectedRedisBroker::list_publisher, or by pairing the policy. Publishing after the connection was shut down reports RedisError::ShutDown.

Trait Implementations

impl Clone for RedisListPublisher

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedisListPublisher

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

Formats the value using the given formatter.

impl Publisher for RedisListPublisher

type Payload = Lend

As on RedisPubSubPublisher: the entry the client is handed is an envelope this crate builds, so the payload is only read.

type Options = RedisPublishOptions

LPUSH carries the key and the value and nothing else; the key TTL is a property of the queue, fixed by the policy and re-armed on every publish. What a call site still says is the partition key, framed into the entry with the message’s other headers.

type Error = RedisError

The error type returned by publish.

async fn publish( &self, msg: OutgoingMessage<'_>, options: Option<&Self::Options>, ) -> Result<(), Self::Error>

Publishes a message to the broker, with the per-message settings the call site adjusted.

fn base_headers(&self) -> Option<&HeaderMap>

The headers this publisher contributes to every message it sends, underneath whatever the message itself names.