OptionaladapterOptionalautoIf true then the connection will be made automatically. Otherwise .connect() should be called before attempting to do any operations.
OptionaldefaultsOptionalappId?: stringThe name of the application. This will be used as the appId when publishing messages.
Optionalconcurrency?: numberThe default concurrency to use for consumers. This can be overridden by calling .concurrency (or it's alias, .prefetch) on the chain.
OptionalextensionsAdditional methods to add to the chains.
OptionalglobalAdd global middlewares to be run for all consumers
OptionallogOptionalreconnectDelay in milliseconds before trying to reconnect to the broker after a connection failure.
OptionaltlsTLS options to use when connecting to the broker
Adapter to use for commands to the broker. Useful for testing.