Re: CSV file

2015-07-15 Thread viral069
Thanks For Reply, But it gives me null as a output. I am providing a source code for same, Please suggest me the changes. public class UnMarshallingTest { public static void main(String[] args) throws Exception { DefaultCamelContext context = new DefaultCamelContext();

Re: Camel 2.14/Netty: Separate Exchange for each UDP packet?

2015-07-15 Thread Claus Ibsen
Hi I dont think so as Camel is the Camel Exchange is the complete message to be routed. Its the job of the component/consumer to assemble that complete message before its passed on as an Exchange to the Camel routing engine. It sounds more like you want lower level networking and process UDP pack

Re: Camel get values from body after split

2015-07-15 Thread vivekrao001
NVM.. this worked from("direct:split").routeId("SplitParallel") .log("Split Message :${body}").log("Split Message :*${body[ID]}*") .end(); -- View this message in context: http://camel.465427.n5.nabble.com/Camel-get-values-from

Camel 2.14/Netty: Separate Exchange for each UDP packet?

2015-07-15 Thread SteveR
I have a Linux Java7 stand-alone application using Camel 2.14 and the *camel-netty* component. I have several routes that each receive a UDP feed via netty:udp. I've already implemented a few routes that do this, but have used either a *DelimiterBasedFrameDecoder* or a *LengthFieldBasedFrameDecode

Camel get values from body after split

2015-07-15 Thread vivekrao001
Hi, I'm getting multiple records using sql and splitting them paralleling for next route. But not able to get the values from the splitted record. from("sql:select * from orders where processed = false") .log("Query Message :${body}").split(body()) .parallelProcessing().to("direct

Re: How to sftp download latest version of a file

2015-07-15 Thread Claus Ibsen
te ftp server, there are timestamped copies of > foo-{mmdd-hhmmss}.txt. > I would like to stfp download the latest copy. If I know the file name of > the latest copy is foo-20150715-130120.txt, I can download > foo-20150715-130120.txt using : template.receiveBo

How to sftp download latest version of a file

2015-07-15 Thread Shing Hing Man
Hi, In a remote ftp server, there are timestamped copies of foo-{mmdd-hhmmss}.txt. I would like to stfp download the latest copy. If I know the file name of the latest copy is foo-20150715-130120.txt, I can download foo-20150715-130120.txt using : template.receiveBody( "sftp:

Re: Need help in running camel in raspberry pi

2015-07-15 Thread Henryk Konsek
Hi Parul, I will help you with your example in coming days. Cheers! śr., 15.07.2015 o 07:54 użytkownik Parul napisał: > Hi All, > > I have uploaded sample code @ https://github.com/parulagrawal14/Came-Kura > . > Please let me know if i have done anything wrong in the project which might > hav

Re: Camel Insert after ready Fixed length message from queue

2015-07-15 Thread vivekrao001
Hi, Thank You, Its working now. I tried that option, may be I made a typo. Thanks, Vivek. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Insert-to-DB-after-reading-Fixed-length-message-from-queue-tp5769316p5769363.html Sent from the Camel - Users mailing list archive

Camel DevOps at the Smithsonian Institution

2015-07-15 Thread Davis, Daniel
The Smithsonian Institution (SI) is looking for a person to join its SIdora team and create a development operations (DevOps) environment. SIdora is an ever-evolving, open-source infrastructure supporting researchers, to make it easy for them to obtain and use IT resources plus support their data n

Re: CSV file

2015-07-15 Thread Claus Ibsen
from file bean to ("seda:foo") Then from some java code where you have CamelContext etc CamelContext camelContext = ... ConsumerTemplate ct = camelContext.createConsumerTemplate(); Object data = ct.receiveBody("seda:foo", 5000); On Wed, Jul 15, 2015 at 7:21 AM, viral069 wrote: > Can you

Re: load balancing in jboss fuse 6.2

2015-07-15 Thread chaituu
thanks. -- View this message in context: http://camel.465427.n5.nabble.com/load-balancing-in-jboss-fuse-6-2-tp5769353p5769356.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: load balancing in jboss fuse 6.2

2015-07-15 Thread Claus Ibsen
Hi You may want to ask this on the jboss fuse user forum as its a fuse specific question https://developer.jboss.org/en/products/fuse On Wed, Jul 15, 2015 at 1:05 PM, chaituu wrote: > I have installed Jboss fuse 6.2 in 2 unix boxes and deployed camel-cxf-proxy > application bundle in both the s

Re: camel-jaxb 2.15.0 and Karaf 3.0.3

2015-07-15 Thread SLGeertsema
Hey! Thansk for the fast reply! Jaxb itself is working perfectly, however, the problem arises when I try to use the Prefixmapper: Map prefix = new HashMap(); prefix.put("namespace1", "ns1"); prefix.put("namespace2", "ns2"); myJaxb.setNamespacePrefix(prefix); In a Junit test in Eclipse this work

load balancing in jboss fuse 6.2

2015-07-15 Thread chaituu
I have installed Jboss fuse 6.2 in 2 unix boxes and deployed camel-cxf-proxy application bundle in both the servers. first server is master box and second one is slave box.how do you configure this set up?if master node is down then requests should automatically should forward to slave box.how do w

Re: camel-jaxb 2.15.0 and Karaf 3.0.3

2015-07-15 Thread SLGeertsema
I'm using Camel version 2.15.1, and it works in Eclipse. However, when using it in combination with Karaf 3.0.3, it is not working (see stacktrace below). Will there be a fix soon, or is this fixed in a different version of Camel? 2015-07-15 12:04:17,996 | ERROR | raf-3.0.3/deploy | BlueprintCame

Re: camel-jaxb 2.15.0 and Karaf 3.0.3

2015-07-15 Thread Charlie Mordant
Hi, Camel-jaxb works well on Karaf 3.0.3, I'm using it within my framework and projects. Your project maybe have a missing or conflicting dependency (i.e. jax.impl). Does 'la' on karaf shell shows all bundles started and resolved? Do you see a jaxb.impl bundle on the list? If there are some, don't

Cannot store file error CSV

2015-07-15 Thread fxthomas
hello, I am trying to write from a DB to CSV file , and I always get a cannot store file exception. My route is like below from("timer://getData?period=2h").setBody(constant("SQL Query")).to("jdbc:DS?outputType=StreamList").split(body()).to(file://C:\\GitWrk?fileName=data.csv&fileExist=Ap

Karaf route-list issue

2015-07-15 Thread Vanshul . Chawla
Hello, We have Fuse 6.1 installed on servers. We have deployed bundles which have multiple blueprints and each blueprint has multiple routes. When I do a route list, it shows routes from one blueprint from a installed bundle. And it varies everytime ie I have 6 blueprints and when I do route lis

RE: Camel aggregation in case of server shutdown

2015-07-15 Thread Vanshul . Chawla
Ok. Thanks. Thanks and Regards, Vanshul Chawla -Original Message- From: Claus Ibsen [mailto:claus.ib...@gmail.com] Sent: Wednesday, July 15, 2015 12:51 PM To: users@camel.apache.org Subject: Re: Camel aggregation in case of server shutdown On Wed, Jul 15, 2015 at 9:15 AM, Vanshul.Cha

Re: Camel aggregation in case of server shutdown

2015-07-15 Thread Claus Ibsen
On Wed, Jul 15, 2015 at 9:15 AM, Vanshul.Chawla wrote: > Thanks Claus. What in case someone kills process pid of server? Ie force kill > the server? > Then they are lost. There is this component on the way in a future Camel release that may help http://camel.apache.org/file2 > Thanks and Regar

RE: Camel aggregation in case of server shutdown

2015-07-15 Thread Vanshul . Chawla
Thanks Claus. What in case someone kills process pid of server? Ie force kill the server? Thanks and Regards, Vanshul Chawla -Original Message- From: Claus Ibsen [mailto:claus.ib...@gmail.com] Sent: Wednesday, July 15, 2015 12:41 PM To: users@camel.apache.org Subject: Re: Camel aggreg

RE: Camel aggregation in case of server shutdown

2015-07-15 Thread Vanshul . Chawla
true

Re: Camel aggregation in case of server shutdown

2015-07-15 Thread Claus Ibsen
How do you aggregate them? If you use the Camel aggregator then its by default in-memory only, and you would loose those messages. There is pluggable persistent stores, but they have their own pros/cons. Its better to stop the consumer that takes in new messages, and wait for the aggregator batch

Camel aggregation in case of server shutdown

2015-07-15 Thread Vanshul . Chawla
Hello All, We have a scenario wherein we aggregate message coming from a IBM MQ queue for 15 minutes before spitting a batch out to another MQ. Suppose we have a server shutdown at 10th minute, what will happen to inflight messages? Will these be lost? Or will Fuse server restart get these messa