Packages

lepus

0.1.2
0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Opinionated library for RabbitMQ with exponential backoff retries and RPC.

HexDocs

Current section

Files

Jump to
Readme
7 Versions
4 Dependencies
Dependants
Files
Activity
lepus lib lepus rabbit client.ex
Raw

lib/lepus/rabbit/client.ex 

defmodule Lepus.Rabbit.Client do

  @moduledoc false



  alias AMQP.Channel

  alias AMQP.Connection



  @type connection :: Connection.t()

  @type channel :: Channel.t()

  @type error :: {:error, any}

  @type exchange :: String.t()

  @type queue :: String.t()

  @type routing_key :: String.t()



  @callback open_connection(binary | keyword) :: {:ok, connection} | error

  @callback close_connection(connection) :: :ok | error

  @callback open_channel(connection) :: {:ok, channel} | error

  @callback close_channel(channel) :: :ok | error

  @callback declare_queue(channel, queue, keyword) :: :ok | error

  @callback bind_queue(channel, queue, exchange, keyword) :: :ok | error

  @callback declare_direct_exchange(channel, exchange, keyword) :: :ok | error

  @callback publish(channel, exchange, routing_key, binary, keyword) :: :ok | error

end