subscribex v0.9.0 Subscribex.TestBroker

channel(:link | :no_link | :monitor | (... -> any)) ::
  %AMQP.Channel{conn: term, pid: term} |
  {%AMQP.Channel{conn: term, pid: term}, monitor} |
  any

channel(callback, args \\ [])

Specs

channel(callback, [term]) :: callback_return

channel(module, function, args)

Specs

channel(module, atom, [any]) :: any

close(channel)

config()

Specs

config :: Keyword.t

config(key, default \\ nil)

Specs

config(atom, any) :: any

config!(key)

Specs

config!(atom) :: any

publish(channel, exchange, routing_key, payload, options \\ [])

reject(channel, delivery_tag, options)

start_link(subscribers \\ [])

Specs

start_link([module]) :: Supervisor.on_start