Struct Publisher 

pub struct Publisher { /* private fields */ }

Simplified Publisher for message publishing

Implementations

impl Publisher

pub fn new(connection: Arc<Connection>) -> Self

Create a new publisher

pub async fn publish_to_exchange<T>( &self, exchange: &str, routing_key: &str, message: &T, options: Option<PublishOptions>, ) -> Result<(), RustRabbitError>

where T: Serialize,

Publish message to an exchange

pub async fn publish_to_queue<T>( &self, queue: &str, message: &T, options: Option<PublishOptions>, ) -> Result<(), RustRabbitError>

where T: Serialize,

Publish message directly to a queue

pub async fn publish_envelope_to_exchange<T>( &self, exchange: &str, routing_key: &str, envelope: &MessageEnvelope<T>, options: Option<PublishOptions>, ) -> Result<(), RustRabbitError>

where T: Serialize,

Publish a message envelope to an exchange (includes retry metadata)

pub async fn publish_envelope_to_queue<T>( &self, queue: &str, envelope: &MessageEnvelope<T>, options: Option<PublishOptions>, ) -> Result<(), RustRabbitError>

where T: Serialize,

Publish a message envelope directly to a queue (includes retry metadata)

pub async fn publish_with_envelope<T>( &self, exchange: &str, routing_key: &str, payload: &T, source_queue: &str, max_retries: u32, options: Option<PublishOptions>, ) -> Result<(), RustRabbitError>

where T: Serialize + Clone,

Create a message envelope with source tracking and publish to exchange

pub async fn publish_with_envelope_to_queue<T>( &self, queue: &str, payload: &T, max_retries: u32, options: Option<PublishOptions>, ) -> Result<(), RustRabbitError>

where T: Serialize + Clone,

Create a message envelope and publish directly to queue