pool-example-clean

Description

Is used to mark pool examples that need to be cleaned up. This event is registered within a manager service when the pool is updated and some old messages are not available anymore.

class MessagePoolExampleClean(BaseKafkaModel):
    _topic = 'message_pool_example_cleans'
 
    def __init__(self, pool_id: int, compound_id: str, timestamp: int = None, **kwargs):
        super(MessagePoolExampleClean, self).__init__(**kwargs)
        self.compound_id = compound_id
        self.pool_id = pool_id
        self.timestamp = timestamp or int(time.time())