Re: Retrieve Caller Ip Address

Hi Could you check the restlet documentation to see if they provide any details how to get this information. As Camel would need to get the information the same way. And if so we could maybe make it easier to get this details out of the box as headers or something by improving the camel-restlet c

Re: TimeOut logic in camel

Hi Take a look at some of the EIPs which has support for timeout built-in, such as recipient list, content enricher etc. On Fri, Feb 14, 2014 at 7:36 AM, geddamsatish wrote: > is there a way using request -reply pattern i want it using direct end > point only :) > > > On Fri, Feb 14, 2014 at 1:

Re: File Exists

On Thu, Feb 13, 2014 at 9:23 PM, JKemp wrote: > Hey guys, > > Does anyone have any further ideas here? I don't see any obvious way to get > the listing of file names. Or should I be looking at another way to solve > this problem? > You can use the java.io file api to check if a file exists and

Re: Camel raising Exception for continuous MQTT Publishing

Hi If possible try with a newer release and test if it works better. We have fixed some bugs in camel-mqtt, and the MQTT library itself has also been upgraded in newer releases. And you can also try testing with latest code as SNAPSHOT and see if that works better. Some pointers is on this page

Re: Camel raising Exception for continuous MQTT Publishing

Hai Claus , Thanks for replying .. am using Apache Camel 2.11.0 .. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-raising-Exception-for-continuous-MQTT-Publishing-tp5747286p5747291.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel raising Exception for continuous MQTT Publishing

Hi What Camel version are you using? On Fri, Feb 14, 2014 at 5:28 AM, harikrish07121991 wrote: > Hai everyone , > am using Apache Camel MQTT adapter for publishing some data continuously > to a message stream but it raises the following exception upon continuous > publishing .. > > I guess its

Re: File Component route issue.

Hi What about the line separators on the big file? Are it just \n or is it maybe \n\r or \r etc? Maybe the tokenizer need to be adjusted? You can also try a little java main app and try to use the java util Scanner to read the same file and see if you can do that without any issues. And is there

Re: Apache Mina2 and HL7 listener

Hi Did you look at the camel-mina2 api? AFAIR the code is similar to mina 1.x, so hopefully you can do the same. On Thu, Feb 13, 2014 at 4:30 PM, Bart wrote: > Hi, > I have simple mina2 listener defined in spring bean: > uri="mina2:tcp://192.168.1.195:8812?sync=false&codec=#hl7codec&minaLogger=

Re: TimeOut logic in camel

is there a way using request -reply pattern i want it using direct end point only :) On Fri, Feb 14, 2014 at 1:34 AM, Elvio Caruana (ecaruana) [via Camel] < ml-node+s465427n5747276...@n5.nabble.com> wrote: > Try switching to a SEDA endpoint (https://camel.apache.org/seda.html), > and use a timeo

Camel raising Exception for continuous MQTT Publishing

Hai everyone , am using Apache Camel MQTT adapter for publishing some data continuously to a message stream but it raises the following exception upon continuous publishing .. I guess its the error of MQTT adapter not able to disconnect from the previous opened connection .. ERROR Default

Retrieve Caller Ip Address

HI all I am new in Camel I have a reslet api like below How can i get the caller ip address..? I have checked message header and body, but didnt find the client ip address Please help me -- View this message in context: http://camel.465427.n5.nabble.com/Retrieve-Caller-Ip-Address-tp5747272

RE: File Exists

Hey guys, Does anyone have any further ideas here? I don't see any obvious way to get the listing of file names. Or should I be looking at another way to solve this problem? Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/File-Exists-tp5746608p5747277.html Sent fr

Re: Apache Karaf and camel-fop

Hi Maruan, Could you please guide me in this? Is this now working in SMX 4.5.3. Can you send me a sample? Thanks -- View this message in context: http://camel.465427.n5.nabble.com/Apache-Karaf-and-camel-fop-tp5719011p5747274.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Jetty endpoint as ActiveMQ consumer

Hi, I bet this page[1] can help you :) [1] http://camel.apache.org/content-enricher.html -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com(http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com(http://jnn.javaeye.com/) (Chinese) Twitter:

Re: Jetty endpoint as ActiveMQ consumer

Hi Scott Thumb Rule is that you cant have more than 1 consumer endpoint ("from") in a route tag. I would suggest you to have a route take data from Queues and sent it as an http request. And another route to grab that (set up a jetty http server point here) and continue what ever processing you w

File Component route issue.

Hi I have a requirement to process 2 huge files from remote server. Step1:i have written route to SFTP the file from remote server to local server - working fine. from(from).autoStartup(true).to(to) from--> sftp://user@?password=&localWorkDirectory=/tmp&readLock=changed&idempotent=true&

Jetty endpoint as ActiveMQ consumer

Hello, I want to consume messages from an ActiveMQ queue using HTTP GET via a Jetty endpoint. This will deploy: http://0.0.0.0:8182/dequeue"/> but the second "from" doesn't wait on the first "from", in other words, messages are consumed from the queue

RE: TimeOut logic in camel

Try switching to a SEDA endpoint (https://camel.apache.org/seda.html), and use a timeout of one second. Elvio -Original Message- From: geddamsatish [mailto:geddamsat...@gmail.com] Sent: 13 February 2014 14:32 To: users@camel.apache.org Subject: TimeOut logic in camel I have route which

Re: Java Route Not Finishing

If the incoming message via the MQTT consumer was InOut (i.e. request-reply), it's likely that the JMS producer is sending the message as InOut. This means that the producer is waiting for a reply. Try setting the 'exchangePattern' option on the JMS endpoint to 'InOnly' to instruct the producer tha

Re: Java Route Not Finishing

It turns out that the MQTT component only supports consuming from that endpoint. I figured out that I can consume a message as an MQTT message if I send the message as a JMS. Like follows: from("mqtt:test?subscribeTopicName=zaq.avila.send") .process(new Rest

Re: Unreleased thread, possible in SMPP component

Any update on this issue? I am also getting this error. :( 2014-02-13 21:15:36,479 132604 INFO [SMPPSession] {Thread-14} Connected 2014-02-13 21:15:36,480 132605 INFO [SMPPSession$PDUReaderWorker] {Thread-19} Starting PDUReaderWorker with processor degree:3 ... 2014-02-13 21:15:37,573 133698 ERR

Re: Question About JNDI Registry when Running Camel in JBoss Application Server

To circle back to this question for historical reasons and those searching the thread, the actual binding of these is transparrent. When you create a JNDI based registry for your camel components, the JNDI registry is fused with the JNDI system of JBOSS so that you can assume that any lookup in the

Multipart message empty in servlet

Hi, I’m having a problem getting a multipart-mime uploaded file from the servlet component using Commons FileUpload. I’m using Camel 2.12.2 with Tomcat 7.04 using the camel-example-servlet-tomcat with added groovy. What happens is I can parse the stream and get the headers, but the body seems t

Re: routing with camel

Look at the HTTP4 component. Jut call it inline: .when(xpath("//oprncode = 'ATM'")) .setHeader(Exchange.HTTPQuery, simple(". stuff here . ")) .to("http4://www.myhost.org:8020").endChoice() Generally with camel if your task is not unique to your process or unique to your domain, then ther

Re: errorHandler for activemq component example configuration

With any JMS system if you send a message using request-reply the broker will utilize one of many options for replying to you. Either a temporary queue just for you or a community topic by which you can use your correlation ID to pluck out the reply. There are other options as well. >From the poin

Re: Resume an Endpoint in a Route

Ok I was trying to accopmlish this without using RouteBuilder class as I dont want to use both Spring XML and Java DSL to define routes. And in Spring XML I dont see an option to set property - routeStartDate in SimpleScheduledRoutePolicy class at runtime. Hence my soluton looks like the one whic

Apache Mina2 and HL7 listener

Hi, I have simple mina2 listener defined in spring bean: And I'm connecting to this listener using HAPI HL7 test panel few clients. I have also a web page that shows some statistics. I would like to show on this page if there is any client connected with listener. I though that since this is TCP

Re: Resume an Endpoint in a Route

Again I am not sure about the use case and all the requirements, but it is possible to build and start routes with other routes in camel. That is very cool concept. You could read the values from database(any other source) and use these values to create new route. You could do something similar to

TimeOut logic in camel

I have route which hits does jobs a,b,c sequentially .I want an SLA of 1 sec i.e, if i don't get reply from the route within 1 sec i will send some custom message. or else i will send the reply back to client but the job should continue even after time out.Im using direct endpoint. -- View

Re: errorHandler for activemq component example configuration

"If using AMQ you can enable sync sending," I am trying to work out how this can be done from Jms Options. I tried to grep with sycnhronous keyword but couldnt find it really. Appreciate if you can tell how this can be achieved. -- View this message in context: http://camel.465427.n5.nabble.com

Re: How to return null element with Camel-CXF

I'm not sure if it is valid to return a null for that POJO request-response web service that you have. If you had a generic provider based request-response interface (javax.xml.ws.Provider), you can return a null to dynamically simulate oneway invocations. But I'm not sure about the POJO case... 2

Re: Resume an Endpoint in a Route

Yes I looked into SimpleScheduleRoutePolicy, the problem is the time comes from DB which is a dynamic value, and I use Spring XML for routes. so I was not sure on how to attach the dynamically created RoutePolicy reference in the route during the runtime. -- View this message in context: http:/

Re: Definition of a HL7 FTP endpoint simulated with a spring Camel mllp

Hi, Thanks for your answer. I have got the same error. An other idea ? DT -- View this message in context: http://camel.465427.n5.nabble.com/Definition-of-a-HL7-FTP-endpoint-simulated-with-a-spring-Camel-mllp-tp5746939p5747260.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Definition of a HL7 FTP endpoint simulated with a spring Camel mllp

Put inside And what version of Camel are you using? On Thu, Feb 13, 2014 at 12:19 PM, dtjep wrote: > Hi, > I have tried with the following code but I have got the same error in the > endpoint : > > http://www.springframework.org/schema/beans"; >xmlns:xsi="http://www.w3.org/2001/XMLSch

AW: suscribeme

On http://camel.apache.org/mailing-lists.html it is described how to subscribe to the mailing list. Basically send an email to users-subscr...@camel.apache.org - don't send this directly to the users list. cheers Jan > -Ursprüngliche Nachricht- > Von: Ramiro Pugh [mailto:ramp...@gmail.com

suscribeme

-- Ramiro Pugh

Re: Definition of a HL7 FTP endpoint simulated with a spring Camel mllp

Hi, I have tried with the following code but I have got the same error in the endpoint : http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.spri

Re: Performance degradation on consumer side when switching Camel from 2.11.0 to 2.12.1v

Hi I have logged a ticket to improve this https://issues.apache.org/jira/browse/CAMEL-7203 On Tue, Feb 11, 2014 at 2:19 PM, Rosen Spasov wrote: > It seems the performance regression is caused by a change triggered due to > this defect: CAMEL-6541

Re: Resume an Endpoint in a Route

If your requirement is to process files at specific time of the day then I think it would be best to use route with cron scheduler route policy. @Override public void configure() throws Exception { CronScheduledRoutePolicy routePolicy = new CronScheduledRoutePolicy(); routePolicy.setRo

routing with camel

I have two REST url's one to check rest url for options second to process from another rest url. i want to route first url "returnu" through xpath and then call another rest service url "query url" and process it Code snippet are as follows. try { context.start();

Re: NullPointerException in FileInputStreamCache

Hi, this is a known issue see https://issues.apache.org/jira/browse/CAMEL-7055 and is fixed in 2.12.3 Regards Franz On Thu, Feb 13, 2014 at 5:03 AM, Rural Hunter wrote: > Hi, > > I'm using Camel 2.12.2 and enabled stream caching with this code: > context.setStreamCaching(true); > > Sometimes I

Re: NullPointerException in FileInputStreamCache

it looks life the stream has been closed and thus destroyed but it was re-used. For the dev community, I think camel's CachedOutputStream is hard to use as it targets for a single owner usage compared to cxf's one which does reference counting for opened connections to support multiple threads rea

Re: NullPointerException in FileInputStreamCache

The message is quite big comparing with others not causing problem. 于 2014/2/13 17:00, Claus Ibsen 写道: btw any idea of the size of the message when you hit that NPE? Are the message big, or small? Mind the stream cache has a overflow to disk for bigger messages. I suspect the NPE is when a stre

Re: NullPointerException in FileInputStreamCache

btw any idea of the size of the message when you hit that NPE? Are the message big, or small? Mind the stream cache has a overflow to disk for bigger messages. I suspect the NPE is when a stream overflows from memory to disk, and somewhere on the way the temporary file to use for disk overflow is

Re: NullPointerException in FileInputStreamCache

It's like this: from(NEW_QUEUE).unmarshal().json(JsonLibrary.Gson, IndexDoc.class) .process(new Processor1()) .process(new Processor2()) .process(new Processor3()) .process(new Processor4()) .process(new Processor5()) .process(new Processor6()).wireTap(MY_STORE) .marshal().json(JsonLibrary.Gson).t