Stream Support?

35 views

Skip to first unread message

Janusz Piotrowski

unread,

Aug 22, 2023, 11:33:44 AM8/22/23

to rabbitmq-c-users

Dear all,

I currently facing one problem regarding the interaction with the stream plugin, in general there is the information everything should work like with normal queues, besides the fact, that a qos must be set. But every time I start consuming a stream queue, after basic_qos was set, I got a unknwon error. Is the reason, that rabbitmq-c is not compatible with streams? I have already tried a lot and now I'm stuck at this point. With classic queues everything is working as expected. Heres my code:

amqp_basic_qos_ok_t* ret = amqp_basic_qos(this->connection, this->channel, 0, 100, 0);
  reply = amqp_get_rpc_reply(this->connection);
  if (reply.reply_type != AMQP_RESPONSE_NORMAL) {
    std::cout << "Set basic qos with code " << reply.reply_type << " and exception " << amqp_error_string2(reply.reply_type) << std::endl;
  }

  amqp_basic_consume(this->connection, this->channel, amqp_cstring_bytes(queue.c_str()), amqp_empty_bytes, 0, 1, 0, amqp_empty_table);
  reply = amqp_get_rpc_reply(this->connection); // Executing basic consumption binding
  if (reply.reply_type != AMQP_RESPONSE_NORMAL) {
    std::cout << "Executed basic consume with code " << reply.reply_type << " and exception " << amqp_error_string2(reply.reply_type) << std::endl;
  }