diff options
-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, |