Function amqp_basic_consume

Synopsis

#include <librabbitmq/amqp_framing.h>

amqp_basic_consume_ok_t * amqp_basic_consume(amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue, amqp_bytes_t consumer_tag, amqp_boolean_t no_local, amqp_boolean_t no_ack, amqp_boolean_t exclusive, amqp_table_t arguments)

Description

amqp_basic_consume

Parameters:

[ in ] state - connection state

[ in ] channel - the channel to do the RPC on

[ in ] queue - queue

[ in ] consumer_tag - consumer_tag

[ in ] no_local - no_local

[ in ] no_ack - no_ack

[ in ] exclusive - exclusive

[ in ] arguments - arguments

Return
amqp_basic_consume_ok_t

Mentioned in

Source

Lines 2755-2772 in librabbitmq/amqp_framing.c. Line 1073 in librabbitmq/amqp_framing.h.

AMQP_PUBLIC_FUNCTION
amqp_basic_consume_ok_t *AMQP_CALL amqp_basic_consume(
    amqp_connection_state_t state, amqp_channel_t channel, amqp_bytes_t queue,
    amqp_bytes_t consumer_tag, amqp_boolean_t no_local, amqp_boolean_t no_ack,
    amqp_boolean_t exclusive, amqp_table_t arguments) {
  amqp_basic_consume_t req;
  req.ticket = 0;
  req.queue = queue;
  req.consumer_tag = consumer_tag;
  req.no_local = no_local;
  req.no_ack = no_ack;
  req.exclusive = exclusive;
  req.nowait = 0;
  req.arguments = arguments;

  return amqp_simple_rpc_decoded(state, channel, AMQP_BASIC_CONSUME_METHOD,
                                 AMQP_BASIC_CONSUME_OK_METHOD, &req);
}





Add Discussion as Guest

Log in to DocsForge