Skip to content

implement BrokerMessages

Philipp S. Sommer requested to merge messages into main

This MR implements another model, the BrokerMessage which is a message that is produced for a topic. As for the apache pulsar we can now cache messages until they are acknowledged, or store them forever. This can be configured with the DASF_STORE_MESSAGES variable that can be one of the following values:

``False``
    The message is not stored at all
``"cache"``
    The message is stored and removed ones the `consumer` acknowledges
    the message
``"store"``
    The message and response topics are stored forever and are not
    automatically removed

Merge request reports