Expand description
§Queue Runtime
Multi-provider queue runtime for reliable message processing with support for Azure Service Bus, AWS SQS, 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
- [rror] - 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.
Re-exports§
pub use client::QueueClient;pub use client::QueueClientFactory;pub use client::QueueProvider;pub use client::SessionClient;pub use client::SessionProvider;pub use client::StandardQueueClient;pub use error::ConfigurationError;pub use error::QueueError;pub use error::SerializationError;pub use error::ValidationError;pub use message::Message;pub use message::MessageId;pub use message::QueueName;pub use message::ReceiptHandle;pub use message::ReceiveOptions;pub use message::ReceivedMessage;pub use message::SendOptions;pub use message::SessionId;pub use message::Timestamp;pub use provider::AwsSqsConfig;pub use provider::AzureServiceBusConfig;pub use provider::InMemoryConfig;pub use provider::ProviderConfig;pub use provider::ProviderType;pub use provider::QueueConfig;pub use provider::SessionSupport;pub use providers::AzureAuthMethod;pub use providers::AzureServiceBusProvider;pub use providers::AzureSessionProvider;pub use providers::InMemoryProvider;pub use providers::InMemorySessionProvider;pub use sessions::CompositeKeyStrategy;pub use sessions::FallbackStrategy;pub use sessions::NoOrderingStrategy;pub use sessions::SessionAffinity;pub use sessions::SessionAffinityTracker;pub use sessions::SessionInfo;pub use sessions::SessionKeyExtractor;pub use sessions::SessionKeyGenerator;pub use sessions::SessionLifecycleConfig;pub use sessions::SessionLifecycleManager;pub use sessions::SessionLock;pub use sessions::SessionLockManager;pub use sessions::SingleFieldStrategy;
Modules§
- client
- Client traits and implementations for queue operations.
- error
- Error types for queue operations.
- message
- Message types for queue operations including core domain identifiers.
- provider
- Provider types and configuration.
- providers
- Queue provider implementations.
- sessions
- Session management for ordered message processing.