I only have one consumer connected to ActiveMQ. With everytime I lose
connection and reconnect, the "number of consumers" increments by 1 (i.e.
+1) instead of just being one (i.e. Number of Consumers: 1). Does it have
anything to do with idle_timeout? Please have a look at the code below. I
even tried appending "wireFormat.maxInactivityDuration=30000" to the
failover url but this did not help. Any help in debugging this further or
guidance would be greatly appreciated!
Thanks!
class class1 : public proton::messaging_handler {
std::string url;
std::string devQueue;
std::vector<std::string> failovers = {"failover:(amqps://1.2.3.4)"};
public:
class1(const std::string& u, const std::string& devQueue) :
url(u), devQueue(devQueue) {}
void on_container_start(proton::container& c) override {
proton::connection_options co;
proton::reconnect_options ro;
ro.failover_urls(failovers);
c.connect(url, co.idle_timeout(proton::duration::SECOND).reconnect(ro));
}
void on_connection_open(proton::connection& c) override {
c.open_receiver(devQueue);
}
...
};
--
Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
