openzeppelin_relayer::queues

Function create_queue_backend

Source 
pub async fn create_queue_backend(
    redis_connections: Arc<RedisConnections>,
) -> Result<Arc<QueueBackendStorage>, QueueBackendError>
Expand description

Creates a queue backend based on the QUEUE_BACKEND environment variable.

§Arguments

  • redis_connections - Redis connection pools (used by Redis backend, ignored by SQS)

§Environment Variables

  • QUEUE_BACKEND: Backend to use (“redis” or “sqs”, default: “redis”)

§Returns

Arc-wrapped QueueBackendStorage implementing QueueBackend

§Errors

Returns QueueBackendError::ConfigError if:

  • QUEUE_BACKEND contains an unsupported value
  • Required backend-specific configuration is missing