Re: Question about the message group

only one consumer will affect performance. Do you have any other good solution? -- View this message in context: http://camel.465427.n5.nabble.com/Question-about-the-message-group-tp5757580p5757622.html Sent from the Camel - Users mailing list archive at Nabble.com.

Question about the message group

Hi All, It seems that message group only support the jms and activemq. But in my application I used SEDA. I tried to use the message group. But it doesn't work. in.setHeader(JMSXGroupID, groupid); Anyone can tell me how to use the message group for SEDA? Thanks -- View this message in

Re: How to use a public endpoint outside of camecontext?

Yes, the camel context is not defined inside of spring configuration file because akka has it's own camel context. So do you have any suggestion to fix it? -- View this message in context:

quesion about onException

Hi All, In spring xml, we can configure onException for camelcontext level. But in Java, I just see configure onException for route level. Is there anyway to configure onException for camel context level in java? -- View this message in context:

Re: How to use a public endpoint outside of camecontext?

Hi Willem, My code like that(not the real code) *in xml: * endpoint id=testSeda uri=seda:trades?size=100amp;concurrentConsumers=20amp;waitForTaskToComplete=Never xmlns=http://camel.apache.org/schema/spring/ routeContext id=defaultRoutes xmlns=http://camel.apache.org/schema/spring;

question about seda component

Hi All, I have one question about the seda component. there is a parameter concurrentConsumers. I am confused about it. Sample code as below route id=publishData autoStartup=true startupOrder=100 from uri=quot;seda:trades?size=100amp;amp;lt;bconcurrentConsumers=100*/

Re: question about seda component

If I use akka-camel to do it , sample code as below.* If I set concurrentConsumers=100 then Will it stilluse 100 threads to pull messages off the queue and execute your route in parallel??* public class AkkaConsumerActor extends UntypedConsumerActor { private static final Logger logger

Re: How to use a public endpoint outside of camecontext?

Hi Willem, I changed accordingly, it still doesn't work. In this case it has a special camel context which is created by akka, not managed by spring. Do you have any other idea? -- View this message in context:

How to use a public endpoint outside of camecontext?

Hi all, I have defined a public endpoint dataSeda and an routeContextwhich refer to the dataSeda in spring xml file /endpoint id=dataSeda uri=seda:data?size=100amp;concurrentConsumers=20amp;waitForTaskToComplete=Never xmlns=http://camel.apache.org/schema/spring/ routeContext

jaxb non-thread safe issue

Hi, Below case is not thread safe because marshal is not thread safe. Is there anybody know how to fix it? Case as below * endpoint id=toMarshal uri=seda:toMarshal?multipleConsumers=falseamp;concurrentConsumers=5 /* dataFormats jaxb id=MarketData

Re: jaxb non-thread safe issue

Hi, Thanks for your quick reponse. I used camel 2.10.4. Sorry, I didn't introduce my issue in detail. Actually, in the route marketDataRoute, it get message from jms queue, and the jms message will be encapsulated to java object in the jmsProcessor them the object will be sent to seda queue.

Re: how to do redelivery message

Hi, If I can checked the null value returned in the below step, I can call it step1, it should works. bean ref=processorService method=processTest(${body})/ But processorService is an OSGi service. I can't check null value in this step. So I only can check null in the below step， I can call it

how to redelivery message in the below case

Hi, somebody could tell me how to redelivery message in the below case. I have a client bundle deployed in karaf(used camel 2.10.4 and karaf 2.3.3). there is a camel route in the client bundle. Code as below: from uri=timer://myTimer?fixedRate=trueamp;period=100 / --IdOsgiTestProcessor just

how to do redelivery message

Hi, somebody Could tell me how to redelivery message in the below case. I have a client bundle deployed in karaf(used camel 2.10.4 and karaf 2.3.3). there is a camel route in the client bundle. Code as below: from uri=timer://myTimer?fixedRate=trueamp;period=100 / --IdOsgiTestProcessor just

What's the proper way to abandon a message in processor.

Hi, Some message are not useless. So I want to abandon it in the processor. *Does anybody know what's the proper way to abandon a message except using filter?* ex: route id=realtimeRoute startupOrder=10 from uri=vantagemsgTimer/ to

Please help about the RejectedExecutionException issue

Hi, I deployed 2 bundles in KARAF2.3.3 cluster. One is client bundle and the other is a service bundle. Thy are deployed in different cluster nodes. Client bundle has a camel route. it just receives message from JMS server and pass the message to service bundle by invoking remote OSGI service

RejectedExecutionException issue in camel 2.10.4

Hi, I deployed 2 bundles in KARAF2.3.3 cluster. One is client bundle and the other is a service bundle. Thy are deployed in different cluster nodes. Client bundle has a camel route. it just receives message from JMS server and pass the message to service bundle by invoking remote OSGI service