Queue is a generic interface to abstract the details of implementation of queue systems.
Supports different int formats for the number of retries. Also discards messages with malformed headers. #19
This version adds support for advertised window in memory queue #16.
This release adds back previous memory queue behaviour (non blocking) when created with one of these methods:
queue.NewBroker("memoryfinite://")
memory.NewFinite(true)
This minor release mainly packs bug fixes and improvements in testing:
Issues fixed in this release:
Minor update, from go-log.v0
to go-log.v1
Initial release based on the code from the https://github.com/src-d/framework/tree/master/queue plus: