All notable changes to this project will be documented in this file.
The format is based on Keep a Changelog, and this project adheres to Semantic Versioning.
- modifies
queuebus:unsubscribe
to decommission only the specified application when passed exactly one argument.
- Properly passes the attributes down to the subscription when using
on_heartbeat
- Allows matching on 0 via the
on_heartbeat
subscription
- Allows matching on
wday
via theon_heartbeat
subscription
- Adds
Dispatch#on_heartbeat
which is a helper function for specifying heartbeat subscriptions.
- Pipelines fetching all queue subscriptions when using
QueueBus::Application.all
- Adds
QueueBus.in_context
method. Useful when working with a multithreaded environment to add a description for all events published within this scope.
- Ability to unsubscribe from specific queues in an application (
Application#unsubscribe_queue
). rake queuebus:unsubscribe
can now take two parameters to unsubscribe from specific queues, e.g.rake queuebus:unsubscribe[my_app_key, my_queue_name]
.
- Documented some of the major classes and modules
- Ran the rubocop autocorrect on the entire codebase.
- Fixed issue that prevented heartbeat events from firing under certain conditions
- Adds rake tasks to list scheduled jobs as csv
with_local_mode
breaks subsequent calls tolocal_mode
on versions less than 2.6.
- Adds
QueueBus.with_local_mode
method. Useful when working with a multithreaded environment.
- Adds
QueueBus.has_adapter?
to check whether the adapter is set.
- Now uses
Process.hostname
to determine hostname versus relying on unix shell. - Rubocop is now a dev dependency.
- Accessors to config are now done with actual attrs.
- Logging with the adapter will use the logger if present.
- Passing a class to
adapter=
would error on aNameError
.
- New middleware implementation that allows middleware to wrap the execution of work from the
QueueBus::Worker
- Changelog!
- Specs are now using the
expect
syntax instead ofshould
. This more closely aligns with the rspec recommendations.