Src D Go Queue Versions Save

Queue is a generic interface to abstract the details of implementation of queue systems.

v1.0.6

5 years ago

Supports different int formats for the number of retries. Also discards messages with malformed headers. #19

v1.0.5

5 years ago

This version adds support for advertised window in memory queue #16.

v1.0.4

5 years ago

This release adds back previous memory queue behaviour (non blocking) when created with one of these methods:

  • queue.NewBroker("memoryfinite://")
  • memory.NewFinite(true)

v1.0.3

5 years ago

This minor release mainly packs bug fixes and improvements in testing:

  • Fix test with delayed jobs #9
  • reopen channel, retry publish #11
  • Fix memory queue not blocking on Next #13
  • Upgrade and improve ci system #14

v1.0.2

6 years ago

Issues fixed in this release:

  • Add debug logging to republish buried jobs #4
  • Improve performance republishing jobs #5
  • Update README to reflect all available environment variables

v1.0.1

6 years ago

Minor update, from go-log.v0 to go-log.v1

v1.0.0

6 years ago