Source code for papfa.middlewares.producer

import abc



[docs]class ProducerMiddleware(abc.ABC):

[docs]    def process_before_produce(self, message: dict) -> dict:
        return message



[docs]    def process_after_produce(self, message: dict):
        pass