Struct DeliveryBus 

pub struct DeliveryBus { /* private fields */ }

Cross-service message delivery.

Services use this to deliver messages to other services without direct dependencies between service crates. The server wires up the delivery functions at startup.

Implementations

impl DeliveryBus

pub fn new() -> Self

pub fn with_sqs(self, sender: Arc<dyn SqsDelivery>) -> Self

pub fn with_sns(self, sender: Arc<dyn SnsDelivery>) -> Self

pub fn send_to_sqs( &self, queue_arn: &str, message_body: &str, attributes: &HashMap<String, String>, )

Send a message to an SQS queue identified by ARN.

pub fn send_to_sqs_with_attrs( &self, queue_arn: &str, message_body: &str, message_attributes: &HashMap<String, SqsMessageAttribute>, message_group_id: Option<&str>, message_dedup_id: Option<&str>, )

Send a message to an SQS queue with message attributes and FIFO fields.

pub fn publish_to_sns( &self, topic_arn: &str, message: &str, subject: Option<&str>, )

Publish a message to an SNS topic identified by ARN.

Trait Implementations

impl Default for DeliveryBus

fn default() -> Self

Returns the “default value” for a type.