diff options
| author | Alan Antonuk <alan.antonuk@gmail.com> | 2013-06-25 03:42:31 -0700 |
|---|---|---|
| committer | Alan Antonuk <alan.antonuk@gmail.com> | 2013-06-25 16:10:51 -0700 |
| commit | aca5dc13c7ebce355f490b395ca3a57593348e84 (patch) | |
| tree | 67acfb70c65200737a6e006e8764dd99c4c8743f /librabbitmq/amqp_private.h | |
| parent | daa0e663ed6ae6d49ed3cc0da3043e3d4e8b2252 (diff) | |
| download | rabbitmq-c-github-ask-aca5dc13c7ebce355f490b395ca3a57593348e84.tar.gz | |
Add support for heartbeats in amqp_basic_publish
Check heartbeats when doing basic.publish. Do this by doing a recv on
the socket.
Diffstat (limited to 'librabbitmq/amqp_private.h')
| -rw-r--r-- | librabbitmq/amqp_private.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/librabbitmq/amqp_private.h b/librabbitmq/amqp_private.h index cb7494b..14a9881 100644 --- a/librabbitmq/amqp_private.h +++ b/librabbitmq/amqp_private.h @@ -165,6 +165,8 @@ struct amqp_connection_state_t_ { amqp_pool_t *amqp_get_or_create_channel_pool(amqp_connection_state_t connection, amqp_channel_t channel); amqp_pool_t *amqp_get_channel_pool(amqp_connection_state_t state, amqp_channel_t channel); +int amqp_try_recv(amqp_connection_state_t state, uint64_t current_time); + static inline void *amqp_offset(void *data, size_t offset) { return (char *)data + offset; |