diff options
| author | Tony Garnock-Jones <tonyg@kcbbs.gen.nz> | 2009-05-12 00:28:39 +0100 |
|---|---|---|
| committer | Tony Garnock-Jones <tonyg@kcbbs.gen.nz> | 2009-05-12 00:28:39 +0100 |
| commit | 9d08293b8e27defb7dba4d84d9f7c11d3520d995 (patch) | |
| tree | 64d051c7b213a7c13717decc99b2d3e7052b01ce | |
| parent | a67c844cdb231f910e43b1709214186b1b1e57bf (diff) | |
| download | rabbitmq-c-github-ask-9d08293b8e27defb7dba4d84d9f7c11d3520d995.tar.gz | |
Return, and send, heartbeat frames.
| -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; } |