diff --git a/apis/rabbitmq/producer.py b/apis/rabbitmq/producer.py index 0f35ffb..c00255f 100644 --- a/apis/rabbitmq/producer.py +++ b/apis/rabbitmq/producer.py @@ -88,6 +88,7 @@ def publish_event(self, body: Any, headers: Dict[str, str], routing_key: str): properties=properties, mandatory=True, # Ensures the message gets routed correctly ) + print(f"Publishing event with body: {body}, and headers: {headers}") except (ChannelWrongStateError, AMQPConnectionError) as e: print( f"Failed to publish message due to {str(e)}. Attempting to reconnect..."