Packages

amqp_channel_pool

0.2.1
0.2.1 0.2.0 0.1.1 0.1.0

A lightweight Elixir library for managing a pool of AMQP channels using NimblePool.

HexDocs

Current section

Files

Jump to
Readme
4 Versions
3 Dependencies
Dependants
Files
Activity
amqp_channel_pool lib amqp_channel_pool amqp_client.ex
Raw

lib/amqp_channel_pool/amqp_client.ex 

defmodule AMQPChannelPool.AMQPClient do
  @moduledoc false
  @callback open_connection(keyword()) :: {:ok, term()} | {:error, term()}
  @callback open_channel(term()) :: {:ok, term()} | {:error, term()}
  @callback close_connection(term()) :: term()
  @callback close_channel(term()) :: term()
  def open_connection(connection_opts) do
    AMQP.Connection.open(connection_opts)
  end
  def open_channel(connection) do
    AMQP.Channel.open(connection)
  end
  def close_connection(connection) do
    AMQP.Connection.close(connection)
  end
  def close_channel(channel) do
    AMQP.Channel.close(channel)
  end
end