Hi
Yeah there is a listerne on the component level that triggers when all
routes are started, see how camel-quarz uses that etc.
On Mon, Aug 12, 2019 at 8:50 AM Michael Zaugg wrote:
>
> Hi
>
> I would suggest to connect() after ALL Consumers are started in
> doStart(). Is this approach feasible?
Hi
I would suggest to connect() after ALL Consumers are started in
doStart(). Is this approach feasible?
On 09.08.19 09:23, Claus Ibsen wrote:
> Hi
>
> Ah yeah well spotted Willem.
>
> The endpoint should only call connection() when the 1st consumer is
> being added, and then disconnect when th
Hi
Ah yeah well spotted Willem.
The endpoint should only call connection() when the 1st consumer is
being added, and then disconnect when the active consumer count hits
zero. So the endpoint needs to keep track on number of consumers
added/removed and react accordingly.
On Fri, Aug 9, 2019 at 8:
I just checked the code of camel-mqtt code, and find a line[1] which
could let to the issue that you face.
If the endpoint is start and consumer is not start yet, the consumers
could be empty, camel cannot send the exchange to right consumer to
use. Maybe you can set a break or add some log to veri
Hi Willem
It's camel version 2.24.0
We gracefully stopped the whole java process with the same result.
"Sending PUBLISH to testclient" occurs before "Received SUBSCRIBE"
according to Mosquitto's log:
1565245897: New client connected from 172.17.0.1 as testclient (p1, c0,
k30).
1565245897: No wi
Hi
Can I know which version of Camel are you using?
I just checked the code of camel-mqtt, there are some changes to fix
the connection related issues.
I doubt that the connection is not full released in your case.
Can you try to stop the camel application instead of stop the camel route?
Wille
We're having difficulties with persistent clients (using
cleanSession=false). We would like to get messages that were sent while
our client was disconnected.
Steps to reproduce:
1. start route to create the initial subscription for the testclient
from("mqtt:bar?subscribeTopicName=testtopic&cleanSe
