diff options
| author | Tony Garnock-Jones <tonygarnockjones@gmail.com> | 2010-01-09 13:09:08 +0000 |
|---|---|---|
| committer | Tony Garnock-Jones <tonygarnockjones@gmail.com> | 2010-01-09 13:09:08 +0000 |
| commit | a30cebfddd019b986d3c2b9356847c2911f5222e (patch) | |
| tree | f501c565a876c1f429b34b7fa0f8d505200357b6 | |
| parent | 4df56e951a2310edf825ec79fb007e16d0f2c2a3 (diff) | |
| download | rabbitmq-c-github-ask-a30cebfddd019b986d3c2b9356847c2911f5222e.tar.gz | |
Pass raw properties along
| -rw-r--r-- | librabbitmq/amqp.h | 1 | ||||
| -rw-r--r-- | librabbitmq/amqp_connection.c | 1 |
2 files changed, 2 insertions, 0 deletions
diff --git a/librabbitmq/amqp.h b/librabbitmq/amqp.h index 45e4d63..a2b062c 100644 --- a/librabbitmq/amqp.h +++ b/librabbitmq/amqp.h @@ -191,6 +191,7 @@ typedef struct amqp_frame_t_ { uint16_t class_id; uint64_t body_size; void *decoded; + amqp_bytes_t raw; } properties; amqp_bytes_t body_fragment; struct { diff --git a/librabbitmq/amqp_connection.c b/librabbitmq/amqp_connection.c index d01af66..47fab11 100644 --- a/librabbitmq/amqp_connection.c +++ b/librabbitmq/amqp_connection.c @@ -221,6 +221,7 @@ int amqp_handle_input(amqp_connection_state_t state, decoded_frame->frame_type = AMQP_FRAME_HEADER; decoded_frame->payload.properties.class_id = D_16(state->inbound_buffer, HEADER_SIZE); decoded_frame->payload.properties.body_size = D_64(state->inbound_buffer, HEADER_SIZE+4); + decoded_frame->payload.properties.raw = encoded; AMQP_CHECK_RESULT(amqp_decode_properties(decoded_frame->payload.properties.class_id, &state->decoding_pool, encoded, |