}
};
+extern "C" {
+
amqp_connection_state_t AMQP_CALL amqp_new_connection(void) {
auto s = new amqp_connection_state_t_;
return s;
return state->confirm;
}
+#if AMQP_VERSION >= AMQP_VERSION_CODE(0, 11, 0, 1)
+int amqp_simple_wait_frame_noblock(amqp_connection_state_t state, amqp_frame_t *decoded_frame, const struct timeval* tv) {
+#else
int amqp_simple_wait_frame_noblock(amqp_connection_state_t state, amqp_frame_t *decoded_frame, struct timeval* tv) {
+#endif
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) {
return state->consume;
}
+} // extern "C"
+
// amqp_parse_url() is linked via the actual rabbitmq-c library code. see: amqp_url.c
// following functions are the actual implementation copied from rabbitmq-c library
return result;
}
+