AMQPHelpers.HighThroughput (AMQP Helpers v1.3.0)

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

Publishes a message to an Exchange.

Like AMQP.Basic.publish/5 but enforces options which play nicely with a high throughput scenario.