Kombu (Kombu v0.1.0)

Top-level facade for the Kombu messaging library for Elixir.

Provides convenient entrypoints matching kombu.__init__ in Python Kombu:

Kombu.connection/1,2 (kombu.Connection)
Kombu.broker_connection/1,2 (kombu.BrokerConnection)
Kombu.exchange/1,2 (kombu.Exchange)
Kombu.queue/1,2,3,4 (kombu.Queue)
Kombu.binding/1,2,3 (kombu.binding)
Kombu.producer/1,2 (kombu.Producer)
Kombu.consumer/1,2,3 (kombu.Consumer)
Kombu.uuid/0 (kombu.common.uuid)
Kombu.eventloop/2 (kombu.common.eventloop)
Kombu.parse_url/1 (kombu.utils.url.parse_url)
Kombu.enable_insecure_serializers/1
Kombu.disable_insecure_serializers/1
Kombu.connections/1 (kombu.pools.connections)
Kombu.producers/1 (kombu.pools.producers)

Summary

Functions

binding(exchange \\ nil, opts \\ [])

Creates a new %Kombu.Binding{} (kombu.binding).

binding(exchange, routing_key, opts)

See Kombu.Binding.new/3.

broker_connection(url_or_opts \\ [])

Alias for Kombu.connection/1,2 (kombu.BrokerConnection).

broker_connection(url, opts)

See Kombu.Connection.new/2.

connection(url_or_opts \\ [])

Creates a new %Kombu.Connection{} (kombu.Connection).

connection(url, opts)

See Kombu.Connection.new/2.

connections(conn)

Returns the connection pool for conn (kombu.pools.connections[conn]).

consumer(channel_or_conn, queues \\ [], opts \\ [])

Creates a new %Kombu.Consumer{} (kombu.Consumer).

disable_insecure_serializers(allowed \\ nil)

Disables insecure serializers (kombu.serialization.disable_insecure_serializers).

enable_insecure_serializers(names \\ nil)

Enables serializers (kombu.serialization.enable_insecure_serializers).

eventloop(conn, opts \\ [])

Runs an event loop generator on a connection (kombu.common.eventloop).

exchange(name \\ "", opts \\ [])

Creates a new %Kombu.Exchange{} (kombu.Exchange).

parse_url(url)

Parses a connection URL string into a keyword list (kombu.utils.url.parse_url).

producer(channel_or_conn \\ nil, opts \\ [])

Creates a new %Kombu.Producer{} (kombu.Producer).

producers(conn)

Returns the producer pool for conn (kombu.pools.producers[conn]).

queue(name \\ "", exchange_or_opts \\ [])

Creates a new %Kombu.Queue{} (kombu.Queue).

queue(name, exchange, opts)

See Kombu.Queue.new/3.

queue(name, exchange, routing_key, opts)

See Kombu.Queue.new/4.

simple_buffer(channel_or_conn, name, opts \\ [])

Creates a new %Kombu.Simple.SimpleBuffer{} (kombu.simple.SimpleBuffer).

simple_queue(channel_or_conn, name, opts \\ [])

Creates a new %Kombu.Simple.SimpleQueue{} (kombu.simple.SimpleQueue).

uuid()

Generates a UUID4 string (kombu.common.uuid).

version()

Returns the Kombu version string matching Python Kombu (5.7.0rc1).

Functions

binding(exchange \\ nil, opts \\ [])

Creates a new %Kombu.Binding{} (kombu.binding).

binding(exchange, routing_key, opts)

See Kombu.Binding.new/3.

broker_connection(url_or_opts \\ [])

Alias for Kombu.connection/1,2 (kombu.BrokerConnection).

broker_connection(url, opts)

See Kombu.Connection.new/2.

connection(url_or_opts \\ [])

Creates a new %Kombu.Connection{} (kombu.Connection).

connection(url, opts)

See Kombu.Connection.new/2.

connections(conn)

Returns the connection pool for conn (kombu.pools.connections[conn]).

consumer(channel_or_conn, queues \\ [], opts \\ [])

Creates a new %Kombu.Consumer{} (kombu.Consumer).

disable_insecure_serializers(allowed \\ nil)

Disables insecure serializers (kombu.serialization.disable_insecure_serializers).

enable_insecure_serializers(names \\ nil)

Enables serializers (kombu.serialization.enable_insecure_serializers).

eventloop(conn, opts \\ [])

Runs an event loop generator on a connection (kombu.common.eventloop).

exchange(name \\ "", opts \\ [])

Creates a new %Kombu.Exchange{} (kombu.Exchange).

parse_url(url)

Parses a connection URL string into a keyword list (kombu.utils.url.parse_url).

producer(channel_or_conn \\ nil, opts \\ [])

Creates a new %Kombu.Producer{} (kombu.Producer).

producers(conn)

Returns the producer pool for conn (kombu.pools.producers[conn]).

queue(name \\ "", exchange_or_opts \\ [])

Creates a new %Kombu.Queue{} (kombu.Queue).

queue(name, exchange, opts)

See Kombu.Queue.new/3.

queue(name, exchange, routing_key, opts)

See Kombu.Queue.new/4.

simple_buffer(channel_or_conn, name, opts \\ [])

Creates a new %Kombu.Simple.SimpleBuffer{} (kombu.simple.SimpleBuffer).

simple_queue(channel_or_conn, name, opts \\ [])

Creates a new %Kombu.Simple.SimpleQueue{} (kombu.simple.SimpleQueue).

uuid()

Generates a UUID4 string (kombu.common.uuid).

version()

@spec version() :: String.t()

Returns the Kombu version string matching Python Kombu (5.7.0rc1).