We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5deb29d commit 4310d8cCopy full SHA for 4310d8c
1 file changed
src/asyncapi_python/contrib/wire/amqp/producer.py
@@ -120,13 +120,8 @@ async def send_batch(
120
address_override if address_override is not None else self._routing_key
121
)
122
123
- # Validate we have a destination
124
- # Note: empty string is valid for default exchange with default queue
125
- if effective_routing_key is None:
126
- raise ValueError(
127
- f"Cannot send: no routing destination specified. "
128
- f"address_override={address_override}, routing_key={self._routing_key}"
129
- )
+ # Note: empty string is valid for default exchange routing
+ # All valid routing configurations should result in a non-None string at this point
130
131
for message in messages:
132
amqp_message = AmqpMessage(
0 commit comments