Source code for platypush.message.event.kafka
from platypush.message.event import Event
[docs]class KafkaMessageEvent(Event):
"""
Kafka message event object. Fired when :mod:`platypush.backend.kafka` receives
a new event.
"""
[docs] def __init__(self, msg, *args, **kwargs):
"""
:param msg: Received message
:type msg: str or bytes stream
"""
super().__init__(msg=msg, *args, **kwargs)
# vim:sw=4:ts=4:et: