5 #ifndef __AMQP_LISTEN_H_
6 #define __AMQP_LISTEN_H_
22 amqp_connection_state_t* conn,
const unsigned int tries);
30 int amqp_consume(amqp_connection_state_t* conn, amqp_envelope_t* envelope);
int amqp_listen_retry(const char *hostname, int port, const char *bindingkey, amqp_connection_state_t *conn, const unsigned int tries)
Setup a consumer for a specific queue.
int amqp_consume(amqp_connection_state_t *conn, amqp_envelope_t *envelope)
Consume one message from a connection object.