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_socket.h | |
| parent | 715901d6755eddcd3a91b7b80d4699e1cb3414d7 (diff) | |
| download | rabbitmq-c-github-ask-ce64e57df8c9f7c53dc98a265513e15960d1841a.tar.gz | |
Right unexpected frames requeue in amqp_consumer.c
Diffstat (limited to 'librabbitmq/amqp_socket.h')
| -rw-r--r-- | librabbitmq/amqp_socket.h | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/librabbitmq/amqp_socket.h b/librabbitmq/amqp_socket.h index b7af785..f8b6f51 100644 --- a/librabbitmq/amqp_socket.h +++ b/librabbitmq/amqp_socket.h @@ -183,6 +183,9 @@ int amqp_queue_frame(amqp_connection_state_t state, amqp_frame_t *frame); int +amqp_put_back_frame(amqp_connection_state_t state, amqp_frame_t *frame); + +int amqp_simple_wait_frame_on_channel(amqp_connection_state_t state, amqp_channel_t channel, amqp_frame_t *decoded_frame); |