A skeleton to create rabbitmq listener using golang. This skeleton used only to setup basic amqp client listener, and also provide a reconnection process.
Notes:
This skeleton should be always simple and the purpose only to setup new project
to listen amqp (rabbitmq), so I will not provide any magic functionalities or will
develop this skeleton to a framework in the future.
RabbitMQ Client: streadway/amqp
go run *.go -amqpUrl="your-rabbitmq-url"
By default, amqpUrl will be: amqp://guest:guest@localhost:5672
This skeleton also provide some debugging process :
go run *.go -debug
This client system will listen on NotifyClose based on description here. The implementation
is simple, and i just follow these description :
Instead of producing a possible interface with undefined behavior, this package is designed to be simple for the caller to implement the necessary connection-time topology declaration so that reconnection is trivial and encapsulated in the caller's application code.
Based on these explanation, reconnection process should be happened on caller's application code.