Packages

yggdrasil

1.2.3
6.0.3 6.0.2 6.0.1 6.0.0 5.0.2 5.0.1 5.0.0 4.1.6 4.1.5 4.1.4 4.1.3 4.1.2 4.1.1 4.1.0 4.0.0 3.3.4 3.3.3 3.3.2 3.3.1 3.3.0 3.2.3 3.2.2 3.2.1 3.2.0 3.1.0 3.0.3 3.0.2 3.0.1 3.0.0 2.1.0 2.0.8 2.0.7 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.2.3 1.2.2 1.2.1 1.1.1 1.1.0 1.0.0

Agnostic pub/sub with Redis, RabbitMQ and Postgres support

HexDocs

Current section

Files

Jump to
Readme
45 Versions
3 Dependencies
Dependants
Files
Activity
yggdrasil test yggdrasil broker rabbitmq_test.exs
Raw

test/yggdrasil/broker/rabbitmq_test.exs 

defmodule Yggdrasil.RabbitMQTest do

  use ExUnit.Case, async: true

  alias Yggdrasil.Proxy, as: Proxy

  alias Yggdrasil.Proxy.Data, as: Data

  alias Yggdrasil.Util.Forwarder, as: Forwarder

  alias Yggdrasil.Messenger, as: Broker

  require Logger



  @forwarder Yggdrasil.Util.Forwarder

  @rabbitmq_broker Yggdrasil.Broker.RabbitMQ



  setup do

    Logger.remove_backend :console

    {:ok, proxy} = Proxy.start_link

    forwarder = Forwarder.set_parent @forwarder

    {:ok, %{proxy: proxy, forwarder: forwarder, channel: {"plants", "trees"}}}

  end



  test "subscribe/unsubscribe",

       %{proxy: proxy, forwarder: forwarder,

         channel: {exchange, routing_key} = channel} do

    {:ok, conn} = AMQP.Connection.open

    {:ok, publisher} = AMQP.Channel.open conn

    AMQP.Exchange.topic publisher, exchange, durable: false

    {:ok, handle} = Proxy.subscribe proxy, @rabbitmq_broker, channel

    {:ok, broker} = Broker.start_link @rabbitmq_broker,

                                      channel,

                                      proxy,

                                      forwarder

    assert_receive {:subscribed, @rabbitmq_broker, ^channel}  # From Rabbit Broker

    message = "Yggdrasil!"

    AMQP.Basic.publish publisher, exchange, routing_key, message 

    assert_receive %Data{broker: @rabbitmq_broker,

                         data: ^message,

                         channel: ^channel}  # From Proxy rerouted by Broker

    Broker.stop broker

    assert_receive {:unsubscribed, @rabbitmq_broker, ^channel}  # From Broker

    Proxy.unsubscribe proxy, handle

    AMQP.Channel.close publisher

    AMQP.Connection.close conn

  end

end