[rabbitmq-discuss] No error reported when tx_select/basic_publish/tx_commit is given an undefined queue name?
Matt Pietrek
mpietrek at skytap.com
Thu Mar 29 01:16:08 BST 2012
I have a Pika code sequence that looks like this:
channel = self._channel
channel.tx_select()
channel.basic_publish(exchange='',
routing_key=queue_name,
body=json_string,
properties=pika.BasicProperties(delivery_mode=2))
channel.tx_commit()
During some robustness testing, I found that if I passed an invalid queue
name to basic_get, I get an AMQPChannelError as expected. However, when
using the above code to write a message to an invalid queue name, no
exception is seen.
Is this normal or am I missing something? In our scenario, we have to
absolutely, positively know that the message was received by the broker.
Thanks,
Matt
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120328/a93b3866/attachment.htm>
More information about the rabbitmq-discuss
mailing list