RedisBatchStreamMessage
faststream.redis.message.RedisBatchStreamMessage dataclass
#
RedisBatchStreamMessage(raw_message, body, headers=dict(), batch_headers=list(), path=dict(), content_type=None, reply_to='', message_id=gen_cor_id(), correlation_id=gen_cor_id(), _source_type=Consume)
Bases: _RedisStreamMessageMixin[BatchStreamMessage]
correlation_id class-attribute
instance-attribute
#
correlation_id = field(default_factory=gen_cor_id)