--- a/src/test/rgw/amqp_mock.cc +++ b/src/test/rgw/amqp_mock.cc @@ -291,7 +291,11 @@ amqp_confirm_select_ok_t* amqp_confirm_select(amqp_connection_state_t state, amq return state->confirm; } -int amqp_simple_wait_frame_noblock(amqp_connection_state_t state, amqp_frame_t *decoded_frame, struct timeval* tv) { +extern "C" { + +int amqp_simple_wait_frame_noblock(amqp_connection_state_t state, + amqp_frame_t *decoded_frame, + const struct timeval* tv) { if (state->socket && state->socket->open_called && state->login_called && state->channel1 && state->channel2 && state->exchange && state->queue && state->consume && state->confirm && !FAIL_NEXT_READ) { @@ -345,6 +349,7 @@ int amqp_simple_wait_frame_noblock(amqp_connection_state_t state, amqp_frame_t * } return AMQP_STATUS_CONNECTION_CLOSED; } +} // extern "C" amqp_basic_consume_ok_t* amqp_basic_consume( amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue,