AMQPHelpers.HighThroughput (AMQP Helpers v1.4.1)
Utilities for dealing with high-throughput scenarios.
This module provides a couple of functions which enforce some options to achieve good results on high throughput scenarios. Review the High Throughput section for more information.
Link to this section Summary
Link to this section Functions
Link to this function
consume(adapter \\ Adapter, channel, queue, consumer \\ nil, options \\ [])
Specs
consume(module(), AMQP.Channel.t(), String.t(), pid() | nil, keyword()) :: {:ok, String.t()} | AMQP.Basic.error()
Registers a queue consumer process.
Like AMQP.Basic.consume/4
but enforces options which play nicely with a high
throughput scenario.
Link to this function
publish(adapter \\ Adapter, channel, exchange, routing_key, payload, options \\ [])
Specs
publish( module(), AMQP.Channel.t(), AMQP.Basic.exchange(), AMQP.Basic.routing_key(), AMQP.Basic.payload(), keyword() ) :: :ok | AMQP.Basic.error()
Publishes a message to an Exchange.
Like AMQP.Basic.publish/5
but enforces options which play nicely with a high
throughput scenario.