Kombu.Transport (Kombu v0.1.0)

Transport behaviour and transport alias resolution (kombu.transport).

Summary

Resolves a transport name/scheme ("redis", "rediss", "memory", or a module) to its transport module.

Normalizes queue arguments into RabbitMQ x-* format (kombu.transport.base.to_rabbitmq_queue_arguments).

Returns the map of supported transport aliases.

@spec resolve_transport(String.t() | atom()) :: module()

Resolves a transport name/scheme ("redis", "rediss", "memory", or a module) to its transport module.

@spec to_rabbitmq_queue_arguments(map() | nil, keyword()) :: map()

Normalizes queue arguments into RabbitMQ x-* format (kombu.transport.base.to_rabbitmq_queue_arguments).

@spec transport_aliases() :: map()

Returns the map of supported transport aliases.