rixmann/cdf_nats_test

NatsTestIex

TODO: Add description

Installation

If available in Hex, the package can be installed by adding nats_test_iex to your list of dependencies in mix.exs:

def deps do
  [
    {:nats_test_iex, "~> 0.1.0"}
  ]
end

Documentation can be generated with ExDoc and published on HexDocs. Once published, the docs can be found at https://hexdocs.pm/nats_test_iex.

start nats dockered

docker run -p 4222:4222 nats -js

perform test

$ iex -S mix run
iex(1)> NatsTestIex.QueueSupervisor.start_subscribers(3)
[ok: #PID<0.261.0>, ok: #PID<0.262.0>, ok: #PID<0.263.0>]

iex(2)> for i <- 1..1, do: Gnat.pub(:gnat, "greetings.#{UUID.uuid4()}.#{i}", "Hello World #{i}")
[:ok]
Pull Consumer 3 got message: Hello World 1 on topic greetings.253751ef-6332-4e59-9b45-638c9e38f290.1

iex(3)> NatsTestIex.search_in_archive(%{id: "253751ef-6332-4e59-9b45-638c9e38f290"})
Found event for id 253751ef-6332-4e59-9b45-638c9e38f290 got message: Hello World 1 on topic greetings.253751ef-6332-4e59-9b45-638c9e38f290