- Fix objects() iterator
- configure() now takes parameters in addition to URL string.
- A new
format
argument for Context._update(). WhenFalse
it will not attempt to process curly braces by calling .format() on the message string.
- Add non-logging based configuration (context.configure()), to get around logger hijacking (I'm looking at you, celery)
- Context processor can now wait for the handler queue to empty, automatically. This simplifies things for short-running process and guarantees EOL message delivery.
- Keep messages until channel is open
- monitor: add queue declare args
lcmon
:
--keys
: will now stay in order- Add
--trim
- Add
-z
- Add version to help
- Add tests
- Add missing config.conf to MANIFEST.in
- Deal with variable args in AMQP callbacks
- Add thread id to handler announcement
- Add reconnection timeout argument to amqp_handler
- Add amqp_handler tests
- Bump pika version to 0.9.13
- Announce queue overflows to the bus (from AMQPHandler's own context)
- Announce queue overflows on threshold crossings only (instead of every message)
- Publisher thread and queue are now singletons (configurable)
- Add AMQPHandler arguments for max queue lenght and singularity
- Fix
on_connection_closed()
signature, no more exceptions - Move
__version__
to__init__.py
where it belongs
- Fix time format
- Reconnect to AMQP endpoint on all connection exceptions