View Source GenericListener behaviour (reactive_commons v1.0.2)

Implements generic behaviour for event listeners

Summary

Create resource topology.

initial_state()

Get initial state.

should_listen()

Evaluate if should listen for this kind of events.

@callback create_topology(AMQP.Channel.t(), map()) :: {:ok, term()} | {:error, term()}

Create resource topology.

@callback initial_state() :: map()

Get initial state.

@callback should_listen() :: boolean()

Evaluate if should listen for this kind of events.