View Source AsyncConfig (reactive_commons v1.0.2)
Configuration structure for using reactive commons abstraction
The required properties are:
- application_name: "my_app"
Optionally you can change the default values for another property
%{
reply_exchange: "globalReply",
direct_exchange: "directMessages",
events_exchange: "domainEvents",
connection_props: "amqp://guest:guest@localhost", this value is passed as uri_or_options in https://hexdocs.pm/amqp/AMQP.Connection.html#open/1
connection_assignation: %{
ReplyListener: ListenerConn,
QueryListener: ListenerConn,
CommandListener: ListenerConn,
EventListener: ListenerConn,
NotificationEventListener: ListenerConn,
MessageExtractor: ListenerConn,
MessageSender: SenderConn,
ListenerController: SenderConn,
},
topology: %{
command_sender: false,
queries_sender: false,
events_sender: false
},
queries_reply: true,
with_dlq_retry: false,
retry_delay: 500,
max_retries: 10,
prefetch_count: 250,
}
Summary
Functions
Creates a new default valued AsyncConfig struct with the specified app name.
Functions
Creates a new default valued AsyncConfig struct with the specified app name.