Function amqp_queue_frame

Synopsis

#include <librabbitmq/amqp_socket.h>

int amqp_queue_frame(amqp_connection_state_t state, amqp_frame_t *frame)

Description

No description yet.

Source

Lines 861-877 in librabbitmq/amqp_socket.c. Line 174 in librabbitmq/amqp_socket.h.

int amqp_queue_frame(amqp_connection_state_t state, amqp_frame_t *frame) {
  amqp_link_t *link = amqp_create_link_for_frame(state, frame);
  if (NULL == link) {
    return AMQP_STATUS_NO_MEMORY;
  }

  if (NULL == state->first_queued_frame) {
    state->first_queued_frame = link;
  } else {
    state->last_queued_frame->next = link;
  }

  link->next = NULL;
  state->last_queued_frame = link;

  return AMQP_STATUS_OK;
}





Add Discussion as Guest

Log in to DocsForge