Re: concurrentConsumers basic question

you are getting duplicates because the topic has up to 10 concurrent consumers based on your jmsConfig... so should either change the jmsConfig (used by all routes) or explicitly set these on any routes in question... from("activemq:topic:xmlOrders?maxConcurrentConsumers=1&concurrentConsumers=1")

Re: XMPP pubsub

We already have a ticket to upgrade to Smack 3.2.0 after Camel 2.8.0 is out. https://issues.apache.org/jira/browse/CAMEL-4134 ... and we love contributions... ;-) Best, Christian On Tue, Jun 28, 2011 at 7:36 PM, rcollier wrote: > In case you are not aware, Smack 3.2 has been released and it in

Re: concurrentConsumers basic question

If you want multiple consumers on topics you might take a look at virtual topics. My guess is that these can have multiple consumers. Correct me if i'm wrong. /preben -- View this message in context: http://camel.465427.n5.nabble.com/concurrentConsumers-basic-question-tp4535789p4536257.html Sen

Re: concurrentConsumers basic question

You're totally right mr. Travis, just confirmed and also read it on the camel book concurrentConsumers Sets the number of consumer threads to use. It’s a good idea to increase this for high-volume queues, *but it’s not advisable to use more than one concurrent consumer for JMS topics, beca

Re: concurrentConsumers basic question

I'm not 100% on this, so someone correct me if I'm wrong. * concurrentConsumers should only be set on the "from" part of a route. using a queue in the "to" part of a route is not actually going to consume any messages. * You probably should not use concurrentConsumers at all with a topic. A topi

Re: concurrentConsumers basic question

thanks for the answer Mr. Pham, I've commented my "concurrent configs" on my spring file and I've done it the way you propose: from("activemq:topic:xmlOrders").to("activemq:accounting?concurrentConsumers=5"); Thanks for the advice. However, the activemq:accounting queue is still getting the m

Re: concurrentConsumers basic question

Hi rogelio, I think you should not have maxConcurrentConsumers on a connection pool. What you want may be maxConcurrentConsumers on the activemq consumer like: from("activemq:topic:xmlOrders").to("activemq:accounting?concurrentConsumers=5"); from("activemq:topic:xmlOrders").to("activemq:production

concurrentConsumers basic question

Hello everyone, sorry if this is too basic. I'm beginning to use Camel (along with Fuse ESB but that's another story) , and i'm doing some basic tests while reading "camel in action" (excellent book by the way). Anyway, i was trying an activemq concurrent example, and i configured it like this o

Re: Custom exclusiveReadLockStrategy in Servicemix + Camel

Hi Claus, You said this: "*Adjust the **configuration to use the new version of the camel features file*" What do you mean by that? Do you mean I should edit the /etc/org.apache.karaf.features.cfg file from ServiceMix? How can I tell it what version of Camel to use? And how to tell it to use a spe

Re: Unable to catch exception from Camel.

I believe I was using the recipientList() in a manner not fitting the requirement. I tried this and have the desired behaviour now: Basically, the OrderService class will set the header with the required route. And exceptions are handled by the onException()... from("ibmmq:B2B.B2B.Q.1")

Re: pre processing before camel route starts

On Wed, Jun 29, 2011 at 5:22 PM, balajiu wrote: > Thank you Claus. > > I can add some java code that looks for lock file and delete in the > configure method. > > But I want lock files to be deleted before the route started and needs to > happens only one time until either camel route stopped or r

Re: pre processing before camel route starts

Thank you Claus. I can add some java code that looks for lock file and delete in the configure method. But I want lock files to be deleted before the route started and needs to happens only one time until either camel route stopped or restarted. So with added java code would it serve above sce

Re: why i building camel2.7.2 use maven install error?

Its likely not only IBM JDKs. HP-UX has been know to have compiling issues as well. Well we can always blame sun for creating the crappy confusing generics. I guess the compiler engineers dont even get generics right as well. The work around I have seen was to add a type cast to the super type Pr

Re: why i building camel2.7.2 use maven install error?

Yep. There are still a bunch of build related issues with the IBM JDK. The last couple weeks, I managed to get all the UNIT TESTS passing on the IBM JDK which was important to validate that Camel works with the IBM JDK, but there are still a bunch of build related issues.The way camel use

Re: why i building camel2.7.2 use maven install error?

Hi Claus, I suspect xiangqiuzhao uses the IBM-JDK6 which has this issue, @xiangqiuzhao is this really the case? I used to experience exactly the same problem while using IBM-JDK, however since moving to SUN-JDK the problem is resolved for me. On my box if I set JAVA_HOME to IBM's JDK, then 'mvn c

Re: pre processing before camel route starts

On Wed, Jun 29, 2011 at 3:31 PM, balajiu wrote: > Hello, > > I have following camel route that picks up file from a directory and process > it. The route looks like as follows. > > from("direct:file://c:///localdir///poller&move=//c:///localdir///archive///${file:name.ext}-${date:now:MhMdd}" >

pre processing before camel route starts

Hello, I have following camel route that picks up file from a directory and process it. The route looks like as follows. from("direct:file://c:///localdir///poller&move=//c:///localdir///archive///${file:name.ext}-${date:now:MhMdd}" But I want to check for any lock files and delete them i

Re: intercept using adviceWith()

You should do the advice stuff in the test method, not in the createCamelContext On Mon, Jun 27, 2011 at 6:30 PM, woggle23 wrote: > I tried running it against 2.8-SNAPSHOT, the results were worse - the test > didn't even pass with a single intercept. > > The attached zip is the test I was trying

Re: Unable to catch exception from Camel.

Thanks, I was able to catch the Exception by wrapping the processor as you said. Works like a charm. Although I still think I am doing something wrong in general, as I cannot catch exceptions I deliberately throw from my MessageRouter class... (starting to get that feeling that I need to use spri

Re: Unable to catch exception from Camel.

Here is the stack trace if it helps: body is : Test Message: 1 1969 [Camel (camel-1) thread #0 - JmsConsumer[B2B.B2B.Q.1]] DEBUG org.apache.camel.processor.MulticastProcessor - Done sequential processing 0 exchanges 1969 [Camel (camel-1) thread #0 - JmsConsumer[B2B.B2B.Q.1]] DEBUG org.apache.cam

Re: Custom exclusiveReadLockStrategy in Servicemix + Camel

On Wed, Jun 29, 2011 at 2:30 PM, Laurentiu Trica wrote: > Hi Claus, > > I attached the sources and modified files + a descriptive comment. > Hope it helps. > > Can you please tell me how can I test my Camel changes in ServiceMix? > Specifically, how can I add a custom Camel version to my ServiceMi

Re: Custom exclusiveReadLockStrategy in Servicemix + Camel

Hi Claus, I attached the sources and modified files + a descriptive comment. Hope it helps. Can you please tell me how can I test my Camel changes in ServiceMix? Specifically, how can I add a custom Camel version to my ServiceMix? Is it possible? Could you provide maybe a useful link or somethin

Re: Exception running from camel-archtype-java -v2.7.2

On 29 June 2011 12:40, Claus Ibsen-2 [via Camel] < ml-node+4534883-248344801-149...@n5.nabble.com> wrote: > On Wed, Jun 29, 2011 at 1:29 PM, gtfisher <[hidden > email]> > wrote: > > > Hi > > I have created a project using the camel-archtype-ja

Re: Exception running from camel-archtype-java -v2.7.2

On Wed, Jun 29, 2011 at 1:29 PM, gtfisher wrote: > Hi > I have created a project using the camel-archtype-java at version 2.7.2 and > if I run the router using mvn camel:run using the versions supplied > camel-core 2.7.2 & camel-spring 2.7.2, I get a runtime error: > > Error occurred while running

Exception running from camel-archtype-java -v2.7.2

Hi I have created a project using the camel-archtype-java at version 2.7.2 and if I run the router using mvn camel:run using the versions supplied camel-core 2.7.2 & camel-spring 2.7.2, I get a runtime error: Error occurred while running main from: org.apache.camel.spring.Main java.lang.reflect.In

Re: Unable to catch exception from Camel.

Here is my sample config: 2011/6/27 Sven Zethelius > Sorry, I didn't look at the stack trace close enough.

Re: Custom exclusiveReadLockStrategy in Servicemix + Camel

There is a JIRA ticket about the changed lock strategy for ftp https://issues.apache.org/jira/browse/CAMEL-2934 You can attach your contribution to that JIRA ticket. Remember to [x] in grant license to apache when attaching files. On Wed, Jun 29, 2011 at 12:21 PM, Laurentiu Trica wrote: > Hi,

Re: Custom exclusiveReadLockStrategy in Servicemix + Camel

Hi, What do you mean by not using JBI? I'm not explicitly using JBI... On the other hand, in the meanwhile I wrote e "changed" strategy for the FTP/FTPS and one for SFTP. I would like to contribute them to Camel as well, but I would also like to make use of them in my project as soon as possible.

Re: XMPP pubsub

In case you are not aware, Smack 3.2 has been released and it includes the pubsub API in question. In fact, there will be a 3.2.1 release in the next few weeks as well. Feel free to contact myself if you have any specific requests of Smack. hadrian wrote: > > You could, but we cannot include i

why i building camel2.7.2 use maven install error?

[ERROR] COMPILATION ERROR : [INFO] - [ERROR] \workspace9\apache-camel-2.7.2\camel-core\src\main\java\org\apache\camel\model\LoadBalanceDefinition.j ava:[131,16] inconvertible types found： org.apache.camel.model.ProcessorDefinition

camel-cxf / spring-ws client saaj

Hello! I am integrating with a legacy web application by using the camel-cxf component to host a SOAP service. The service hosts many operations and they all work, except for the method that uses an attachment. The legacy webapp is using spring-ws and its client template. As you can see below in t

Re: Unable to catch exception from Camel.

And here is the source code... Notice the excessive error handling attempts... The cause of the error is intentional (I am trying to send to a non-existant queue :) package spikes.camel; import javax.jms.JMSException; import org.apache.camel.CamelContext; import org.apache.camel.Exchange; import

Unable to catch exception from Camel.

Hi all, Background: Running Camel 2.7 and IBM MQ Series... UserCredentialsConnectionFactoryAdapter ucf = new UserCredentialsConnectionFactoryAdapter(); MQQueueConnectionFactory cf = new MQQueueConnectionFactory(); ...etc... I have been trying in vain to catch the following exception: (how

camel vs openAdapter vs xbus?

i want to select a Routing and Transformation tool，i found camel, openAdapter and xbus have these functions, but i can't decide what i need to select, who can help me how to choice? -- View this message in context: http://camel.465427.n5.nabble.com/camel-vs-openAdapter-vs-xbus-tp4522979p4522979.h

How does Camel work with ofbiz?

i want to use camel in ofbiz, and use camel to handle receive request, transform message and send response , how to integrate camel to ofbiz? -- View this message in context: http://camel.465427.n5.nabble.com/How-does-Camel-work-with-ofbiz-tp4522972p4522972.html Sent from the Camel - Users mailin

Re: reload routebuilder at runtime

Ask the computer :) For reloading .class files I guess you need something like JRebel or the likes that support hot-reloading of .class files. On Tue, Jun 28, 2011 at 5:15 PM, fachhoch wrote: > I saw the code fo DefaultCamelContext and I think I can use the method > > >    public synchronized

Re: Custom exclusiveReadLockStrategy in Servicemix + Camel

On Tue, Jun 28, 2011 at 3:08 PM, Laurentiu Trica wrote: > Hi, > > I'm using Servicemix 4.3.2 from Fuse. > I have the same problem if I want to use a strategy defined in another > bundle and I want to get it with OSGI I suggest to not use JBI. Pure OSGi works better. > > Regards, > Laurentiu > >

Re: why i building camel2.7.2 use maven install error?

Try upgrading your JDK6 version. - Claus Ibsen - FuseSource Email: cib...@fusesource.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.blogspot.com/ Author of Camel in Action: http://www.manning.com/ibsen/ -- View this message in context: http://camel.46

Re: InvocationTargetException when startinhg active mq endpoint

On Tue, Jun 28, 2011 at 3:01 PM, Andrè wrote: > thx mr ibsen, > > (https://issues.apache.org/jira/browse/AMQ-3184) (Upgrade to camel 2.6.0) > does that mean, that there exists no activemq version which works with camel > 2.7.x > >  or didnt i get that the sense of your post.. > Yeah I dont think

Re: Is there any way to 'park' values for later use

Hi, I'm afraid that you have to store the parameter for second service to use into the exchange. Maybe you can consider to use the setProperty("header", simple(xxx)); On 6/29/11 12:11 PM, Jim Talbut wrote: Hi, I want to provide a single web service that makes calls to two separate web service

Re: Is there any way to 'park' values for later use

Hi, I Had a similar problem like that. I think that you need to look in into "Claim Check" pattern http://camel.apache.org/claim-check.html Regards, Ismail On Wed, Jun 29, 2011 at 7:12 AM, Jim Talbut-2 [via Camel] < ml-node+4534068-1741869265-45...@n5.nabble.com> wrote: > Hi, > > I want to pro

Re: Is there any way to 'park' values for later use

You can store custom values as properties on the Camel Exchange. On Wed, Jun 29, 2011 at 6:11 AM, Jim Talbut wrote: > Hi, > > I want to provide a single web service that makes calls to two separate web > services. > The arguments for the two services are different and some of them are > independe