You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Tomohisa Igarashi <tm...@gmail.com> on 2014/07/17 07:05:41 UTC
Dispatch queue 'mqtt client' was not executing error from camel-mqtt producer
Hi,
I'm trying to use camel-mqtt producer on camel 2.12.2 but it fails
with the error:
------------------------------
Caused by: java.lang.AssertionError: Dispatch queue 'mqtt client' was
not executing, (currently executing: 'mqtt client')
at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.assertExecuting(SerialDispatchQueue.java:145)
at org.fusesource.mqtt.client.CallbackConnection.publish(CallbackConnection.java:585)
at org.fusesource.mqtt.client.CallbackConnection.publish(CallbackConnection.java:581)
at org.apache.camel.component.mqtt.MQTTEndpoint.publish(MQTTEndpoint.java:160)
at org.apache.camel.component.mqtt.MQTTProducer.process(MQTTProducer.java:58)
...(snip)...
------------------------------
I found MQTTProducerTest in the camel-mqtt tests is excluded in its
pom.xml, so tried to run it but it fails with same error. Is
MQTTProducer not supported on camel 2.12.2?
Thanks,
Tomo
--
IGARASHI Tomohisa mailto:tm.igarashi@gmail.com
Re: Dispatch queue 'mqtt client' was not executing error from
camel-mqtt producer
Posted by Tomohisa Igarashi <tm...@gmail.com>.
Hi,
I filed a JIRA for this issue:
https://issues.apache.org/jira/browse/CAMEL-7662
Thanks,
Tomo
--
IGARASHI Tomohisa mailto:tm.igarashi@gmail.com
On Thu, Jul 17, 2014 at 4:03 PM, Tomohisa Igarashi
<tm...@gmail.com> wrote:
> Hi Charles,
>
> I don't think it's a warning, please see this surefire report:
> http://pastebin.com/zYGxWmNx
>
> You can see the test fails with this error. The message is not sent actually.
>
> Thanks,
> Tomo
>
> --
> IGARASHI Tomohisa mailto:tm.igarashi@gmail.com
>
>
> On Thu, Jul 17, 2014 at 3:47 PM, Charles Moulliard <ch...@gmail.com> wrote:
>> There is an issue with the unit test, reason why the test is commented.
>>
>> The message that you see is a warning reported when the camel route service
>> shutting down and I don't think that it is related to the fact that test
>> fails
>>
>> -->
>>
>> 2014-07-17 07:38:09,267 [main ] WARN DefaultCamelContext
>> - Error occurred while shutting down service:
>> org.apache.camel.impl.RouteService@1a6032ce. This exception will be ignored.
>> java.lang.AssertionError: Dispatch queue 'mqtt client' was not executing,
>> (currently executing: '<not-dispatched>')
>> at
>> org.fusesource.hawtdispatch.internal.SerialDispatchQueue.assertExecuting(SerialDispatchQueue.java:145)
>> at
>> org.fusesource.hawtdispatch.transport.TcpTransport.offer(TcpTransport.java:644)
>> at
>> org.fusesource.mqtt.client.CallbackConnection.send(CallbackConnection.java:653)
>> at
>> org.fusesource.mqtt.client.CallbackConnection.disconnect(CallbackConnection.java:548)
>> at
>> org.apache.camel.component.mqtt.MQTTEndpoint.doStop(MQTTEndpoint.java:145)
>> at
>> org.apache.camel.support.ServiceSupport.stop(ServiceSupport.java:102)
>> at
>> org.apache.camel.util.ServiceHelper.stopService(ServiceHelper.java:141)
>> at
>> org.apache.camel.util.ServiceHelper.stopAndShutdownServices(ServiceHelper.java:234)
>> at
>> org.apache.camel.util.ServiceHelper.stopAndShutdownServices(ServiceHelper.java:192)
>> at
>> org.apache.camel.impl.RouteService.doShutdown(RouteService.java:272)
>> at
>> org.apache.camel.support.ChildServiceSupport.shutdown(ChildServiceSupport.java:109)
>> ...
>>
>>
>> On Thu, Jul 17, 2014 at 8:15 AM, Tomohisa Igarashi <tm...@gmail.com>
>> wrote:
>>
>>> I see this error with just commented out the following line and run mvn
>>> clean package:
>>> https://github.com/apache/camel/blob/camel-2.12.2/
>>> components/camel-mqtt/pom.xml#L84
>>>
>>>
>>> (07/17/2014 03:00 PM), Charles Moulliard wrote:
>>>
>>>> You can use camel mqtt component to produce (
>>>> https://github.com/apache/camel/blob/camel-2.12.2/
>>>> components/camel-mqtt/src/main/java/org/apache/camel/
>>>> component/mqtt/MQTTProducer.java
>>>> )
>>>> Can you provide us more info about your use case, config, ... ?
>>>>
>>>>
>>>> On Thu, Jul 17, 2014 at 7:05 AM, Tomohisa Igarashi <tm.igarashi@gmail.com
>>>> >
>>>> wrote:
>>>>
>>>> Hi,
>>>>>
>>>>> I'm trying to use camel-mqtt producer on camel 2.12.2 but it fails
>>>>> with the error:
>>>>> ------------------------------
>>>>> Caused by: java.lang.AssertionError: Dispatch queue 'mqtt client' was
>>>>> not executing, (currently executing: 'mqtt client')
>>>>> at
>>>>> org.fusesource.hawtdispatch.internal.SerialDispatchQueue.
>>>>> assertExecuting(SerialDispatchQueue.java:145)
>>>>> at
>>>>> org.fusesource.mqtt.client.CallbackConnection.publish(
>>>>> CallbackConnection.java:585)
>>>>> at
>>>>> org.fusesource.mqtt.client.CallbackConnection.publish(
>>>>> CallbackConnection.java:581)
>>>>> at
>>>>> org.apache.camel.component.mqtt.MQTTEndpoint.publish(
>>>>> MQTTEndpoint.java:160)
>>>>> at
>>>>> org.apache.camel.component.mqtt.MQTTProducer.process(
>>>>> MQTTProducer.java:58)
>>>>> ...(snip)...
>>>>> ------------------------------
>>>>>
>>>>> I found MQTTProducerTest in the camel-mqtt tests is excluded in its
>>>>> pom.xml, so tried to run it but it fails with same error. Is
>>>>> MQTTProducer not supported on camel 2.12.2?
>>>>>
>>>>> Thanks,
>>>>> Tomo
>>>>>
>>>>> --
>>>>> IGARASHI Tomohisa mailto:tm.igarashi@gmail.com
>>>>>
>>>>>
>>>>
>>>>
>>>>
>>> --
>>> Tomohisa Igarashi
>>> mailto:tm.igarashi@gmail.com
>>>
>>
>>
>>
>> --
>> Charles Moulliard
>> Apache Committer / Architect @RedHat
>> Twitter : @cmoulliard | Blog : http://cmoulliard.github.io
Re: Dispatch queue 'mqtt client' was not executing error from
camel-mqtt producer
Posted by Tomohisa Igarashi <tm...@gmail.com>.
Hi Charles,
I don't think it's a warning, please see this surefire report:
http://pastebin.com/zYGxWmNx
You can see the test fails with this error. The message is not sent actually.
Thanks,
Tomo
--
IGARASHI Tomohisa mailto:tm.igarashi@gmail.com
On Thu, Jul 17, 2014 at 3:47 PM, Charles Moulliard <ch...@gmail.com> wrote:
> There is an issue with the unit test, reason why the test is commented.
>
> The message that you see is a warning reported when the camel route service
> shutting down and I don't think that it is related to the fact that test
> fails
>
> -->
>
> 2014-07-17 07:38:09,267 [main ] WARN DefaultCamelContext
> - Error occurred while shutting down service:
> org.apache.camel.impl.RouteService@1a6032ce. This exception will be ignored.
> java.lang.AssertionError: Dispatch queue 'mqtt client' was not executing,
> (currently executing: '<not-dispatched>')
> at
> org.fusesource.hawtdispatch.internal.SerialDispatchQueue.assertExecuting(SerialDispatchQueue.java:145)
> at
> org.fusesource.hawtdispatch.transport.TcpTransport.offer(TcpTransport.java:644)
> at
> org.fusesource.mqtt.client.CallbackConnection.send(CallbackConnection.java:653)
> at
> org.fusesource.mqtt.client.CallbackConnection.disconnect(CallbackConnection.java:548)
> at
> org.apache.camel.component.mqtt.MQTTEndpoint.doStop(MQTTEndpoint.java:145)
> at
> org.apache.camel.support.ServiceSupport.stop(ServiceSupport.java:102)
> at
> org.apache.camel.util.ServiceHelper.stopService(ServiceHelper.java:141)
> at
> org.apache.camel.util.ServiceHelper.stopAndShutdownServices(ServiceHelper.java:234)
> at
> org.apache.camel.util.ServiceHelper.stopAndShutdownServices(ServiceHelper.java:192)
> at
> org.apache.camel.impl.RouteService.doShutdown(RouteService.java:272)
> at
> org.apache.camel.support.ChildServiceSupport.shutdown(ChildServiceSupport.java:109)
> ...
>
>
> On Thu, Jul 17, 2014 at 8:15 AM, Tomohisa Igarashi <tm...@gmail.com>
> wrote:
>
>> I see this error with just commented out the following line and run mvn
>> clean package:
>> https://github.com/apache/camel/blob/camel-2.12.2/
>> components/camel-mqtt/pom.xml#L84
>>
>>
>> (07/17/2014 03:00 PM), Charles Moulliard wrote:
>>
>>> You can use camel mqtt component to produce (
>>> https://github.com/apache/camel/blob/camel-2.12.2/
>>> components/camel-mqtt/src/main/java/org/apache/camel/
>>> component/mqtt/MQTTProducer.java
>>> )
>>> Can you provide us more info about your use case, config, ... ?
>>>
>>>
>>> On Thu, Jul 17, 2014 at 7:05 AM, Tomohisa Igarashi <tm.igarashi@gmail.com
>>> >
>>> wrote:
>>>
>>> Hi,
>>>>
>>>> I'm trying to use camel-mqtt producer on camel 2.12.2 but it fails
>>>> with the error:
>>>> ------------------------------
>>>> Caused by: java.lang.AssertionError: Dispatch queue 'mqtt client' was
>>>> not executing, (currently executing: 'mqtt client')
>>>> at
>>>> org.fusesource.hawtdispatch.internal.SerialDispatchQueue.
>>>> assertExecuting(SerialDispatchQueue.java:145)
>>>> at
>>>> org.fusesource.mqtt.client.CallbackConnection.publish(
>>>> CallbackConnection.java:585)
>>>> at
>>>> org.fusesource.mqtt.client.CallbackConnection.publish(
>>>> CallbackConnection.java:581)
>>>> at
>>>> org.apache.camel.component.mqtt.MQTTEndpoint.publish(
>>>> MQTTEndpoint.java:160)
>>>> at
>>>> org.apache.camel.component.mqtt.MQTTProducer.process(
>>>> MQTTProducer.java:58)
>>>> ...(snip)...
>>>> ------------------------------
>>>>
>>>> I found MQTTProducerTest in the camel-mqtt tests is excluded in its
>>>> pom.xml, so tried to run it but it fails with same error. Is
>>>> MQTTProducer not supported on camel 2.12.2?
>>>>
>>>> Thanks,
>>>> Tomo
>>>>
>>>> --
>>>> IGARASHI Tomohisa mailto:tm.igarashi@gmail.com
>>>>
>>>>
>>>
>>>
>>>
>> --
>> Tomohisa Igarashi
>> mailto:tm.igarashi@gmail.com
>>
>
>
>
> --
> Charles Moulliard
> Apache Committer / Architect @RedHat
> Twitter : @cmoulliard | Blog : http://cmoulliard.github.io
Re: Dispatch queue 'mqtt client' was not executing error from
camel-mqtt producer
Posted by Charles Moulliard <ch...@gmail.com>.
There is an issue with the unit test, reason why the test is commented.
The message that you see is a warning reported when the camel route service
shutting down and I don't think that it is related to the fact that test
fails
-->
2014-07-17 07:38:09,267 [main ] WARN DefaultCamelContext
- Error occurred while shutting down service:
org.apache.camel.impl.RouteService@1a6032ce. This exception will be ignored.
java.lang.AssertionError: Dispatch queue 'mqtt client' was not executing,
(currently executing: '<not-dispatched>')
at
org.fusesource.hawtdispatch.internal.SerialDispatchQueue.assertExecuting(SerialDispatchQueue.java:145)
at
org.fusesource.hawtdispatch.transport.TcpTransport.offer(TcpTransport.java:644)
at
org.fusesource.mqtt.client.CallbackConnection.send(CallbackConnection.java:653)
at
org.fusesource.mqtt.client.CallbackConnection.disconnect(CallbackConnection.java:548)
at
org.apache.camel.component.mqtt.MQTTEndpoint.doStop(MQTTEndpoint.java:145)
at
org.apache.camel.support.ServiceSupport.stop(ServiceSupport.java:102)
at
org.apache.camel.util.ServiceHelper.stopService(ServiceHelper.java:141)
at
org.apache.camel.util.ServiceHelper.stopAndShutdownServices(ServiceHelper.java:234)
at
org.apache.camel.util.ServiceHelper.stopAndShutdownServices(ServiceHelper.java:192)
at
org.apache.camel.impl.RouteService.doShutdown(RouteService.java:272)
at
org.apache.camel.support.ChildServiceSupport.shutdown(ChildServiceSupport.java:109)
...
On Thu, Jul 17, 2014 at 8:15 AM, Tomohisa Igarashi <tm...@gmail.com>
wrote:
> I see this error with just commented out the following line and run mvn
> clean package:
> https://github.com/apache/camel/blob/camel-2.12.2/
> components/camel-mqtt/pom.xml#L84
>
>
> (07/17/2014 03:00 PM), Charles Moulliard wrote:
>
>> You can use camel mqtt component to produce (
>> https://github.com/apache/camel/blob/camel-2.12.2/
>> components/camel-mqtt/src/main/java/org/apache/camel/
>> component/mqtt/MQTTProducer.java
>> )
>> Can you provide us more info about your use case, config, ... ?
>>
>>
>> On Thu, Jul 17, 2014 at 7:05 AM, Tomohisa Igarashi <tm.igarashi@gmail.com
>> >
>> wrote:
>>
>> Hi,
>>>
>>> I'm trying to use camel-mqtt producer on camel 2.12.2 but it fails
>>> with the error:
>>> ------------------------------
>>> Caused by: java.lang.AssertionError: Dispatch queue 'mqtt client' was
>>> not executing, (currently executing: 'mqtt client')
>>> at
>>> org.fusesource.hawtdispatch.internal.SerialDispatchQueue.
>>> assertExecuting(SerialDispatchQueue.java:145)
>>> at
>>> org.fusesource.mqtt.client.CallbackConnection.publish(
>>> CallbackConnection.java:585)
>>> at
>>> org.fusesource.mqtt.client.CallbackConnection.publish(
>>> CallbackConnection.java:581)
>>> at
>>> org.apache.camel.component.mqtt.MQTTEndpoint.publish(
>>> MQTTEndpoint.java:160)
>>> at
>>> org.apache.camel.component.mqtt.MQTTProducer.process(
>>> MQTTProducer.java:58)
>>> ...(snip)...
>>> ------------------------------
>>>
>>> I found MQTTProducerTest in the camel-mqtt tests is excluded in its
>>> pom.xml, so tried to run it but it fails with same error. Is
>>> MQTTProducer not supported on camel 2.12.2?
>>>
>>> Thanks,
>>> Tomo
>>>
>>> --
>>> IGARASHI Tomohisa mailto:tm.igarashi@gmail.com
>>>
>>>
>>
>>
>>
> --
> Tomohisa Igarashi
> mailto:tm.igarashi@gmail.com
>
--
Charles Moulliard
Apache Committer / Architect @RedHat
Twitter : @cmoulliard | Blog : http://cmoulliard.github.io
Re: Dispatch queue 'mqtt client' was not executing error from camel-mqtt
producer
Posted by Tomohisa Igarashi <tm...@gmail.com>.
I see this error with just commented out the following line and run mvn
clean package:
https://github.com/apache/camel/blob/camel-2.12.2/components/camel-mqtt/pom.xml#L84
(07/17/2014 03:00 PM), Charles Moulliard wrote:
> You can use camel mqtt component to produce (
> https://github.com/apache/camel/blob/camel-2.12.2/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTProducer.java
> )
> Can you provide us more info about your use case, config, ... ?
>
>
> On Thu, Jul 17, 2014 at 7:05 AM, Tomohisa Igarashi <tm...@gmail.com>
> wrote:
>
>> Hi,
>>
>> I'm trying to use camel-mqtt producer on camel 2.12.2 but it fails
>> with the error:
>> ------------------------------
>> Caused by: java.lang.AssertionError: Dispatch queue 'mqtt client' was
>> not executing, (currently executing: 'mqtt client')
>> at
>> org.fusesource.hawtdispatch.internal.SerialDispatchQueue.assertExecuting(SerialDispatchQueue.java:145)
>> at
>> org.fusesource.mqtt.client.CallbackConnection.publish(CallbackConnection.java:585)
>> at
>> org.fusesource.mqtt.client.CallbackConnection.publish(CallbackConnection.java:581)
>> at
>> org.apache.camel.component.mqtt.MQTTEndpoint.publish(MQTTEndpoint.java:160)
>> at
>> org.apache.camel.component.mqtt.MQTTProducer.process(MQTTProducer.java:58)
>> ...(snip)...
>> ------------------------------
>>
>> I found MQTTProducerTest in the camel-mqtt tests is excluded in its
>> pom.xml, so tried to run it but it fails with same error. Is
>> MQTTProducer not supported on camel 2.12.2?
>>
>> Thanks,
>> Tomo
>>
>> --
>> IGARASHI Tomohisa mailto:tm.igarashi@gmail.com
>>
>
>
>
--
Tomohisa Igarashi
mailto:tm.igarashi@gmail.com
Re: Dispatch queue 'mqtt client' was not executing error from
camel-mqtt producer
Posted by Charles Moulliard <ch...@gmail.com>.
You can use camel mqtt component to produce (
https://github.com/apache/camel/blob/camel-2.12.2/components/camel-mqtt/src/main/java/org/apache/camel/component/mqtt/MQTTProducer.java
)
Can you provide us more info about your use case, config, ... ?
On Thu, Jul 17, 2014 at 7:05 AM, Tomohisa Igarashi <tm...@gmail.com>
wrote:
> Hi,
>
> I'm trying to use camel-mqtt producer on camel 2.12.2 but it fails
> with the error:
> ------------------------------
> Caused by: java.lang.AssertionError: Dispatch queue 'mqtt client' was
> not executing, (currently executing: 'mqtt client')
> at
> org.fusesource.hawtdispatch.internal.SerialDispatchQueue.assertExecuting(SerialDispatchQueue.java:145)
> at
> org.fusesource.mqtt.client.CallbackConnection.publish(CallbackConnection.java:585)
> at
> org.fusesource.mqtt.client.CallbackConnection.publish(CallbackConnection.java:581)
> at
> org.apache.camel.component.mqtt.MQTTEndpoint.publish(MQTTEndpoint.java:160)
> at
> org.apache.camel.component.mqtt.MQTTProducer.process(MQTTProducer.java:58)
> ...(snip)...
> ------------------------------
>
> I found MQTTProducerTest in the camel-mqtt tests is excluded in its
> pom.xml, so tried to run it but it fails with same error. Is
> MQTTProducer not supported on camel 2.12.2?
>
> Thanks,
> Tomo
>
> --
> IGARASHI Tomohisa mailto:tm.igarashi@gmail.com
>
--
Charles Moulliard
Apache Committer / Architect @RedHat
Twitter : @cmoulliard | Blog : http://cmoulliard.github.io