Hey gophers! ![]()
Shipped VarMQ v1.5.0! In case you haven’t heard of it, VarMQ is a lightweight, in-process job queue library for Go. It supports standard, priority, persistent, and distributed queues with a simple worker-based API. No external dependencies by default.
Anyway, here’s what’s new:
Default strategy change: multi-queue binding now defaults to Priority instead of RoundRobin.
Queue priorities: you can now assign processing priorities to individual queues when binding them to workers using the new WithQueuePriority option.
Default config modifiers: added standalone functions like DefaultConcurrency, DefaultStrategy, etc. so you can set global defaults for all new workers in one place.
Also fixed a subtle bug where redundant recursive calls in the worker event loop could silently swallow errors.
Feedback and issues welcome as always