foxtive-worker 0.2.0

Foxtive Worker - Background worker framework for message processing
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

pub mod contract;
pub mod dlq;
pub mod memory;
pub mod resilient;

#[cfg(feature = "rabbitmq")]
pub mod rabbitmq;

#[cfg(feature = "redis-stream")]
pub mod redis_stream;

pub use contract::MessageBackend;
pub use contract::ReceiveResult;
pub use dlq::{DeadLetterQueueBackend, create_dlq_message};
pub use memory::MemoryBackend;

#[cfg(feature = "rabbitmq")]
pub use rabbitmq::{RabbitMqBackend, RabbitMqConsumerConfig};

#[cfg(feature = "redis-stream")]
pub use redis_stream::{RedisStreamBackend, RedisStreamConsumerConfig};

// Re-export resilient backend types
pub use resilient::{ReconnectStrategy, ResilientBackend, ResilientBackendBuilder};