Packages

yggdrasil

1.0.0
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
2 Dependencies
Dependants
Files
Activity
yggdrasil test yggdrasil broker redis_test.exs
Raw

test/yggdrasil/broker/redis_test.exs 

defmodule Yggdrasil.RedisTest 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

  @redis_broker Yggdrasil.Broker.Redis



  setup do

    Logger.remove_backend :console

    {:ok, proxy} = Proxy.start_link

    forwarder = Forwarder.set_parent @forwarder

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

  end



  test "subscribe/unsubscribe",

       %{proxy: proxy, forwarder: forwarder, channel: channel} do

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

    {:ok, broker} = Broker.start_link @redis_broker, channel, proxy, forwarder

    assert_receive {:subscribed, @redis_broker, ^channel}  # From Redis Broker

    assert_receive {:broker_conn, conn}  # From Redis Broker

    message = "Yggdrasil!"

    {:ok, publisher} = Exredis.start_link

    publisher |> Exredis.Api.publish(channel, message)

    assert_receive %Data{broker: @redis_broker,

                         data: ^message,

                         channel: ^channel}  # From Proxy rerouted by Broker

    Exredis.stop publisher

    Broker.stop broker

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

    Proxy.unsubscribe proxy, handle

  end

end