queue-runtime 0.2.0

Multi-provider queue runtime for Queue-Keeper
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
45
46
47
48
49
50
51
52
53
54
55
56

//! # Queue Runtime
//!
//! Multi-provider queue runtime for reliable message processing with support for
//! Azure Service Bus, AWS SQS, RabbitMQ, NATS, and in-memory implementations.
//!
//! This library provides:
//! - Provider-agnostic queue operations
//! - Session-based ordered message processing
//! - Dead letter queue support
//! - Retry policies with exponential backoff
//! - Batch operations where supported
//!
//! ## Module Organization
//!
//! - [`error`] - Error types for all queue operations
//! - [`message`] - Message structures and receipt handles
//! - [`provider`] - Provider types and configuration
//! - [`client`] - Client traits and implementations
//!
//! See specs/interfaces/queue-client.md for complete specification.

// Module declarations
pub mod client;
pub mod error;
pub mod message;
pub mod provider;
pub mod providers;
pub mod sessions;

// Re-export commonly used types at crate root for convenience
pub use client::{
    QueueClient, QueueClientFactory, QueueProvider, SessionClient, SessionProvider,
    StandardQueueClient,
};
pub use error::{ConfigurationError, QueueError, SerializationError, ValidationError};
pub use message::{
    Message, MessageId, QueueName, ReceiptHandle, ReceivedMessage, SessionId, Timestamp,
};
pub use provider::{
    AwsSqsConfig, AzureServiceBusConfig, InMemoryConfig, ProviderConfig, ProviderType, QueueConfig,
    SessionSupport,
};
pub use providers::nats::NatsConfig;
pub use providers::rabbitmq::RabbitMqConfig;
pub use providers::{
    AwsError, AwsSessionProvider, AwsSqsProvider, AzureAuthMethod, AzureError,
    AzureServiceBusProvider, AzureSessionProvider, InMemoryProvider, InMemorySessionProvider,
    NatsError, NatsProvider, NatsSessionProvider, RabbitMqError, RabbitMqProvider,
    RabbitMqSessionProvider,
};
pub use sessions::{
    CompositeKeyStrategy, FallbackStrategy, NoOrderingStrategy, SessionAffinity,
    SessionAffinityTracker, SessionInfo, SessionKeyExtractor, SessionKeyGenerator,
    SessionLifecycleConfig, SessionLifecycleManager, SessionLock, SessionLockManager,
    SingleFieldStrategy,
};