Categorygithub.com/jmalloc/axaxrmq
package
0.5.0
Repository: https://github.com/jmalloc/ax.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
13
Dependents
1
Files
796 SLOC

# Variables

DefaultReceiveConcurrency is the default number of messages to process concurrently.
DefaultSendConcurrency is the default number of messages to send concurrently.

# Structs

Acknowledger is an implementation of bus.Acknowledger that acknowledges AMQP messages.
Transport is an implementation of endpoint.InboundTransport and endpoint.OutboundTransport that uses RabbitMQ to communicate messages between endpoints.