[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