Re: Camel route with mina2 and HL7codec not working

2014-09-02 Thread Claus Ibsen
Hi I dont see that your hl7 test data matches the expected end bytes - there are 2 end bytes, which you must provide, see: http://camel.apache.org/hl7 On Wed, Sep 3, 2014 at 12:55 AM, gnsandeep wrote: > > Hi, > > I have created below camel-context.xml file .Camel context and route is > started w

RE: camel 2.13.2 zipdataformat

2014-09-02 Thread Sven Nold
Hi, sorry didn't fix it, still the same error. -Original Message- From: Claus Ibsen [mailto:claus.ib...@gmail.com] Sent: Tuesday, September 02, 2014 4:07 PM To: users@camel.apache.org Subject: Re: camel 2.13.2 zipdataformat Hi Thanks. I suspect its because this code creates a new inp

Re: Camel 2.13.1 Retry : starting from Parent Route on a sub route failure

2014-09-02 Thread Claus Ibsen
Try turn off error handling in the sub routes, eg use .noErrorHandler() On Tue, Sep 2, 2014 at 8:20 PM, sandp wrote: > > Hi, I'm trying to understand how the scenario can be implemented : > *direct:parent* calls a RESTFul service, that succeeds, the exchange is > multicast to other endpoints with

Re: Is it possible to have dynamic "from" uri with data in exchange? (Flatpack related)

2014-09-02 Thread Claus Ibsen
Hi You can try using the data format component and refer to flatpack, and do that using "dynamic to" http://camel.apache.org/dataformat-component.html http://camel.apache.org/how-to-use-a-dynamic-uri-in-to.html And your route can then use a regular file component to pickup the files. On Wed, S

Camel 2.13.1 Retry : starting from Parent Route on a sub route failure

2014-09-02 Thread sandp
Hi, I'm trying to understand how the scenario can be implemented : *direct:parent* calls a RESTFul service, that succeeds, the exchange is multicast to other endpoints with *direct:child1* and *direct:child2*. Now, *direct:child1* results in *IOException*, so, on redelivery, route* direct:child1*

Re: Using Timer in Camel

2014-09-02 Thread Shiv
Hi Charles, Thanks for your detailed reply. It resolves my query and confusion. -Shiv -- View this message in context: http://camel.465427.n5.nabble.com/Using-Timer-in-Camel-tp5755951p5755990.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to Enable SSL on Camel MQTT component

2014-09-02 Thread liu gang
OK, it works now, thanks you all 2014-09-03 9:19 GMT+08:00 clever <191008...@qq.com>: > Hi Jimmi: > > > Thank you very much. I'll check your example and try again. > > > Thanks. > > > > > -- 原始邮件 -- > 发件人: "Jimmi Dyson";; > 发送时间: 2014年9月2日(星期二) 晚上10:21 > 收件人: "us

回复: How to Enable SSL on Camel MQTT component

2014-09-02 Thread clever
Hi Jimmi: Thank you very much. I'll check your example and try again. Thanks. -- 原始邮件 -- 发件人: "Jimmi Dyson";; 发送时间: 2014年9月2日(星期二) 晚上10:21 收件人: "users"; 主题: Re: How to Enable SSL on Camel MQTT component Hi, Is the ActiveMQ (I'm assuming you're using Ac

回复: How to Enable SSL on Camel MQTT component

2014-09-02 Thread clever
Hi Charles: Thank you version much, let me try again. -- 原始邮件 -- 发件人: "Charles Moulliard";; 发送时间: 2014年9月2日(星期二) 晚上7:04 收件人: "users"; 主题: Re: How to Enable SSL on Camel MQTT component Hi, I think that debugging will be required as you get a message type =

Camel route with mina2 and HL7codec not working

2014-09-02 Thread gnsandeep
Hi, I have created below camel-context.xml file .Camel context and route is started without any errors. when I send Hl7 message from java client nothing happens- i dont see any logs, exception nor mesaage in java code which is listening on 9020. Can someone please help on how to debug this java

Is it possible to have dynamic "from" uri with data in exchange? (Flatpack related)

2014-09-02 Thread zhouij
Hi, I have searched everywhere and couldn't find a good solution to our problem. We are trying to use the Flatpack component to parse fixed width files, using Spring DSL. The parsing definition pzmap.xml is located under different directories for different customers("resources/customer/{customer

Re: Incorrect behavior of onCompletion for exception and stop

2014-09-02 Thread jorabin
i) If an exception is thrown that is not caught by an exception handler or not “handled" in an exception handler then the onFailureOnly processing stops with an exception after the first processor - presumably because the exception is still present in the exchange. Can I can suppress the excepti

Re: How to Enable SSL on Camel MQTT component

2014-09-02 Thread Jimmi Dyson
Hi, Is the ActiveMQ (I'm assuming you're using ActiveMQ!) MQTT transport connector configured to listen on 61617? Are you sure that's not a non-MQTT (perhaps SSL-configured Openwire) transport connector on 61617? FYI there is a IANA port reserved (8883) for MQTT over SSL, although of course you ca

Re: camel 2.13.2 zipdataformat

2014-09-02 Thread Claus Ibsen
Hi Thanks. I suspect its because this code creates a new input stream in the message body https://github.com/apache/camel/blob/master/components/camel-zipfile/src/main/java/org/apache/camel/dataformat/zipfile/ZipIterator.java#L106 That is not explicit closed. Can you try changing

Re: Using restlet as post - how to use the body?

2014-09-02 Thread OysteinAndersen
That was the solution! Thanks! So, to capture, I addes this to the context:streamCache="true"* id="pg_rest_demo" xmlns="http://camel.apache.org/schema/blueprint";>Best regardsÖystein -- View this message in context: http://camel.465427.n5.nabble.com/Using-restlet-as-post-how-to-use-the-body-tp5

AW: camel 2.13.2 zipdataformat

2014-09-02 Thread Sven Nold
Hi, same result, but workaround is to use zipSplitter like this: zipSplitter ZipSplitter seems not to have this issue. Also works for 2.13.2.

Re: Using Timer in Camel

2014-09-02 Thread Charles Moulliard
Hi Shiv, The Camel component maintains a Map of the Timer objects that the endpoint check when this method is called public synchronized Timer getTimer() { if (timer == null) { TimerComponent tc = (TimerComponent)getComponent(); timer = tc.getTimer(this); // CALL G

Re: Using Timer in Camel

2014-09-02 Thread Matt Sicker
I believe it's either speaking of Timer: http://docs.oracle.com/javase/7/docs/api/java/util/Timer.html Or it may be speaking of ScheduledExecutorService: http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ScheduledExecutorService.html On 2 September 2014 02:52, Shiv wrote: > Hi, > I

Re: camel 2.13.2 zipdataformat

2014-09-02 Thread Claus Ibsen
You need to build the code to make sure the snapshot is using recent code. On Tue, Sep 2, 2014 at 2:22 PM, Sven Nold wrote: > Hi Claus, > > I changed to 2.13.3-SNAPSHOT but still the same issue. > > Best regards, > > Sven > > -Ursprüngliche Nachricht- > Von: Claus Ibsen [mailto:claus.ib..

AW: camel 2.13.2 zipdataformat

2014-09-02 Thread Sven Nold
Hi Claus, I changed to 2.13.3-SNAPSHOT but still the same issue. Best regards, Sven -Ursprüngliche Nachricht- Von: Claus Ibsen [mailto:claus.ib...@gmail.com] Gesendet: Dienstag, 2. September 2014 13:52 An: users@camel.apache.org Betreff: Re: camel 2.13.2 zipdataformat Hi See CAMEL-75

When to use Proxy ?

2014-09-02 Thread Frankiboy
When to use Proxy in Camel ? I have to create a sort og "HUB" , the "HUB´s" function is to get a webservice request , and from the header information, route the request to one of 3 difrent endpoints. The Hub logs the header in MQ. The Hub change some of the header information. The Hub is runnin

Re: camel 2.13.2 zipdataformat

2014-09-02 Thread Claus Ibsen
Hi See CAMEL-7577 On Tue, Sep 2, 2014 at 1:49 PM, Sven Nold wrote: > Hi, > > interesting is also that if I only have on zipEntry and define the > zipDataFormat as useIterator=false it works fine. So my guess is that > ZipIterator somehow holds a lock on the file: > > class="org.apache.cam

AW: camel 2.13.2 zipdataformat

2014-09-02 Thread Sven Nold
Hi, interesting is also that if I only have on zipEntry and define the zipDataFormat as useIterator=false it works fine. So my guess is that ZipIterator somehow holds a lock on the file: http://camel.apache.org/schema/spring";>

AW: camel 2.13.2 zipdataformat

2014-09-02 Thread Sven Nold
Hi, thanks for this test now I think here is the problem: [l-1) thread #1 - file://target] GenericFileOnCompletionWARN Error during commit. Exchange[any.zip]. Caused by: [org.apache.camel.component.file.GenericFileOperationFailedException - Error renaming file from C:\temp\camel-exam

Re: How to Enable SSL on Camel MQTT component

2014-09-02 Thread Charles Moulliard
Hi, I think that debugging will be required as you get a message type = 0 (see code here : https://github.com/fusesource/mqtt-client/blob/master/mqtt-client/src/main/java/org/fusesource/mqtt/client/CallbackConnection.java#L335 ) As you have configured your ActiveMQ Transport connector to use MQTT

How to Enable SSL on Camel MQTT component

2014-09-02 Thread clever
I saw the page of http://camel.apache.org/mqtt.html said mqtt component supports to use ssl connection. but didn't mention how to enable it. I tried to change the protocol to ssl, and also set the system properties: javax.net.ssl.keyStore/javax.net.ssl.keyStorePassword/javax.net.ssl.TrustSt

Re: camel hdfs to ftp

2014-09-02 Thread samnik60 .
Hi guys, Thanks you ur input. Charles : the use case is just to transfer all files in a given hdfs directory to a ftp server and end its execution. I will try out the 'sendEmptyMessageWhenIdle' methodology and revert. Thanks again, R.Monish On Tue, Sep 2, 2014 at 12:33 PM, Charles Moulliard w

Re: camel 2.13.2 zipdataformat

2014-09-02 Thread Jimmi Dyson
Hi, I just added an example at https://github.com/jimmidyson/camel-examples/tree/master/zip-file-processing. This example creates the zip file first (so that it's repeatable) & then does pretty much what you're doing: read from file uri, unmarshal, log each file contents (careful with large files)

Using Timer in Camel

2014-09-02 Thread Shiv
Hi, I need to use a timer using format timer://kickoff?period=30 which will run every 5 minutes and pull records from DB and sends to JMS queue. As the timer fires and busy processing if new timer will be fired again if the timer interval expires? This timer endpoint is defined and used only on

Re: camel 2.13.2 zipdataformat

2014-09-02 Thread Walzer, Thomas
Hi Sven, I seem to have a similar problem. I also use 2.13.2. My code is almost identical. The only difference is my in-url, that looks like: file:someserver/somedir/in?move=archive/${date:now:MMdd}/${file:name}.${date:now:HHmmss}&antInclude=*.ZIP I get a random number of retrievals (abou

Re: camel hdfs to ftp

2014-09-02 Thread Charles Moulliard
To be informed that you have polled all the files in a specific directory (your hdfs dir), you can ask the pollingConsumer of the file component/endpoint to send an empty message using this property ("sendEmptyMessageWhenIdle") and using a ContentBaseRouter with a predicate (check that you get an e