Re: Body Object in Camel Exchange

2017-01-09 Thread yxzhao
Sorry I have not checked this thread. Thanks for your reply. We're not using the latest Camel version, but 2.14.2. Based on what CAMEL-6481 describes and the fixed time, version 2.14.2 should not have this problem anymore. However, it does happen. We changed our config to go around as of now. Hop

Body Object in Camel Exchange

2016-10-20 Thread yxzhao
We have a camel route which uses the length of exchange message body to determine data types. It works fine when the body contains a string or array of objects, but if it contains array of primitive types, it only returns 1 as length. Below is a simplified version of the route:

XA Transactions in Camel JMS Component

2016-02-28 Thread yxzhao
Hi all, We've been using XA transactions (via atomikos) with JMS component to send/read messages to/from MQ, data is from and saved to oracle database. Now the performance becomes a major problem. We found below from the documentation of camel JMS Component page. Could anyone tell us if it is stil

Re: How to check if the file waiting in enricher arrived after timeout

2014-07-11 Thread yxzhao
Yes, it works now. I thought if the file is empty, the body will be null. Apparently, there is difference between no file and empty file. Thanks for your help. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-check-if-the-file-waiting-in-enricher-arrived-after-timeout-

How to check if the file waiting in enricher arrived after timeout

2014-07-10 Thread yxzhao
Hi there, We need to run a job in certain time window only once a day and it also depends on a trigger file. It needs to be also started if the application started after the starting time point of the time window. Periodically checking for the trigger file with a timeout as defined below fails us

Re: Customizing DestinationResolver for JmsComponent got $proxy40 as session

2014-01-13 Thread yxzhao
We found out the class of the proxy object. It is SessionProxy. -- View this message in context: http://camel.465427.n5.nabble.com/Customizing-DestinationResolver-for-JmsComponent-got-proxy40-as-session-tp5745850p5745893.html Sent from the Camel - Users mailing list archive at Nabble.com.

Customizing DestinationResolver for JmsComponent got $proxy40 as session

2014-01-11 Thread yxzhao
Hi all, We're trying to customize DestinationResolver as below as camel JmsComponent doc page suggested, but could not cast the session parameter to MQQueueSession. The print line displays the class of the session passed in is of class $proxy40. Does anyone out there have a clue on what we do wro

Re: Camel/JMS with Atomikos UserTransactionManager not consuming Messages

2013-04-09 Thread yxzhao
Yes, we have transacted configured with the objects of JmsComponent. I have a general question now on how transaction boundaries are marked in camel routes. I saw results of each database call in a split list is committed into database. I wonder how are other regular routes that don't have transa

Re: Camel/JMS with Atomikos UserTransactionManager not consuming Messages

2013-04-04 Thread yxzhao
I saw you commented out the dataSource declaration with com.atomikos.jdbc.AtomikosDataSourceBean on the bottom and used org.apache.commons.dbcp.managed.BasicManagedDataSource instead. What was the reason for that? I don't see a way of setting the jta transaction manager with atomikos data source

Camel/JMS with Atomikos UserTransactionManager not consuming Messages

2013-04-03 Thread yxzhao
Hi All, We have an app using Camel to schedule jobs and Atomikos to manage transactions accessing IBM MQ queues and Oracle DB. Once a while message consuming routes stop consuming messages completely without indication of any abnormal conditions. Does anyone out there experience this or something

Copy Files with doneFile in different Folder

2013-02-26 Thread yxzhao
Hi all, We need to design a route as below. ...copy files from sourceDirectory to destDirectory... What about sourceDirectory and destDirectory are on different servers? Could anyone tell us if it's possible to get this done with camel existing components or do we have to cu

Re: Always receive String Message even with jmsMessageType set to Bytes

2013-02-14 Thread yxzhao
We can verify that if the MQ message is sent with MQMessage.format = MQConstants.MQFMT_STRING, then our route will receive text message. Otherwise, it will receive a byte array. Actually, the sending app uses the same write bytes method to put the message into the queue. The same message can be rec

Always receive String Message even with jmsMessageType set to Bytes

2013-02-13 Thread yxzhao
Hi All, We have a route which gets messages from an MQ queue. We expect messages in bytes, but always receive java.lang.String even when we set our route as below: Does anybody have a clue what we did wrong or missing? Thanks in advance for any h

Camel Shutdown but Application does not die

2013-01-01 Thread yxzhao
Hi All, We have an application using camel. Now we're trying to shut it down through JConsole (invoke the stop operation in camel context), but the application does not die though the camel logged below info in the log. [INFO] org.apache.camel.spring.SpringCamelContext - Apache Camel 2.10.0 (Came

Files not Picked up with doneFile

2012-12-04 Thread yxzhao
Hi All, We have a route to get a set of files being processed together, that are prepared by different processes asynchronously. In order to flag the start, we will put a doneFile to flag all the files are ready to be processed. However, once a while we found some of the files are left there whi