Struct MassTransitOptions 

pub struct MassTransitOptions {
    pub message_type: String,
    pub correlation_id: Option<String>,
    pub source_address: Option<String>,
    pub destination_address: Option<String>,
}

MassTransit-specific options for message publishing

Fields

message_type: String

Message type in URN format: “urn:message:Namespace:TypeName” or simple format: “Namespace:TypeName” (will be converted to URN)

correlation_id: Option<String>

Optional correlation ID

source_address: Option<String>

Optional source address (defaults to exchange/queue if not provided)

destination_address: Option<String>

Optional destination address (defaults to routing_key/queue if not provided)

Implementations

impl MassTransitOptions

pub fn new(message_type: impl Into<String>) -> Self

Create new MassTransit options with message type

pub fn with_correlation_id(self, correlation_id: impl Into<String>) -> Self

Set correlation ID

pub fn with_source_address(self, source_address: impl Into<String>) -> Self

Set source address

pub fn with_destination_address( self, destination_address: impl Into<String>, ) -> Self

Set destination address

Trait Implementations

impl Clone for MassTransitOptions

fn clone(&self) -> MassTransitOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MassTransitOptions

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

Formats the value using the given formatter.