I have the below route in Camel
from JMS --> Websocket
The websocket is exposed in a node js appliation running separately. and
this is my route specification
/from("test-jms:queue:test.queue").convertBodyTo(String.class,
"UTF-8").to("websocket://localhost");/
When I run the code, i get the following exception
java.lang.IllegalArgumentException: Failed to send message to single
connection;
connetion key not set.
at
org.apache.camel.component.websocket.WebsocketProducer.process(Websoc
ketProducer.java:57)
at
org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncP
rocessorBridge.process(AsyncProcessorConverterHelper.java:61)
at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:1
29)
at
org.apache.camel.management.InstrumentationProcessor.process(Instrume
ntationProcessor.java:77)
at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryE
rrorHandler.java:448)
at
org.apache.camel.processor.CamelInternalProcessor.process(CamelIntern
alProcessor.java:191)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:118)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)
at
org.apache.camel.processor.CamelInternalProcessor.process(CamelIntern
alProcessor.java:191)
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp
er.java:109)
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy
ncProcessor.java:87)
at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(Endp
ointMessageListener.java:103)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doI
nvokeListener(AbstractMessageListenerContainer.java:699)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.inv
okeListener(AbstractMessageListenerContainer.java:637)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doE
xecuteListener(AbstractMessageListenerContainer.java:605)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContai
ner.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:308)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContai
ner.receiveAndExecute(AbstractPollingMessageListenerContainer.java:246)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$Asyn
cMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1144
)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$Asyn
cMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:
1136)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$Asyn
cMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1033)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.
java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:615)
at java.lang.Thread.run(Thread.java:724)
[d #0 - JmsConsumer[test.queue]] EndpointMessageListener WARN
Execution
of JMS message listener failed. Caused by:
[org.apache.camel.RuntimeCamelExcepti
on - java.lang.IllegalArgumentException: Failed to send message to single
connec
tion; connetion key not set.]
org.apache.camel.RuntimeCamelException: java.lang.IllegalArgumentException:
Fail
ed to send message to single connection; connetion key not set.
at
org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHe
lper.java:1619)
at
org.apache.camel.component.jms.EndpointMessageListener$EndpointMessag
eListenerAsyncCallback.done(EndpointMessageListener.java:186)
at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(Endp
ointMessageListener.java:107)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doI
nvokeListener(AbstractMessageListenerContainer.java:699)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.inv
okeListener(AbstractMessageListenerContainer.java:637)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doE
xecuteListener(AbstractMessageListenerContainer.java:605)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContai
ner.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:308)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContai
ner.receiveAndExecute(AbstractPollingMessageListenerContainer.java:246)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$Asyn
cMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1144
)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$Asyn
cMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:
1136)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$Asyn
cMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1033)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.
java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor
.java:615)
at java.lang.Thread.run(Thread.java:724)
Caused by: java.lang.IllegalArgumentException: Failed to send message to
single
connection; connetion key not set.
at
org.apache.camel.component.websocket.WebsocketProducer.process(Websoc
ketProducer.java:57)
at
org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncP
rocessorBridge.process(AsyncProcessorConverterHelper.java:61)
at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:1
29)
at
org.apache.camel.management.InstrumentationProcessor.process(Instrume
ntationProcessor.java:77)
at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryE
rrorHandler.java:448)
at
org.apache.camel.processor.CamelInternalProcessor.process(CamelIntern
alProcessor.java:191)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:118)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)
at
org.apache.camel.processor.CamelInternalProcessor.process(CamelIntern
alProcessor.java:191)
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelp
er.java:109)
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsy
ncProcessor.java:87)
at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(Endp
ointMessageListener.java:103)
Some light ??
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Websocket-Connection-key-not-set-tp5766728.html
Sent from the Camel - Users mailing list archive at Nabble.com.
