GossamerAmqp

Tiny event bus API

Examples

Publisher

import GossamerAmqp.Connection

GossamerAmqp.Sink.send(open_connection).("event.example", {[message: example]})

Consumer

import GossamerAmqp.Connection

GossamerAmqp.Source.subscribe(open_connection).("event.example", fn(message) ->
  IO.inspect(message)
end)