[jira] [Created] (PROTON-1917) [proton-c] When qpid broker is killed and started, the c++ proton consumer (with retry) is randomly receiving an exception

["Jeremy (JIRA)" <ji...@apache.org>]

Jeremy created PROTON-1917:
------------------------------

             Summary: [proton-c] When qpid broker is killed and started, the c++ proton consumer (with retry) is randomly receiving an exception
                 Key: PROTON-1917
                 URL: https://issues.apache.org/jira/browse/PROTON-1917
             Project: Qpid Proton
          Issue Type: Bug
          Components: cpp-binding
    Affects Versions: proton-c-0.22.0
            Reporter: Jeremy


I have a running broker, and a configured queue and containing messages.

I also have a consumer, where I configured the max delay to 0 (infinite retry).
 Upon reconnection, I get the following error message randomly:
{code:java}
receive_with_retry on_connection_open
receive_with_retry: on_error: amqp:not-found: Virtual host 'localhost' is not active
main: end{code}
I was able to reproduce with the following code, on windows 7 (msvc 12 2013)
{code:java}
class receive_with_retry : public proton::messaging_handler {
private:
   std::string url;
   std::string queueName;

public:
   receive_with_retry(const std::string &u, const std::string& q) : url(u), queueName(q) {}

   void on_container_start(proton::container &c) override {
      std::cout << "receive_with_retry on_container_start" << std::endl;

      c.connect(
         url,
         proton::connection_options()
            .idle_timeout(proton::duration(2000))
            .reconnect(proton::reconnect_options()
                        .max_attempts(0)
                        .delay(proton::duration(3000))
                        .delay_multiplier(1)
                        .max_delay(proton::duration(3001))));
   }

   void on_connection_open(proton::connection& c) override {
      std::cout << "receive_with_retry on_connection_open " << std::endl;
      c.open_receiver(queueName, proton::receiver_options().auto_accept(false));
   }

   void on_session_open(proton::session& session) override {
      std::cout << "receive_with_retry on_session_open " << std::endl;
   }

   void on_receiver_open(proton::receiver& receiver) override {
      std::cout << "receive_with_retry on_receiver_open " << std::endl;
      receiver.open();
   }

   void on_message(proton::delivery& delivery, proton::message &message) override {
      std::cout << "receive_with_retry on_message " << message.body() << std::endl;

      // commented out in order not to exit immediately, but to retry.
      // delivery.receiver().close();
      // delivery.receiver().connection().close();
   }

   void on_transport_error(proton::transport& error) override {
      std::cout << "receive_with_retry: on_transport_error: " << error.error().what() << std::endl;

      error.connection().close();
   }

   void on_error(const proton::error_condition& error) override {
      std::cout << "receive_with_retry: on_error: " << error.what() << std::endl;
   }
};

void receiveWithRetry(const std::string& url, const std::string& queueName){
   try {
      std::cout << "main: start" << std::endl;
      receive_with_retry receiveWithRetry(url, queueName);
      proton::container(receiveWithRetry).run();
      std::cout << "main: end" << std::endl;
   }

   catch (const std::exception& cause) {
      std::cout << "main: caught exception: " << cause.what() << std::endl;
   }
}

int main() {
   try {
      receiveWithRetry("amqp://localhost:5673", "test_queue");
      return 0;
   }
   catch (const std::exception& e) {
      std::cerr << e.what() << std::endl;
   }
   return 1;
}
{code}
 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org