search

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
768 stars 125 forks source link

update: Add manual action to consumer handler & expose function for Publishing with deferred confirmation #105

Closed vishal-android-freak closed 1 year ago

vishal-android-freak commented 1 year ago

I would want to spin up goroutines to do some other processing on the message and use the amqp.Delivery object to send acknowledgements later from the routine. Currently the consumer handler expects a compulsory type which doesn't let us do any processing from a routine.

wagslane commented 1 year ago

Please re-pull to trigger a new CI flow! Thanks

vishal-android-freak commented 1 year ago

@wagslane done!

vishal-android-freak commented 1 year ago

Exposed the function from the base amqp llibrary to publish with deferred confirms. This is useful in correlating published messages with publisher confirms via NotifyPublish()

vishal-android-freak commented 1 year ago

@wagslane sorry, you must be busy, but does this look good to merge? Wanted to switch our dependency from our fork to this main repo. Would be great if you can get it merged