You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@servicemix.apache.org by KenBarnesJr <ke...@tkctech.com> on 2009/09/02 15:28:54 UTC
Servicemix Bean camel jms little help
Hello all why wont this work
Camel-su
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:bean="http://servicemix.apache.org/bean/1.0"
xmlns:test="http://barnes/test">
<bean:endpoint service="test:beanService" endpoint="beanPoint"
bean="#myBean"/>
<bean id="myBean" class="barnes.test.MyBean"/>
</beans>
public void configure() {
from("timer://tutorial?fixedRate=true&delay=3000&period=10000")
.setBody(constant("<message>Hello world!</message>"))
.to("jbi:endpoint:http://barnes/test/jms/provider");
}
jms-su
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:jms="http://servicemix.apache.org/jms/1.0"
xmlns:test="http://barnes/test"
xmlns:amq="http://activemq.org/config/1.0">
<jms:provider service="test:jms"
endpoint="provider"
destinationName="test.queue"
connectionFactory="#connectionFactory"/>
<jms:consumer service="test:jms"
endpoint="consumer"
destinationName="test.queue"
connectionFactory="#connectionFactory"
marshaler="#marshaler"
targetService="test:beanService"
targetEndpoint="beanPoint" />
<bean id="marshaler"
class="org.apache.servicemix.jms.endpoints.DefaultConsumerMarshaler">
<property name="mep" value="http://www.w3.org/2004/08/wsdl/in-out" />
</bean>
<amq:connectionFactory id="connectionFactory"
brokerURL="tcp://localhost:61616" />
</beans>
bean-su
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:jms="http://servicemix.apache.org/jms/1.0"
xmlns:test="http://barnes/test"
xmlns:amq="http://activemq.org/config/1.0">
<jms:provider service="test:jms"
endpoint="provider"
destinationName="test.queue"
connectionFactory="#connectionFactory"/>
<jms:consumer service="test:jms"
endpoint="consumer"
destinationName="test.queue"
connectionFactory="#connectionFactory"
marshaler="#marshaler"
targetService="test:beanService"
targetEndpoint="beanPoint" />
<bean id="marshaler"
class="org.apache.servicemix.jms.endpoints.DefaultConsumerMarshaler">
<property name="mep" value="http://www.w3.org/2004/08/wsdl/in-out" />
</bean>
<amq:connectionFactory id="connectionFactory"
brokerURL="tcp://localhost:61616" />
</beans>
@Resource
private DeliveryChannel channel;
public void onMessageExchange(MessageExchange exchange) throws
MessagingException {
System.out.println("WLRI");
exchange.setStatus(ExchangeStatus.ACTIVE);
channel.send(exchange);
}
All i want is to have a bean intercept the message and output something. So
the xml string goes to the jms queue and a listener outputs a message thats
it.
Thanks in advance
--
View this message in context: http://www.nabble.com/Servicemix-Bean-camel-jms-little-help-tp25257646p25257646.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
RE: Servicemix Bean camel jms little help
Posted by Madesclair Vivian <vm...@sopragroup.com>.
Hello,
What is the endpoint that is not found? This exception is at runtime right? So I'm assuming all is deploying correctly.
The bean su that you gave in your last e-mail was the jms-su. The jms su seemed all right to me.
Your flow is Timer -> jms-provider -> jms consumer -> bean right? Obviously you don't need JMS but I guess you want to build up something.
And btw, why do you use a JMS marshaler?
Regards
Vivian
-----Message d'origine-----
De : KenBarnesJr [mailto:ken.barnes@tkctech.com]
Envoyé : mercredi 2 septembre 2009 19:08
À : users@servicemix.apache.org
Objet : RE: Servicemix Bean camel jms little help
I keep getting could not find route for exchange inOnly
It has something to do with this
from("timer://tutorial?fixedRate=true&delay=3000&period=10000")
.setBody(constant("<message>Hello world!</message>"))
.to("jbi:endpoint:http://barnes/test/jms/provider");
where this is the jms
xmlns:test="http://barnes/test"
xmlns:amq="http://activemq.org/config/1.0">
<jms:provider service="test:jms"
endpoint="provider"
destinationName="test.queue"
connectionFactory="#connectionFactory"/>
<jms:consumer service="test:jms"
endpoint="consumer"
destinationName="test.queue"
connectionFactory="#connectionFactory"
marshaler="#marshaler"
targetService="test:beanService"
targetEndpoint="beanPoint" />
<bean id="marshaler"
class="org.apache.servicemix.jms.endpoints.DefaultConsumerMarshaler">
<property name="mep" value="http://www.w3.org/2004/08/wsdl/in-out" />
</bean>
--
View this message in context: http://www.nabble.com/Servicemix-Bean-camel-jms-little-help-tp25257646p25261628.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
RE: Servicemix Bean camel jms little help
Posted by KenBarnesJr <ke...@tkctech.com>.
I keep getting could not find route for exchange inOnly
It has something to do with this
from("timer://tutorial?fixedRate=true&delay=3000&period=10000")
.setBody(constant("<message>Hello world!</message>"))
.to("jbi:endpoint:http://barnes/test/jms/provider");
where this is the jms
xmlns:test="http://barnes/test"
xmlns:amq="http://activemq.org/config/1.0">
<jms:provider service="test:jms"
endpoint="provider"
destinationName="test.queue"
connectionFactory="#connectionFactory"/>
<jms:consumer service="test:jms"
endpoint="consumer"
destinationName="test.queue"
connectionFactory="#connectionFactory"
marshaler="#marshaler"
targetService="test:beanService"
targetEndpoint="beanPoint" />
<bean id="marshaler"
class="org.apache.servicemix.jms.endpoints.DefaultConsumerMarshaler">
<property name="mep" value="http://www.w3.org/2004/08/wsdl/in-out" />
</bean>
--
View this message in context: http://www.nabble.com/Servicemix-Bean-camel-jms-little-help-tp25257646p25261628.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
RE: Servicemix Bean camel jms little help
Posted by Madesclair Vivian <vm...@sopragroup.com>.
Hello,
What exactly is not working? Do you have any exceptions?
IMO, your camel su seems very strange. Check http://servicemix.apache.org/32-using-the-camel-java-dsl-for-the-first-time.html and all the pages around.
Regards
Vivian
-----Message d'origine-----
De : KenBarnesJr [mailto:ken.barnes@tkctech.com]
Envoyé : mercredi 2 septembre 2009 15:29
À : users@servicemix.apache.org
Objet : Servicemix Bean camel jms little help
Hello all why wont this work
Camel-su
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:bean="http://servicemix.apache.org/bean/1.0"
xmlns:test="http://barnes/test">
<bean:endpoint service="test:beanService" endpoint="beanPoint"
bean="#myBean"/>
<bean id="myBean" class="barnes.test.MyBean"/>
</beans>
public void configure() {
from("timer://tutorial?fixedRate=true&delay=3000&period=10000")
.setBody(constant("<message>Hello world!</message>"))
.to("jbi:endpoint:http://barnes/test/jms/provider");
}
jms-su
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:jms="http://servicemix.apache.org/jms/1.0"
xmlns:test="http://barnes/test"
xmlns:amq="http://activemq.org/config/1.0">
<jms:provider service="test:jms"
endpoint="provider"
destinationName="test.queue"
connectionFactory="#connectionFactory"/>
<jms:consumer service="test:jms"
endpoint="consumer"
destinationName="test.queue"
connectionFactory="#connectionFactory"
marshaler="#marshaler"
targetService="test:beanService"
targetEndpoint="beanPoint" />
<bean id="marshaler"
class="org.apache.servicemix.jms.endpoints.DefaultConsumerMarshaler">
<property name="mep" value="http://www.w3.org/2004/08/wsdl/in-out" />
</bean>
<amq:connectionFactory id="connectionFactory"
brokerURL="tcp://localhost:61616" />
</beans>
bean-su
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:jms="http://servicemix.apache.org/jms/1.0"
xmlns:test="http://barnes/test"
xmlns:amq="http://activemq.org/config/1.0">
<jms:provider service="test:jms"
endpoint="provider"
destinationName="test.queue"
connectionFactory="#connectionFactory"/>
<jms:consumer service="test:jms"
endpoint="consumer"
destinationName="test.queue"
connectionFactory="#connectionFactory"
marshaler="#marshaler"
targetService="test:beanService"
targetEndpoint="beanPoint" />
<bean id="marshaler"
class="org.apache.servicemix.jms.endpoints.DefaultConsumerMarshaler">
<property name="mep" value="http://www.w3.org/2004/08/wsdl/in-out" />
</bean>
<amq:connectionFactory id="connectionFactory"
brokerURL="tcp://localhost:61616" />
</beans>
@Resource
private DeliveryChannel channel;
public void onMessageExchange(MessageExchange exchange) throws MessagingException {
System.out.println("WLRI");
exchange.setStatus(ExchangeStatus.ACTIVE);
channel.send(exchange);
}
All i want is to have a bean intercept the message and output something. So the xml string goes to the jms queue and a listener outputs a message thats it.
Thanks in advance
--
View this message in context: http://www.nabble.com/Servicemix-Bean-camel-jms-little-help-tp25257646p25257646.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
RE: Servicemix Bean camel jms little help
Posted by Madesclair Vivian <vm...@sopragroup.com>.
I never used the bean component so I won't be of much help there, but it seems to me that you have an InOut exchange somewhere while your whole flow is InOnly.
The marshaler is useless here as you are using the default one so you can omit it. But this is not causing the error in my opinion. If you can switch to InOnly everywhere maybe it will work. Or otherwise, you can try to simplify at the extreme and build up from it to find the error. >From what I know you want to do, Camel -> Bean should be enough, your JMS endpoint are useless.
-----Message d'origine-----
De : KenBarnesJr [mailto:ken.barnes@tkctech.com]
Envoyé : jeudi 3 septembre 2009 16:26
À : users@servicemix.apache.org
Objet : RE: Servicemix Bean camel jms little help
10:23:11,078 | ERROR | pool-flow.seda.servicemix-bean-thread-3 |
BeanComponent | emix.common.AsyncBaseLifeCycle 537 | Error
processing exchange InOut[
id: ID:10.30.16.204-12380479f45-11:1
status: Done
role: provider
service: {http://barnes/test}beanService
endpoint: beanPoint
in: <?xml version="1.0" encoding="UTF-8"?><message>Hello world!</message> ]
javax.jbi.messaging.MessagingException: illegal exchange status: done
at
org.apache.servicemix.jbi.messaging.MessageExchangeImpl.handleSend(MessageExchangeImpl.java:626)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:386)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:432)
at
org.apache.servicemix.common.EndpointDeliveryChannel.send(EndpointDeliveryChannel.java:88)
at
org.apache.servicemix.bean.BeanEndpoint$PojoChannel.send(BeanEndpoint.java:628)
at barnes.test.MyBean.onMessageExchange(MyBean.java:35)
at
org.apache.servicemix.bean.BeanEndpoint.onProviderExchange(BeanEndpoint.java:230)
at org.apache.servicemix.bean.BeanEndpoint.process(BeanEndpoint.java:217)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:627)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:581)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.onMessageExchange(AsyncBaseLifeCycle.java:535)
at
org.apache.servicemix.common.SyncLifeCycleWrapper.onMessageExchange(SyncLifeCycleWrapper.java:60)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:623)
at
org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:168)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
10:23:11,140 | WARN | DefaultMessageListenerContainer-2 | MessageListenerContainer | stractMessageListenerContainer 646 | Execution of JMS message listener failed
javax.jms.JMSException: Error sending JBI exchange
at
org.apache.servicemix.jms.endpoints.AbstractConsumerEndpoint.onMessage(AbstractConsumerEndpoint.java:575)
at
org.apache.servicemix.jms.endpoints.JmsConsumerEndpoint$1.onMessage(JmsConsumerEndpoint.java:505)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:518)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:479)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:451)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:323)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:261)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:982)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:974)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:876)
at java.lang.Thread.run(Thread.java:619)
Caused by: javax.jbi.messaging.MessagingException: illegal exchange status:
done
at
org.apache.servicemix.jbi.messaging.MessageExchangeImpl.handleSend(MessageExchangeImpl.java:626)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:386)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:432)
at
org.apache.servicemix.common.EndpointDeliveryChannel.send(EndpointDeliveryChannel.java:88)
at
org.apache.servicemix.bean.BeanEndpoint$PojoChannel.send(BeanEndpoint.java:628)
at barnes.test.MyBean.onMessageExchange(MyBean.java:35)
at
org.apache.servicemix.bean.BeanEndpoint.onProviderExchange(BeanEndpoint.java:230)
at org.apache.servicemix.bean.BeanEndpoint.process(BeanEndpoint.java:217)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:627)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:581)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.onMessageExchange(AsyncBaseLifeCycle.java:535)
at
org.apache.servicemix.common.SyncLifeCycleWrapper.onMessageExchange(SyncLifeCycleWrapper.java:60)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:623)
at
org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:168)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
... 1 more
The bean JAVA looks like
@Resource
private DeliveryChannel channel;
public void onMessageExchange(MessageExchange exchange) throws MessagingException {
System.out.println("WLRI");
exchange.setStatus(ExchangeStatus.DONE);
channel.send(exchange);
}
THE CAMEL JAVA
from("timer://tutorial?fixedRate=true&delay=3000&period=10000")
.setBody(constant("<message>Hello world!</message>"))
.to("jbi:endpoint:http://barnes/test/jms/provider");
THE JMS XBEAN
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:jms="http://servicemix.apache.org/jms/1.0"
xmlns:test="http://barnes/test"
xmlns:amq="http://activemq.org/config/1.0">
<jms:provider service="test:jms"
endpoint="provider"
destinationName="test.queue"
connectionFactory="#connectionFactory"/>
<jms:consumer service="test:jms"
endpoint="consumer"
destinationName="test.queue"
connectionFactory="#connectionFactory"
marshaler="#marshaler"
targetService="test:beanService"
targetEndpoint="beanPoint" />
<bean id="marshaler"
class="org.apache.servicemix.jms.endpoints.DefaultConsumerMarshaler">
<property name="mep" value="http://www.w3.org/2004/08/wsdl/in-out" />
</bean>
<amq:connectionFactory id="connectionFactory"
brokerURL="tcp://localhost:61616" />
</beans>
I dont know why i use a marshaler.... what exactly is it doing?? Just saw it in tutorial somewhere
--
View this message in context: http://www.nabble.com/Servicemix-Bean-camel-jms-little-help-tp25257646p25277247.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
RE: Servicemix Bean camel jms little help
Posted by KenBarnesJr <ke...@tkctech.com>.
10:23:11,078 | ERROR | pool-flow.seda.servicemix-bean-thread-3 |
BeanComponent | emix.common.AsyncBaseLifeCycle 537 | Error
processing exchange InOut[
id: ID:10.30.16.204-12380479f45-11:1
status: Done
role: provider
service: {http://barnes/test}beanService
endpoint: beanPoint
in: <?xml version="1.0" encoding="UTF-8"?><message>Hello world!</message>
]
javax.jbi.messaging.MessagingException: illegal exchange status: done
at
org.apache.servicemix.jbi.messaging.MessageExchangeImpl.handleSend(MessageExchangeImpl.java:626)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:386)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:432)
at
org.apache.servicemix.common.EndpointDeliveryChannel.send(EndpointDeliveryChannel.java:88)
at
org.apache.servicemix.bean.BeanEndpoint$PojoChannel.send(BeanEndpoint.java:628)
at barnes.test.MyBean.onMessageExchange(MyBean.java:35)
at
org.apache.servicemix.bean.BeanEndpoint.onProviderExchange(BeanEndpoint.java:230)
at org.apache.servicemix.bean.BeanEndpoint.process(BeanEndpoint.java:217)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:627)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:581)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.onMessageExchange(AsyncBaseLifeCycle.java:535)
at
org.apache.servicemix.common.SyncLifeCycleWrapper.onMessageExchange(SyncLifeCycleWrapper.java:60)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:623)
at
org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:168)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:619)
10:23:11,140 | WARN | DefaultMessageListenerContainer-2 |
MessageListenerContainer | stractMessageListenerContainer 646 | Execution
of JMS message listener failed
javax.jms.JMSException: Error sending JBI exchange
at
org.apache.servicemix.jms.endpoints.AbstractConsumerEndpoint.onMessage(AbstractConsumerEndpoint.java:575)
at
org.apache.servicemix.jms.endpoints.JmsConsumerEndpoint$1.onMessage(JmsConsumerEndpoint.java:505)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:518)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:479)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:451)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:323)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:261)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:982)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:974)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:876)
at java.lang.Thread.run(Thread.java:619)
Caused by: javax.jbi.messaging.MessagingException: illegal exchange status:
done
at
org.apache.servicemix.jbi.messaging.MessageExchangeImpl.handleSend(MessageExchangeImpl.java:626)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:386)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:432)
at
org.apache.servicemix.common.EndpointDeliveryChannel.send(EndpointDeliveryChannel.java:88)
at
org.apache.servicemix.bean.BeanEndpoint$PojoChannel.send(BeanEndpoint.java:628)
at barnes.test.MyBean.onMessageExchange(MyBean.java:35)
at
org.apache.servicemix.bean.BeanEndpoint.onProviderExchange(BeanEndpoint.java:230)
at org.apache.servicemix.bean.BeanEndpoint.process(BeanEndpoint.java:217)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:627)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:581)
at
org.apache.servicemix.common.AsyncBaseLifeCycle.onMessageExchange(AsyncBaseLifeCycle.java:535)
at
org.apache.servicemix.common.SyncLifeCycleWrapper.onMessageExchange(SyncLifeCycleWrapper.java:60)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:623)
at
org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:168)
at
org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
... 1 more
The bean JAVA looks like
@Resource
private DeliveryChannel channel;
public void onMessageExchange(MessageExchange exchange) throws
MessagingException {
System.out.println("WLRI");
exchange.setStatus(ExchangeStatus.DONE);
channel.send(exchange);
}
THE CAMEL JAVA
from("timer://tutorial?fixedRate=true&delay=3000&period=10000")
.setBody(constant("<message>Hello world!</message>"))
.to("jbi:endpoint:http://barnes/test/jms/provider");
THE JMS XBEAN
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:jms="http://servicemix.apache.org/jms/1.0"
xmlns:test="http://barnes/test"
xmlns:amq="http://activemq.org/config/1.0">
<jms:provider service="test:jms"
endpoint="provider"
destinationName="test.queue"
connectionFactory="#connectionFactory"/>
<jms:consumer service="test:jms"
endpoint="consumer"
destinationName="test.queue"
connectionFactory="#connectionFactory"
marshaler="#marshaler"
targetService="test:beanService"
targetEndpoint="beanPoint" />
<bean id="marshaler"
class="org.apache.servicemix.jms.endpoints.DefaultConsumerMarshaler">
<property name="mep" value="http://www.w3.org/2004/08/wsdl/in-out" />
</bean>
<amq:connectionFactory id="connectionFactory"
brokerURL="tcp://localhost:61616" />
</beans>
I dont know why i use a marshaler.... what exactly is it doing?? Just saw it
in tutorial somewhere
--
View this message in context: http://www.nabble.com/Servicemix-Bean-camel-jms-little-help-tp25257646p25277247.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.