Packages

A framework for handling distributed and ordered processing of data over AMQP queues.

Current section

Files

Jump to
mississippi lib producer options.ex
Raw

lib/producer/options.ex

# Copyright 2024 SECO Mind Srl
# SPDX-License-Identifier: Apache-2.0
defmodule Mississippi.Producer.Options do
@moduledoc false
alias Mississippi.Producer.EventsProducer
definition =
[
amqp_producer_options: [
type: :keyword_list,
keys: [
username: [
type: :string,
default: "guest"
],
password: [
type: :string,
default: "guest"
],
virtual_host: [
type: :string,
default: "/"
],
host: [
type: :string,
default: "localhost"
],
port: [
type: :pos_integer,
default: 5672
],
ssl_options: [
type: :keyword_list
],
channels: [
type: :pos_integer,
default: 10,
doc: """
The number of AMQP channels to open for each AMQP connection.
"""
]
]
]
] ++
EventsProducer.Options.producer_opts()
@definition NimbleOptions.new!(definition)
def definition, do: @definition
end