Connecting to ActiveMQ by a consumer and a producer - best practice

2016-04-07 Thread hayden74
Hi guys, I have question related to the best way to connect to ActiveMQ from a consumer and a producer. So does the way to connect to ActiveMQ from a consumer and a producer have to be the same? that is, using caching in both sides, connection pooling, max number of connections...etc My current c

VirtualTopic message acknowledgment/confirmation

2016-02-24 Thread hayden74
Hi guys, We use VirtualTopics for event publishing and recently one of the consumers failed to process the message from the event due to some database error. >From the ActiveMQ perspectives, the message has been delivered. The client, however, failed to process it. So my question is, is there a way

Re: Why using camel routes (via activemq) in Apache karaf?

2015-11-19 Thread hayden74
Thanks Matt, this is what I have in mind... so basically, OSGi bundle to non-OSGi => JMS via ActiveMQ. The next question I guess would be OSGi service to non-Java platform, such as AngularJS. I probably should post another topic about this. -- View this message in context: http://camel.465427

Re: Why using camel routes (via activemq) in Apache karaf?

2015-11-17 Thread hayden74
Thanks for the reply souciance. I am a little bit not clear on what you mean by "separate integration" though. Can you please elaborate more? I know that OSGi bundles can communicate inside the OSGi container but accessing the OSGi from outside is the part that confuses me. -- View this messag

Why using camel routes (via activemq) in Apache karaf?

2015-11-17 Thread hayden74
Hi guys, My camel routes basically represent business services. I started with 2 routes and now I have over 50. The project is a spring MVC/maven deployed in a Tomcat server. The routes are accessible via ActiveMQ using JMS. Everything works fine except when it comes to updating or fixing a bug in

Re: File component to only process files if modified with noop=true

2015-10-01 Thread hayden74
Thanks for the reply Claus. The *eagerMaxMessagesPerPoll=false* didn't fix the issue unfortunately -- View this message in context: http://camel.465427.n5.nabble.com/File-component-to-only-process-files-if-modified-with-noop-true-tp5772074p5772165.html Sent from the Camel - Users mailing list

Re: File component to only process files if modified with noop=true

2015-09-29 Thread hayden74
Thanks Claus. This worked, but not with expression language. My route looks like below: from("{{data.inbox.componentType}}://{{data.inbox.dataDirPath}}?fileName={{file.ownerStatusDataFile}}&idempotentKey=${file:name}-${file:modified}&noop=true") .log("Copying ownerStatusDataFile")

File component to only process files if modified with noop=true

2015-09-28 Thread hayden74
Hi guys, The issue I am having at the moment seems to be reported back in 2010 as per this link . Just wondering if this has been resolved or considered as a bug? My use case is basically:

Re: ${date:now:yyyMMdd} is not parsed correctly

2015-09-21 Thread hayden74
Thanks Claus, that what I expected but I needed to be sure :) -- View this message in context: http://camel.465427.n5.nabble.com/date-now-yyyMMdd-is-not-parsed-correctly-tp5771739p5771750.html Sent from the Camel - Users mailing list archive at Nabble.com.

${date:now:yyyMMdd} is not parsed correctly

2015-09-21 Thread hayden74
Hi guys, the ${date:now:MMdd} is not parsed correctly. Can you please help? My route looks like this: from("file://C:/applications/data?fileName=${date:now:MMdd}/dataFile.csv") .log("New file received"); That's parsed as below: Route: route4 started and consuming from:

Re: smb endpoint - modified files not copied to destination

2015-09-18 Thread hayden74
I finally had time to try this. The result was not what I expected though. My route looks like this: from("file://C:/applications/data?fileName=${date:now:MMdd}/dataFile.csv") .log("New file received"); and the result was: Route: route4 started and consuming from: Endpoint

Re: smb endpoint - modified files not copied to destination

2015-08-10 Thread hayden74
> > Yeah you can filter by fileName actually. Though this would require > the file to be named inputFile.csv > > On Mon, Aug 10, 2015 at 10:45 AM, hayden74 <[hidden email] > <http:///user/SendEmail.jtp?type=node&node=5770522&i=0>> wrote: > > &g

Re: smb endpoint - modified files not copied to destination

2015-08-10 Thread hayden74
So basically change the route to: from("smb://networkDriveOne/"?noop=true&fileName=${date:now:ddMM}/inputFile.csv&recursive=true") .to("smb://networkDriveTwo?fileExist=Override") -- View this message in context: http://camel.465427.n5.nabble.com/smb-endpoint-modified-files-not-copie

Re: smb endpoint - modified files not copied to destination

2015-08-10 Thread hayden74
Many thanks Claus. I've tried to simply the scenario and ended up asking the wrong question. My bad. The input directory in my scenario changes daily based on the date. So the route looks like this: string todaysDateStr = "01-01-2015"; //this value changes based on the current date from("smb://

smb endpoint - modified files not copied to destination

2015-08-09 Thread hayden74
Hi Camel experts. The issue I am facing is that Camel doesn't seem to copy a modified file after being copied the first time to its destination. The route used is: from("smb://networkDriveOne?noop=true&fileName=inputFile.csv") .to("smb://networkDriveTwo?fileExist=Override") When Camel is resta

Re: Virtual Topic isn't working

2015-04-16 Thread hayden74
Many thanks Paul, it turned up that I was using older version of Camel & ActiveMQ. it worked fine when I've upgraded the pom to use 2.15.1 & 5.11.1 respectively. -- View this message in context: http://camel.465427.n5.nabble.com/Virtual-Topic-isn-t-working-tp5765762p5765857.html Sent from the

Re: Virtual Topic isn't working

2015-04-14 Thread hayden74
Thanks Paul, I will give it another go when I get home. Do I also need to change the Camel side to publish to a queue instead of a topic? eg:change Camel side from from("jms:queue:foo").to("activemq:topic:VirtualTopic.bar"); to from("jms:queue:foo").to("activemq:queue:VirtualTopic.bar"); Tha

Re: Virtual Topic isn't working

2015-04-14 Thread hayden74
Thanks Paul, That was a typo, the code now looks like: Camel side: from("jms:queue:foo").to("activemq:topic:VirtualTopic.bar"); onsumerTemplate consumerTemplate = context.getBean("consumerTemplate", ConsumerTemplate.class); String number = consumerTemplate.receiveBody("activemq:topic

Virtual Topic isn't working

2015-04-14 Thread hayden74
Hi guys, I am having trouble consuming messages from a Virtual Topic. Basically I want messages from FOO queue to be published to VirtualTopic.BAR. Here is what I have so far: Camel side from("jms:queue:FOO").to("activemq:topic:VirtualTopic.BAR"); Consumer side: ConsumerTemplate consumerTemplate

Publishing events using Camel - best approach with example

2015-04-13 Thread hayden74
I want to use Camel to basically do the following asynchronously: - System A triggers newAccountCreated spring event - System A - event handler publishes the event to a Camel route "accounts" - Camel receives the event and delivers it to System X, Y and Z What is the best approach to implement th