Adding support for publishing messages with an expiration.

wagslane / go-rabbitmq

A wrapper of streadway/amqp that provides reconnection logic and sane defaults

https://blog.boot.dev/golang/connecting-to-rabbitmq-in-golang-easy/

MIT License

797 stars 129 forks source link

Adding support for publishing messages with an expiration. #7

Closed ajmckee closed 3 years ago

ajmckee commented 3 years ago

Added WithPublishOptionsExpiration which permits message expiry when the TTL has been reached
Introduced new message var to permit the confidiontal injection of amp.Publishing options in the future.

ajmckee commented 3 years ago

I needed to add support for publishing messages with an expiration. Therefore find a basic PR for this. Additionally as more options are supported I thought it would be a good idea to add some conditional to the injection of amqp.Publishing options. I was not able to determine a method to write tests for this, but if you have suggests I would gladly write some.

wagslane commented 3 years ago

Looks like there's go fmt failure. Once that's resolved I'll get it merged! Thanks for making those changes

ajmckee commented 3 years ago

Looks like there's go fmt failure. Once that's resolved I'll get it merged! Thanks for making those changes

Yep my bad, still figuring out golang and forgot to run fmt.