CHANGELOG¶
1.2.0¶
Fixed Multiple consumer on the same model
Refactored bus console script, Added processes parameter on bus_consumer. The goal is to define processes for one queue, by default all the queues are in the same process
Add better logging when a queue is missing. If a queue is missing, then workers won’t start.
Added adapter parameter to transform bus message, the schema attribute become now a simple kwargs argument give to adapter.
The adapter is not required.
Note
To keep the compatibility, if no adapter is defined with a schema then the adapter is schema_adapter
1.1.0 (2018-09-15)¶
- Improved logging: for helping to debug the messages
- Added create and update date columns
- fixed
consume_all
method. now the method does not stop when an exception is raised - Used marsmallow version >= 3.0.0
1.0.0 (2018-06-05)¶
- add Worker to consume the message from rabbitmq
- add publish method to publish a message to rabbitmq
- add anyblok_bus.bus_consumer add decorator to défine the consumer