diff options
| author | Oleg Blednov <blake-r@linkfeed.ru> | 2013-10-31 18:16:04 +0400 |
|---|---|---|
| committer | Alan Antonuk <alan.antonuk@gmail.com> | 2013-11-05 22:53:59 -0800 |
| commit | ce64e57df8c9f7c53dc98a265513e15960d1841a (patch) | |
| tree | 117f7e5024163da0ca3ece3ca4a23715e8bae19c /librabbitmq/amqp_consumer.c | |
| parent | 715901d6755eddcd3a91b7b80d4699e1cb3414d7 (diff) | |
| download | rabbitmq-c-ce64e57df8c9f7c53dc98a265513e15960d1841a.tar.gz | |
Right unexpected frames requeue in amqp_consumer.c
Diffstat (limited to 'librabbitmq/amqp_consumer.c')
| -rw-r--r-- | librabbitmq/amqp_consumer.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/librabbitmq/amqp_consumer.c b/librabbitmq/amqp_consumer.c index 6fb5b96..6c6c1c9 100644 --- a/librabbitmq/amqp_consumer.c +++ b/librabbitmq/amqp_consumer.c @@ -153,7 +153,7 @@ amqp_consume_message(amqp_connection_state_t state, amqp_envelope_t *envelope, if (AMQP_FRAME_METHOD != frame.frame_type || AMQP_BASIC_DELIVER_METHOD != frame.payload.method.id) { - amqp_queue_frame(state, &frame); + amqp_put_back_frame(state, &frame); ret.reply_type = AMQP_RESPONSE_LIBRARY_EXCEPTION; ret.library_error = AMQP_STATUS_UNEXPECTED_STATE; goto error_out1; @@ -227,7 +227,7 @@ amqp_rpc_reply_t amqp_read_message(amqp_connection_state_t state, ret.reply_type = AMQP_RESPONSE_LIBRARY_EXCEPTION; ret.library_error = AMQP_STATUS_UNEXPECTED_STATE; - amqp_queue_frame(state, &frame); + amqp_put_back_frame(state, &frame); } goto error_out1; } |