[rabbitmq-discuss] Publish to exchange that doesn't bind to any queue in trunsaction mode

Mon Jul 1 10:52:13 BST 2013

Hi there!

I open channel in transaction mode and try to publish some message to
exchange, that doesn't bind to any queue.
And after commit I have no any error...

I expected that commit will return some error...

Do you know where my message is after that? Is it dropped and if so why I
doesn't receive any error?

Pseudo code:
 amqp_new_connection();
amqp_open_socket(host, port); 
amqp_set_sockfd(conn, sockfd);
amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, user, pass);
amqp_channel_open(conn, channel_exchange);
amqp_rpc_reply_t res = amqp_get_rpc_reply(conn);
amqp_tx_select(conn, channel_exchange);
res = amqp_get_rpc_reply(conn);
... form message ...
  int r = amqp_basic_publish(conn, channel_exchange, exchange_bytes,
routingKey_bytes,  1, 0, &props, message_bytes);
  if (r < 0) {
    char *errstr = amqp_error_string(-r);
    cout << errstr;
    free(errstr);
    char ch;
    cin >> ch;
  }

  amqp_tx_commit(conn, channel_exchange);
  die_on_amqp_error(amqp_get_rpc_reply(conn), "Commit error");

  cout << "Publish = " << r << endl;
  char ch;
  cin >> ch;

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/Publish-to-exchange-that-doesn-t-bind-to-any-queue-in-trunsaction-mode-tp27706.html
Sent from the RabbitMQ mailing list archive at Nabble.com.