Struct DispatchBuilder 

pub struct DispatchBuilder { /* private fields */ }

Allows building an outgoing RabbitMQ Dispatch iteratively.

Expects that the payload has been converted to a vector of bytes.

Implementations

impl DispatchBuilder

pub fn new() -> Self

Creates a new Dispatch builder.

pub fn with_bytes(self, bytes: Vec<u8>) -> Self

Sets the payload of this Dispatch to the given bytes.

This method is specifically made to take an owned Vec<u8>, to make sure no copying occurs and the bytes are simply moved into this dispatch.

When copying of bytes is acceptable or desired, use with_byte_ref.

pub fn with_byte_ref(self, bytes: impl AsRef<[u8]>) -> Self

Copies the given bytes to the payload of this Dispatch.

pub fn durable(self) -> Self

Sets the durability flag in the AMQPProperties of this Dispatch to “durable”.

pub fn transient(self) -> Self

Sets the durability flag in the AMQPProperties of this Dispatch to “transient”.

pub fn with_priority(self, priority: u8) -> Self

Sets the priority in the AMQPProperties of this Dispatch to the given value.

pub fn with_timestamp(self, timestamp: u64) -> Self

Sets the timestamp in the AMQPProperties of this Dispatch to the given value.

pub fn with_current_timestamp(self) -> Self

Sets the timestamp in the AMQPProperties of this Dispatch to the current timestamp.

pub fn with_attempt(self, attempt: u32) -> Self

Sets the attempt header of this Dispatch to the given value.

pub fn with_incremented_attempt(self) -> Self

Increments the attempt header of this Dispatch by one. If the attempt is not yet present, it will be assumed to be zero, and will be incremented to one.

pub fn with_content_type<T>(self, content_type: T) -> Self

where ShortString: Morph<T>,

Sets the content type of this Dispatch to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder().with_content_type("application/json").build();

pub fn with_content_encoding<T>(self, content_encoding: T) -> Self

where ShortString: Morph<T>,

Sets the content encoding of this Dispatch to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder().with_content_encoding("gzip").build();

pub fn with_header<T>(self, key: &str, value: T) -> Self

where AMQPValue: Morph<T>,

Sets a header of this Dispatch under the given key to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder()
    .with_header("created_via", "strut")
    .with_header("processed_in_secs", 12.9)
    .build();

pub fn with_correlation_id<T>(self, correlation_id: T) -> Self

where ShortString: Morph<T>,

Sets the correlation ID of this Dispatch to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder().with_correlation_id(4489).build();

pub fn with_reply_to<T>(self, reply_to: T) -> Self

where ShortString: Morph<T>,

Sets the “reply-to” value of this Dispatch to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder().with_reply_to("me").build();

pub fn with_expiration<T>(self, expiration: T) -> Self

where ShortString: Morph<T>,

Sets the expiration of this Dispatch to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder().with_expiration(86400).build();

pub fn with_message_id<T>(self, message_id: T) -> Self

where ShortString: Morph<T>,

Sets the message ID of this Dispatch to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder().with_message_id(664833405).build();

pub fn with_kind<T>(self, kind: T) -> Self

where ShortString: Morph<T>,

Sets the kind of this Dispatch to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder().with_kind("priority").build();

pub fn with_user_id<T>(self, user_id: T) -> Self

where ShortString: Morph<T>,

Sets the user ID of this Dispatch to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder()
    .with_user_id("01522090-f465-4a44-bd3d-9e06c061f6ac")
    .build();

pub fn with_app_id<T>(self, app_id: T) -> Self

where ShortString: Morph<T>,

Sets the app ID of this Dispatch to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder().with_app_id("app_17").build();

pub fn with_cluster_id<T>(self, cluster_id: T) -> Self

where ShortString: Morph<T>,

Sets the cluster ID of this Dispatch to the given value.

Example

use strut_rabbitmq::Dispatch;

let dispatch = Dispatch::builder().with_cluster_id(7747).build();

pub fn with_routing_key(self, routing_key: impl Into<String>) -> Self

Defines a routing key to be used just for this dispatch.

If this method is never called, the Publisher instead uses the routing key configured on the Egress.

pub fn build(self) -> Dispatch

Builds the Dispatch.