diff options
| -rw-r--r-- | librabbitmq/amqp_connection.c | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/librabbitmq/amqp_connection.c b/librabbitmq/amqp_connection.c index 17a30d1..d39a829 100644 --- a/librabbitmq/amqp_connection.c +++ b/librabbitmq/amqp_connection.c @@ -226,6 +226,10 @@ int amqp_handle_input(amqp_connection_state_t state, break; } + case AMQP_FRAME_HEARTBEAT: + decoded_frame->frame_type = AMQP_FRAME_HEARTBEAT; + break; + default: /* Ignore the frame by not changing frame_type away from 0. */ break; @@ -311,6 +315,12 @@ static int inner_send_frame(amqp_connection_state_t state, separate_body = 1; break; + case AMQP_FRAME_HEARTBEAT: + *encoded = AMQP_EMPTY_BYTES; + *payload_len = 0; + separate_body = 0; + break; + default: return -EINVAL; } |