Re: Should camel extend the way of custom logical of camel route?

2011-11-08 Thread Willem Jiang
On Tue Nov 8 14:37:59 2011, xuhb wrote: Thanks Hadrian Zbarcea: . it seems the discuss has stray away from my original question. the original question is : when execution logic of route cannot be expressed by camel's built in MEP. Is there method which could be used to define a custom ex

Re: Remotely pulling messages using CAMEL

2011-11-08 Thread Ioannis Canellos
I think that camel can be a good fit inside your use case. I would still need a few more details, in order to respond to all your questions. What is the communication protocol between your application and the truck (you just mention that you use a host & port but what about protocol? Is it http? i

NPE when using SEDA queue

2011-11-08 Thread Tarjei Huse
Hi, I'm trying to construct a system for moving some seda queues over to ActiveMQ during system shutdown. What I did was create a Route that connects to some of my seda queues and then drains the queue to activemq. Basicly I got two routes, the drainer: from("seda:" + sedaId + "?size=1000")

Re: NPE when using SEDA queue

2011-11-08 Thread Claus Ibsen
What version of Camel are you using? On Tue, Nov 8, 2011 at 9:16 AM, Tarjei Huse wrote: > Hi, > > I'm trying to construct a system for moving some seda queues over to > ActiveMQ during system shutdown. What I did was create a Route that > connects to some of my seda queues and then drains the qu

Re: Should camel extend the way of custom logical of camel route?

2011-11-08 Thread xuhb
>It is not good to let your business logical aware the low level of camel API. Yes, it's bad. if there are other ways, we will prefer to it; > It could be more handy if you let camel to call a customer bean. ...unfortunately, I still haven't thought out a way to resolve the example(query user-in

Re: Should camel extend the way of custom logical of camel route?

2011-11-08 Thread xuhb
>It is not good to let your business logical aware the low level of camel API. Yes, it's bad. if there are other ways, we will prefer to it; >It could be more handy if you let camel to call a customer bean. ...unfortunately, I still haven't thought out a way to resolve the example(query user-i

Re: NPE when using SEDA queue

2011-11-08 Thread Tarjei Huse
On 11/08/2011 10:00 AM, Claus Ibsen wrote: > What version of Camel are you using? 2.8.2 T > > > On Tue, Nov 8, 2011 at 9:16 AM, Tarjei Huse wrote: >> Hi, >> >> I'm trying to construct a system for moving some seda queues over to >> ActiveMQ during system shutdown. What I did was create a Route tha

Re: Should camel extend the way of custom logical of camel route?

2011-11-08 Thread Willem Jiang
You can pass the header to be bean by adding the annotation @header[1]. [1]http://camel.apache.org/bean-binding.html On Tue Nov 8 17:10:40 2011, xuhb wrote: It is not good to let your business logical aware the low level of camel API. Yes, it's bad. if there are other ways, we will prefer to

Re: NPE when using SEDA queue

2011-11-08 Thread bvahdat
Hi, just a very tiny pointer: Looking at the source it seems that the SedaEndpoint.getConsumerMulticastProcessor() method returns 'null' causing the NPE, as the condition: multicastStarted == false || consumerMulticastProcessor == null is true. Regards, Babak -- View this message in context:

Concurrent SEDA Route with CXF Client

2011-11-08 Thread Achim Nierbeck
Hi all, Using Camel 2.8.1 with CXF 2.4.0 I have a strange behaviour/issue with consuming Webservices with a cxf client. My Route has a configured CXF Endpoint http://tempuri.org/"; xmlns:a="http://schemas.microsoft.com/2003/10/Serialization/Arrays"; xmlns:i="http://www.w3.org/2001/XMLSchema-ins

Re: NPE when using SEDA queue

2011-11-08 Thread Tarjei Huse
On 11/08/2011 11:58 AM, bvahdat wrote: > Hi, > > just a very tiny pointer: > > Looking at the source it seems that the > SedaEndpoint.getConsumerMulticastProcessor() method returns 'null' causing > the NPE, as the condition: > > multicastStarted == false || consumerMulticastProcessor == null > > i

Re: Concurrent SEDA Route with CXF Client

2011-11-08 Thread Achim Nierbeck
Hi Another update on this, after taking a closer look on the system I fear I have the following issue: Client calling on Server a is waiting for a response while Client 11 is starting a new Call on Server k which rests the client waiting for response of server a. To me it seems possible that the

Starting routes in StartupListener

2011-11-08 Thread wing-tung Leung
Hello, my camel context contains a few routes which should not be started automatically, but it should run a business check first for those routes. My initial idea is to disable "autoStartup" for those routes, and add a custom StartupListener which performs the check and simply calls "startRoute()

Re: Starting routes in StartupListener

2011-11-08 Thread wing-tung Leung
On Tue, Nov 8, 2011 at 2:13 PM, wing-tung Leung wrote: > my camel context contains a few routes which should not be started > automatically, but it should run a business check first for those routes. > My initial idea is to disable "autoStartup" for those routes, and add a > custom StartupListener

Re: Concurrent SEDA Route with CXF Client

2011-11-08 Thread Willem Jiang
Does your Client 11 and Client 8 using the same address to send the request ? CXF is using the HttpURLConnection of sun, which is try to reuse the connection by default. I had some headache last week to deal with it. You can try to pass the -Dhttp.keepAlive=false to the VM to avoid the HttpU

META-INF.cxf

2011-11-08 Thread Gnanaguru S
Hi We are trying to create a new cxf-camel example. After generating the jar and deploying it to deploy dir. we are facing this exception. 19:01:42,343 | INFO | l Console Thread | Console | 35 - org.apache.karaf.shell.console - 2.2.2.fuse-00-08 | Exception caught while

Re: META-INF.cxf

2011-11-08 Thread Willem Jiang
Hi, It should be exported by cxf bundle jar. Are you using the apache-camel feature to install the bundles ? On Tue Nov 8 23:25:37 2011, Gnanaguru S wrote: Hi We are trying to create a new cxf-camel example. After generating the jar and deploying it to deploy dir. we are facing this exceptio

Re: META-INF.cxf

2011-11-08 Thread Charles Moulliard
META-INF.cxf is a directory of the bundle cxf containing shema definition of the beans, ... Have you installed cxf and camel-cxf features ? On Tue, Nov 8, 2011 at 4:25 PM, Gnanaguru S wrote: > > Hi > > We are trying to create a new cxf-camel example. After generating the jar > and deploying it t

Re: Should camel extend the way of custom logical of camel route?

2011-11-08 Thread Jesús Castillo
In general, I would avoid writing business logic by using interceptors and all this low level Camel API. In your example, you can either use the Recipient List with a customized Aggregation strategy that keeps the Exchange that reports the person's info or use the Dynamic Router and stop the web s

Re: Remotely pulling messages using CAMEL

2011-11-08 Thread Jesús Castillo
Camel can help you out. Take a look at the MINA and netty component in Camel for low level TCP/IP communication. http://camel.apache.org/netty.html http://camel.apache.org/mina.html Rgds, Jesus.

Call a bean with a overloaded method

2011-11-08 Thread Michael Prieß
Hello, me again. I looked on the following page http://camel.apache.org/bean-binding.html but found only a solution to call a method overloaded method from JAVA DSL. But I like to use the Camel-Spring XML way like and call the method convertAndSend(Object); but alltime the method convertAndSe

Re: Call a bean with a overloaded method

2011-11-08 Thread Claus Ibsen
Hi Yeah this should be easier from Camel 2.9 onwards as you can specify the binding in the uri directly So that should be, to use the 1 parameter method: Unfortunately for older releases its a bit more tricky. What people maybe have done in the past is to use an intermediate java object, which

Re: Starting routes in StartupListener

2011-11-08 Thread Claus Ibsen
On Tue, Nov 8, 2011 at 2:13 PM, wing-tung Leung wrote: > Hello, > > my camel context contains a few routes which should not be started > automatically, but it should run a business check first for those routes. > My initial idea is to disable "autoStartup" for those routes, and add a > custom Star

correlationExpression while Aggregating

2011-11-08 Thread ebinsingh
Hi All, Appreciate your help. I have a bean that returns a String or a StringBuilder. I want to aggregate the first 2000 String's returned by this method into a single file. I am having trouble with finding the right correlationExpression to aggregate them. Please can you help me fix this. Tha

Re: correlationExpression while Aggregating

2011-11-08 Thread boday
Ebe, what does your bean return? If its just a String, then just use the completionSize() like this... from("direct:start") .to("bean:myBean") .aggregate(constant(true), new MyAggregationStrategy()).completionSize(2000) .to("file:myFile"); If the bean returns a List of Strings, then you can spli

Re: correlationExpression while Aggregating

2011-11-08 Thread ebinsingh
Thanks a lot. Below is the code am using and I get this error message. Not sure what is missing. from("file:C:\\camelProject\\data\\inbox\\") .log("Starting to process big file: ${header.CamelFileName}") .split(body().tokenize("\n")).streaming()

cxfEndpoint and cxf:dataBinding

2011-11-08 Thread Matt Narrell
Hey, I'm trying to add a cxf:dataBinding element to my cxf:cxfEndpoint. According to the documentation[1] and the XSD[2] this seems possible, but looking at the code I don't see a DataBinding property. When Spring tries to create the bean, I get this: org.springframework.beans.NotWritablePro

Re: Remotely pulling messages using CAMEL

2011-11-08 Thread newbiee
Thank you for the reppy. I can use any of the following protocols: XMPP (Jabber) HTTPS SSL SFTP Secure MQ But most probably I would prefer to use HTTPS. The thing is that the digi device is connected to the computer on board truck via a serial port so all the communication reaching at digi devic

Re: Concurrent SEDA Route with CXF Client

2011-11-08 Thread Willem Jiang
Just another comment for it, current camel-cxf producer is work in the async module, and the HttpURLConnection will reuses the cached the connection in 5000ms, which means you will hit such error in a heave load situation. You can use the synchronous=true to force CXF client to work synchronou

Re: cxfEndpoint and cxf:dataBinding

2011-11-08 Thread Willem Jiang
It's a know issue[1], and it is fixed in camel 2.8.2 [1] https://issues.apache.org/jira/browse/CAMEL-4473 On Wed Nov 9 04:34:46 2011, Matt Narrell wrote: Hey, I'm trying to add a cxf:dataBinding element to my cxf:cxfEndpoint. According to the documentation[1] and the XSD[2] this seems possi

Re: META-INF.cxf

2011-11-08 Thread Gnanaguru S
I am trying to deploy a camel example. facing this issue. ( the bundle was active but failed) 11:43:53,714 | ERROR | xtenderThread-19 | ContextLoaderListener| ? ? | 85 - org.springframework.osgi.extender - 1.2.1 | Application context refresh failed (OsgiBundleXmlAppli cationContext

REST service through camel-cxfrs producer using CXFRS dispatch Interface

2011-11-08 Thread santoshjoshi
Using: Apache Camel: 2.8.1 Apache CXF: 2.4.1 The Follwing codes invoke the remote REST service through a proxy, here we had specified the operation name in the message header and parameters in the message body. Exchange exchange = template.send("direct://proxy", new Processor() { publi

Camel feature query

2011-11-08 Thread Gnanaguru S
Hi I am trying to achieve this scenario from camel. 1. I have a web service ( WSDL First approach ). This WSDL has four different operations. 2. I will create a route, *From wsdl To xslt transformer* 3. But i have to do four different transformations for four different operations. 4. How i am go

Unable to export camel example to servicemix

2011-11-08 Thread Gnanaguru S
Hi I was trying to deploy camel-example-cxf example from camel package into servicemix, But i was not able to deploy. When i try mvn install in that example folder, it is generating jar files but when i deploy It is showing failed. Help out. Regards Guru -- View this message in context: htt