Repository files navigation

This repository isNOT ACTIVELY MAINTAINED. Consider usinga different fork instead:rabbitmq/amqp091-go.In case of questions, start a discussion in that repo oruse other RabbitMQ community resources.

This project has been used in production systems for many years. As of 2022,this repository isNOT ACTIVELY MAINTAINED.

This repository isvery strict about any potential public API changes.You may want to considerrabbitmq/amqp091-go whichis more willing to adapt the API.

This library supports two most recent Go release series, currently 1.10 and 1.11.

This project supports RabbitMQ versions starting with2.0 but primarily testedagainst reasonably recent3.x releases. Some features and behaviours may beserver version-specific.

Provide a functional interface that closely represents the AMQP 0.9.1 modeltargeted to RabbitMQ as a server. This includes the minimum necessary tointeract the semantics of the protocol.

Things not intended to be supported.

• Auto reconnect and re-synchronization of client and server topologies.
  • Reconnection would require understanding the error paths when thetopology cannot be declared on reconnect. This would require a new setof types and code paths that are best suited at the call-site of thispackage. AMQP has a dynamic topology that needs all peers to agree. Ifthis doesn't happen, the behavior is undefined. Instead of producing apossible interface with undefined behavior, this package is designed tobe simple for the caller to implement the necessary connection-timetopology declaration so that reconnection is trivial and encapsulated inthe caller's application code.
• AMQP Protocol negotiation for forward or backward compatibility.
  • 0.9.1 is stable and widely deployed. Versions 0.10 and 1.0 are divergentspecifications that change the semantics and wire format of the protocol.We will accept patches for other protocol support but have no plans forimplementation ourselves.
• Anything other than PLAIN and EXTERNAL authentication mechanisms.
  • Keeping the mechanisms interface modular makes it possible to extendoutside of this package. If other mechanisms prove to be popular, thenwe would accept patches to include them in this package.

See the 'examples' subdirectory for simple producers and consumers executables.If you have a use-case in mind which isn't well-represented by the examples,please file an issue.

UseGodoc documentation forreference and usage.

RabbitMQ tutorials inGo are alsoavailable.

Pull requests are very much welcomed. Create your pull request on a non-masterbranch, make sure a test or example is included that covers your change andyour commits represent coherent changes that include a reason for the change.

To run the integration tests, make sure you have RabbitMQ running on any host,export the environment variableAMQP_URL=amqp://host/ and rungo test -tags integration. TravisCI will also run the integration tests.

Thanks to thecommunity of contributors.

• Google App Engine Dialer support
• RabbitMQ examples in Go

BSD 2 clause - see LICENSE for more details.