veritas.messagebus.rabbitmq
Module Contents
Classes
Messagebus for rabbitmq |
- class veritas.messagebus.rabbitmq.Rabbitmq(app=None, rabbitmq=None, uuid=None)
Messagebus for rabbitmq
- Parameters:
app (str) – name of the app
rabbitmq (dict) – dictionary with rabbitmq connection parameters
uuid (str) – uuid of the app
- write(message)
write message to rabbitmq endpoints
- Parameters:
message (message.record) – the message to write