Module enrgdaq.message_broker