legend-saga 0.0.47

A Rust library for working with RabbitMQ and asynchronous operations
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

/// Represents the names of specific message queues in the RabbitMQ context.
pub struct Queue;

impl Queue {
    /// Queue used for sending replies in response to saga events.
    pub const REPLY_TO_SAGA: &'static str = "reply_to_saga";
    /// Queue used for commencing a saga.
    pub const COMMENCE_SAGA: &'static str = "commence_saga";
    /// Queue for audit.published events
    pub const AUDIT_PUBLISHED_COMMANDS: &'static str = "audit_published_commands";
    /// Queue for audit.received events
    pub const AUDIT_RECEIVED_COMMANDS: &'static str = "audit_received_commands";
    /// Queue for audit.processed events
    pub const AUDIT_PROCESSED_COMMANDS: &'static str = "audit_processed_commands";
    /// Queue for audit.dead_letter events
    pub const AUDIT_DEAD_LETTER_COMMANDS: &'static str = "audit_dead_letter_commands";
}

/// Represents the names of exchanges, which act as message routing hubs in the RabbitMQ context.
pub struct Exchange;

impl Exchange {
    /// Exchange dedicated to requeueing messages that require further processing in a saga process
    pub const REQUEUE: &'static str = "requeue_exchange";
    /// Exchange for sending command messages to various consumers in a saga process
    pub const COMMANDS: &'static str = "commands_exchange";
    /// Exchange used for starting a saga.
    pub const MATCHING: &'static str = "matching_exchange";
    /// Exchange dedicated to requeueing messages that require further processing.
    pub const MATCHING_REQUEUE: &'static str = "matching_requeue_exchange";
    /// Exchange for audit events (audit.received, audit.processed, audit.dead_letter)
    pub const AUDIT: &'static str = "audit_exchange";
}

/// Represents the names of specific message queues in the RabbitMQ context.
pub type ExchangeType = &'static str;

/// Properties defining a queue consumer within the RabbitMQ context.
pub struct QueueConsumerProps {
    /// The name of the queue that messages will be consumed from.
    pub queue_name: String,
    /// The associated exchange for the queue, used for routing messages.
    pub exchange: ExchangeType,
}