Packages

freddy

0.13.1
0.17.2 0.17.1 0.17.0 0.17.0-rc.5 0.17.0-rc.4 0.17.0-rc.3 0.17.0-rc.2 0.17.0-rc 0.16.0 0.15.2 0.15.1 0.15.0 0.14.0 0.13.1 0.13.0 0.12.1 0.12.0 0.11.0 0.10.2 0.10.1 0.10.0 0.9.2 0.9.1 retired 0.9.0

JSON RPC Client/Server, JSON Publisher-Subscriber over AMQP

HexDocs

Current section

Files

Jump to
Readme
24 Versions
3 Dependencies
Dependants
Files
Activity
freddy lib freddy core channel.ex
Raw

lib/freddy/core/channel.ex 

defmodule Freddy.Core.Channel do

  @moduledoc false



  @type t :: %__MODULE__{

          adapter: module,

          chan: term

        }



  defstruct [:adapter, :chan]



  def open(adapter, connection) do

    case adapter.open_channel(connection) do

      {:ok, chan} ->

        {:ok, %__MODULE__{adapter: adapter, chan: chan}}



      error ->

        error

    end

  end



  def monitor(%{adapter: adapter, chan: chan}) do

    adapter.monitor_channel(chan)

  end



  def close(%{adapter: adapter, chan: chan}) do

    adapter.close_channel(chan)

  end



  def register_return_handler(%{adapter: adapter, chan: chan}, pid) do

    adapter.register_return_handler(chan, pid)

  end

end