Packages

subscribex

0.6.0
0.10.0-rc.1 0.10.0-rc.0 0.9.0 0.8.1 0.8.0 0.8.0-rc.1 0.8.0-rc.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0

A high-level library for making RabbitMQ subscribers

HexDocs

Current section

Files

Jump to
Readme
14 Versions
1 Dependency
Dependants
Files
Activity
subscribex lib test_subscriber.ex
Raw

lib/test_subscriber.ex 

defmodule Subscribex.TestSubscriber do

  use Subscribex.Subscriber



  require Logger



  header_exchange "he_events"

  queue "test.queue"

  routing_key "test.queue.de"

  provide_channel!



  def start_link, do: Subscribex.Subscriber.start_link(__MODULE__)



  def handle_payload(payload, channel) do

    Logger.info(payload)

    Subscribex.publish(channel, exchange, routing_key, payload)

    {:ok, :ack}

  end

end