Struct HttpPlainMessageSenderWithTracking

pub struct HttpPlainMessageSenderWithTracking { /* private fields */ }

HTTP message sender with delivery tracking

This sender extends HttpPlainMessageSender with delivery tracking capabilities, recording delivery attempts, success/failure status, HTTP status codes, and retry counts in the database for monitoring and automatic retry processing.

Features

• All capabilities of HttpPlainMessageSender
• Delivery record creation before sending
• Status updates after delivery attempts
• Retry count tracking
• HTTP status code recording
• Error message logging

Usage

// Create storage instance
let storage = Arc::new(Storage::new(None).await?);

// Create sender with tracking
let sender = HttpPlainMessageSenderWithTracking::new(
    "https://recipient.example.com".to_string(),
    storage
);

// Send message - delivery will be tracked automatically
sender.send("packed_message".to_string(), vec!["did:example:recipient".to_string()]).await?;

Implementations

impl HttpPlainMessageSenderWithTracking

pub fn new(base_url: String, storage: Arc<Storage>) -> Self

Create a new HttpPlainMessageSenderWithTracking

pub fn with_options( base_url: String, timeout_ms: u64, max_retries: u32, storage: Arc<Storage>, ) -> Self

Create a new HttpPlainMessageSenderWithTracking with custom options

Trait Implementations

impl Debug for HttpPlainMessageSenderWithTracking

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

Formats the value using the given formatter.

impl PlainMessageSender for HttpPlainMessageSenderWithTracking

fn send<'life0, 'async_trait>( &'life0 self, packed_message: String, recipient_dids: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a packed message to one or more recipients