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 i

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: If a message doesn't satisfy some condition

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 i

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: <--IdOsgiTestProcessor just used to created message body--> <--processorService is

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. 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 step2. But if I check in the step2, the redelivery polic

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: <--IdOsgiTestProcessor just used to created message body--> <--processorService is

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 * * ** Issue: the route jaxbRoute ge

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.

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 /http://camel.apache.org/schema/spring"/> http://camel.apache.org/schema/spring";> rdList = (ArrayList)camel.context().getRegistry

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: http://camel.465427.n5.nabble.com/How-to-use-a-public-endpoint-outside-of-cameconte

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 concurrentConsumers=100*"/> concurrentConsumers=100, does it means it the route publishData will us

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, My code like that(not the real code) *in xml: * http://camel.apache.org/schema/spring"/> http://camel.apache.org/schema/spring";> *in java: * //load spring xml final AbstractXmlApplicationContext springAppContext= new

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: http://camel.465427.n5.nabble.com/How-to-use-a-public-endpoint-outside-of-camecontext-tp5752336p5753761.ht

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: http://camel.465427.n5.nabble.com/quesion-about-

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 co

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.