[
https://issues.apache.org/jira/browse/CAMEL-7697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14098320#comment-14098320
]
Willem Jiang commented on CAMEL-7697:
-------------------------------------
Hi Tomohisa,
When I enable the trace log of MQTTProducer:
{code}
log4j.logger.org.apache.camel.component.mqtt=TRACE
{code}
I found the wait time is between the MQTTProducer (Publishing to testTopicOut)
and (onSuccess from testTopicOut).
{code}
2014-08-15 15:53:00,535 [ hawtdispatch-DEFAULT-2] MQTTProducer
DEBUG Publishing to testTopicOut
2014-08-15 15:53:30,405 [ main] CamelMQTTExample
INFO >>>>> MQTT consumer: 29877[ms]
2014-08-15 15:53:30,406 [ hawtdispatch-DEFAULT-3] MQTTProducer
TRACE onSuccess from testTopicOut
{code}
When I change the camel route to use other thread to send the message, the
test looks good.
{code}
from("mqtt:input?subscribeTopicName=" + TOPIC_IN)
.removeProperty("MQTTTopicPropertyName")
.threads(2)
.to("mqtt:output?publishTopicName=" + TOPIC_OUT);
{code}
Here is the log message about MQTTProducer sending the message
{code}
2014-08-15 15:55:21,766 [ (camel-1) thread #0 - Threads] MQTTProducer
DEBUG Publishing to testTopicOut
2014-08-15 15:55:21,767 [ hawtdispatch-DEFAULT-3] MQTTProducer
TRACE onSuccess from testTopicOut
2014-08-15 15:55:21,768 [ main] CamelMQTTExample
INFO >>>>> MQTT consumer: 11[ms]
{code}
It looks the hawtdispatch queue have some kind of block issue there.
> from("mqtt:..").to("mqtt:...") causes a seriously delayed delivery
> ------------------------------------------------------------------
>
> Key: CAMEL-7697
> URL: https://issues.apache.org/jira/browse/CAMEL-7697
> Project: Camel
> Issue Type: Bug
> Components: camel-mqtt
> Affects Versions: 2.14.0
> Reporter: Tomohisa Igarashi
> Attachments: camel-example-mqtt.tar.gz
>
>
> If you have a following route
> {code}
> from("mqtt:input?subscribeTopicName=testTopicIn")
> .from("direct:foo")
> .removeProperty("MQTTTopicPropertyName")
> .to("mqtt:output?publishTopicName=testTopicOut");
> {code}
> The delivery through mqtt:input seriously delays. I'll attach a reproducer
> soon.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
