View Source Rambla.Handlers.Mock behaviour (Rambla v1.2.5)

Default handler for Mock testing doubles.

Normally, the test.exs config would have included all the channels under config :rambla, mock: […] key. This would allow testing actual interactions using Mox library.

By default it’d be simply send the message back to the caller.

config :rambla, mock: [
  connections: [mocked: :conn],
  channels: [chan_0: [connection: :mocked]]
]

# Then you can access the connection/channel explicitly via `Rambla.Handlers.Mock`
#   or implicitly via `Rambla` as

Rambla.publish(:chan_0, %{message: %{foo: 42}, serializer: Jason})
Rambla.Handlers.Mock.publish(:chan_0, %{message: %{foo: 42}, serializer: Jason})

Summary

Callbacks

on_publish(name, message, options)

Functions

children_specs(options \\ [])

The list of child_spec returned to be embedded into a supervision tree.

do_handle_publish(mock, name, message, options)

extract_options(payload, map)

publish(id, payload, pid \\ nil)

An interface to publish messages using the FSM pool.

start_link(options \\ [])

The entry point: this would start a supervisor with all the pools and stuff

Callbacks

on_publish(name, message, options)

@callback on_publish(name :: atom(), message :: any(), options :: map()) ::
  Rambla.Handler.resolution()

Functions

children_specs(options \\ [])

The list of child_spec returned to be embedded into a supervision tree.

Known options:

connection_options — a keyword() or a function of arity one, which is to receive channel names and return connection options as a list
count — the number of workers in the pool
child_opts — the options to be passed to the worker’s spec (you won’t need those)

Example

Rambla.Handlers.Redis.children_specs(
  connection_options: [exchange: "amq.direct"], count: 3)

do_handle_publish(mock, name, message, options)

extract_options(payload, map)

publish(id, payload, pid \\ nil)

An interface to publish messages using the FSM pool.

The id is the specific to an implementation, for Amqp it’d be the channel name, for instance.

The second parameter would be a payload, or, if the backend supports it, the function of arity one, which would receive back the connection pid.

Example

Rambla.Handlers.Amqp.publish :channel_name, %{foo: :bar}

start_link(options \\ [])

@spec start_link([
  Supervisor.option()
  | Supervisor.init_option()
  | {:connection_options, keyword() | (term() -> keyword())}
  | {:count, non_neg_integer()}
]) :: Supervisor.on_start()

The entry point: this would start a supervisor with all the pools and stuff