If you grep the source, you can see a bit where Kombu itself fills out a correlation ID calling publish
, in kombu.common.send_reply
:
producer.publish(
msg, exchange=exchange,
retry=retry, retry_policy=retry_policy,
**dict({'routing_key': req.properties['reply_to'],
'correlation_id': req.properties.get('correlation_id'),
'serializer': serializers.type_to_name[req.content_type],
'content_encoding': req.content_encoding}, **props)
)
correlation_id
is the name of the kwarg used.