diff options
| author | Ask Solem <ask@celeryproject.org> | 2013-10-17 14:05:25 +0100 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2013-10-17 14:05:25 +0100 |
| commit | b82c14317185c601195b71f3fd5e3bbd3f2ac996 (patch) | |
| tree | e79cd6a40693fd9ad0179b11c3ce9888f07730cb /Modules | |
| parent | a35a8b271c87473e4f4f30581d4d08b42316cb99 (diff) | |
| download | librabbitmq-b82c14317185c601195b71f3fd5e3bbd3f2ac996.tar.gz | |
Bad frame read should be ConnectionError, not ChannelError
Diffstat (limited to 'Modules')
| -rw-r--r-- | Modules/_librabbitmq/connection.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/Modules/_librabbitmq/connection.c b/Modules/_librabbitmq/connection.c index 7c9cfef..2125136 100644 --- a/Modules/_librabbitmq/connection.c +++ b/Modules/_librabbitmq/connection.c @@ -1930,7 +1930,7 @@ PyRabbitMQ_Connection_basic_recv(PyRabbitMQ_Connection *self, if (PyRabbitMQ_recv(self, NULL, self->conn, 0) < 0) { if (!PyErr_Occurred()) - PyErr_SetString(PyRabbitMQExc_ChannelError, "Bad frame read"); + PyErr_SetString(PyRabbitMQExc_ConnectionError, "Bad frame read"); goto error; } @@ -1999,7 +1999,7 @@ PyRabbitMQ_Connection_basic_get(PyRabbitMQ_Connection *self, if (amqp_data_in_buffer(self->conn)) { if (PyRabbitMQ_recv(self, p, self->conn, 1) < 0) { if (!PyErr_Occurred()) - PyErr_SetString(PyRabbitMQExc_ChannelError, + PyErr_SetString(PyRabbitMQExc_ConnectionError, "Bad frame read"); Py_XDECREF(p); Py_XDECREF(delivery_info); |