Re: MinaUdpProtocolCodecFactory

2013-04-18 Thread Claus Ibsen
Hi You can always create your own codec and use that. And do you really use ByteBuffer as the body type? That is a Mina type? What we can do is to check the type of the body. If its already a ByteBuffer then use it as is. Otherwise we can try converting to byte[] and String. Which we need to cre

Re: Bindy fixed length

2013-04-18 Thread Charles Moulliard
Thx. Will have a look. On Fri, Apr 19, 2013 at 7:21 AM, Magnus Palmér wrote: > A very simple JUnit test, code and description is in the below gist: > https://gist.github.com/magnuspalmer/5418305 > > > > 2013/4/19 Charles Moulliard > > > Hi, > > > > Can you provide the code used so we can make

Re: consumer.bridgeErrorHandler=true on netty uri

2013-04-18 Thread Claus Ibsen
Hi What version of Camel do you use? On Wed, Apr 17, 2013 at 9:09 PM, fbarbat wrote: > Hi, > > I tried to use consumer.bridgeErrorHandler=true on a netty endpoint but it > had no effect. From what I see from Camel's source, it looks like this > parameter is not used although NettyConsumer extend

Re: How to enable thread pool for Mina Endpoint (consumer)

2013-04-18 Thread Claus Ibsen
Hi Ah yeah in the old 2.8.1 its using the default thread pool which as 10-20 as default setting. You can configure the default thread pool profile to have a higher values as documented here http://camel.apache.org/threading-model.html On Thu, Apr 18, 2013 at 2:18 PM, Claus Ibsen wrote: > You can

Re: How to enable thread pool for Mina Endpoint (consumer)

2013-04-18 Thread Hema T
Is it possible using camel mina2? We are having performance issues because of this. How can I improve the performance otherwise? Any upgrades on Camel or camel mina component would help? Please share your thoughts.. Thanks, Hema -- View this message in context: http://camel.465427.n5.nabble.c

Re: Calling WebService with Camel

2013-04-18 Thread abhi
You can also refer to http://camel.465427.n5.nabble.com/How-to-call-CXF-web-service-from-Camel-td5729692.html#a5729744 Thanks, ABhi -- View this message in context: http://camel.465427.n5.na

Re: Calling WebService with Camel

2013-04-18 Thread abhi
Hi, PLease find below example that is working for me . http://localhost:8080/HelloWeb/Hello"; wsdlURL="http://localhost:8080/HelloWeb/Hello?wsdl"; serviceClass="com.server.HelloFirst" endpointName="s:HelloFirstImplPort" serviceName="s:HelloFirstImplService" xmlns:s="http://s

Re: Issue in Calling REST web service through Camel

2013-04-18 Thread abhi
Hi Sergey, Thanks for your reply. I think i have put up my question wrongly. Following Camel route is working perfectly fine. * http://localhost:8080/cxf-rest-example/myservice/users"; /> * The Camel route that is not working is as follows *htt

Re: Bindy fixed length

2013-04-18 Thread Magnus Palmér
A very simple JUnit test, code and description is in the below gist: https://gist.github.com/magnuspalmer/5418305 2013/4/19 Charles Moulliard > Hi, > > Can you provide the code used so we can make a try (unit test using > camel-bindy) and fix if there is an issue please ? As I have created the

Re: Bindy fixed length

2013-04-18 Thread Charles Moulliard
Hi, Can you provide the code used so we can make a try (unit test using camel-bindy) and fix if there is an issue please ? As I have created the @Link long time ago, I need to refresh my brain before to tell if there is an issue or not ;-) Regards, On Thu, Apr 18, 2013 at 5:34 PM, fbarbat wrot

Re: String to byte array TypeConverter uses hbase.util.Bytes?

2013-04-18 Thread Willem jiang
Did you have camel-hbase in your class path? Please remove it from your class path if it is there. -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web: http://www.fusesource.com | http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (E

Re: CXF Bean, MultiPart -> Couldn't find MIME boundary

2013-04-18 Thread Willem jiang
Camel Jetty component is using the org.eclipse.jetty.servlets.MultiPartFilter by default. You can access the file from the message attachment just like this Message in = exchange.getIn(); assertEquals("Get a wrong attachement size", 1, in.getAttachments().size()); // The file name is attachment

Re: How to unmarshal a XML String to java object for properties without required annotation

2013-04-18 Thread Raul Kripalani
You have a mismatch between the XML element named 'fieldValue' and the POJO property named 'fieldVal'. *Raúl Kripalani* Enterprise Architect, Open Source Integration specialist, Program Manager | Apache Camel Committer http://about.me/raulkripalani | http://www.linkedin.com/in/raulkripalani http:/

Re: CXF Bean, MultiPart -> Couldn't find MIME boundary

2013-04-18 Thread Raul Kripalani
You'd drop Jetty and use a Camel CXFRS consumer endpoint instead. Its usage is documented in http://camel.apache.org/cxfrs.html. Please take a look there first. Worse comes to worst, if this approach doesn't work for you, given your constraints with such old versions, I'd propose to switch back to

Re: How to unmarshal a XML String to java object for properties without required annotation

2013-04-18 Thread crmanoj
Thank you Christian for replying! Here goes the details Camel version 2.9, JDK:1.6.0_39. We use the maven plugin 'cxf-codegen-plugin' version: 2.4.3 to generate java class from WSDL. We run the camel routes in Fuse ESB 7.1. We use ObjectFactory generated from the plugin. Here is the dataformat

String to byte array TypeConverter uses hbase.util.Bytes?

2013-04-18 Thread ekeeton
I'm getting ClassNotFoundException: org.apache.hadoop.hbase.util.Bytes. I'm not using Hadoop or HBase. Camel is embedded in a standalone app in Windows XP. I see the hbase TypeConverter in the TypeConverterRegistry, but if this is the default type converter for String to byte[], why the ClassNo

Re: Bindy fixed length

2013-04-18 Thread Magnus Palmér
It should work, but it doesn't for me. Seems like the BindyFixedLengthFactory does properly notice that I have linked two fields in the middle of my record when it builds the model, but when it does the parsing (unmarshalling) it tries to read all the fields from the main record and not properly t

Re: FTP Concurrency - Single threaded or not

2013-04-18 Thread Christian Müller
The route execution in this case is only single threaded until it comes to the "threads(3)" point. Afterwards you have three threads where each is processing one file. And I cannot tell you what's wrong in your setup because you didn't share the important parts. At [1] we mention what kind of info

RE: CXF Bean, MultiPart -> Couldn't find MIME boundary

2013-04-18 Thread Calvert, Zach (Zach)** CTR **
I think I misread your reply on my first round. If I pulled the SimpleCxfRsBinding into 2.6.0, not the whole 2.11 jar, what would my camel route look like to make use of it including the port? Would I still be using jetty or configuring a cxfRsBinding in XML/cfg? Thanks again! -Origina

RE: CXF Bean, MultiPart -> Couldn't find MIME boundary

2013-04-18 Thread Calvert, Zach (Zach)** CTR **
For the moment I'm stuck way back in time on Camel 2.6.0. My greatest current concern is that this is a bug, not easily patched, that is been fixed and unavailable to 2.6.0. I spent an hour digging through CXF and Camel JIRA tickets to see if I could find the right fix/patch. My CXF search yi

Re: CXF Bean, MultiPart -> Couldn't find MIME boundary

2013-04-18 Thread Raul Kripalani
Why don't you use the CXFRS endpoint directly, instead of bridging over through Jetty? Something's probably going haywire with the combination of Jetty, CXF bean and Multiparts... Note there's a new SimpleCxfRsBinding in 2.11 [1], which you can use in older versions by copying the class into your

Re: How to unmarshal a XML String to java object for properties without required annotation

2013-04-18 Thread Christian Müller
It works for us in many many projects we build. It must be something wrong in your code/configuration. As we mentioned at [1], you should provide some more detail if you are looking for help: What Camel Version do you use? JDK version? and also: Did you annotate your Java class by hand or did you

RE: CXF Bean, MultiPart -> Couldn't find MIME boundary

2013-04-18 Thread Calvert, Zach (Zach)** CTR **
Hello Christian, Thank you for your help. Unfortunately that didn't change the outcome. The AttachmentDeserializer class's "readTillFirstBoundary" still exits upon the first read due to a -1 from the first read of the IO stream. I have tried FireFox, Chrome, and IE. Any other ideas? Could i

How to unmarshal a XML String to java object for properties without required annotation

2013-04-18 Thread crmanoj
Hi, I am trying to convert a XML string to Java object using JAXB dataformat. I face an issue that the output of the unmarshaller is missing the properties which are not annotation as 'required. Here is the XML string before unmarshalling

Re: Create a Simple CXF - Http Route

2013-04-18 Thread Chubutin
I resolved the route problem. This is my CamelContext http://service.esb.tecplata.com/"; /> http://localhost:80/vessel_visitors.xml"; /> The route i

Re: Create a Simple CXF - Http Route

2013-04-18 Thread Chubutin
I resolved putting direct in the *to* route. So, my route is now http://localhost/vessel_visitors.xml"; /> Thank you! -- View this message in context: http://camel.465427.n5.nabble.com/Create-a-Simple-CXF-

Re: How to set a custom ExceptionHandler to a consumer

2013-04-18 Thread fbarbat
Hi Valerian, I was talking about org.apache.camel.spi.ExceptionHandler. As far as I know, OnException does not catch exceptions thrown inside the consumer such as java.nio.channels.ClosedChannelException. Any ideas? Thanks. -- View this message in context: http://camel.465427.n5.nabble.com

Re: How to set a custom ExceptionHandler to a consumer

2013-04-18 Thread valerian.merkling
from("netty:tcp:...").onException(MyEx).dosomethings.end().transform(constant("hello")); http://camel.apache.org/exception-clause.html -- View this message in context: http://camel.465427.n5.nabble.com/How-to-set-a-custom-ExceptionHandler-to-a-consumer-tp5731097p5731098.html Sent from the Cam

How to set a custom ExceptionHandler to a consumer

2013-04-18 Thread fbarbat
Hi, I have a route definition like this: from("netty:tcp:...").transform(constant("hello")); How can I set a custom ExceptionHandler to the netty consumer created from that route? Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-set-a-custom-ExceptionHandler

Re: log4j not writing to log file

2013-04-18 Thread ronithomas
Thanks a lot. I was also facing same issue -Dlog4j.debug really helped to find if the correct log4j file is getting loaded. I had a classpath issue -- View this message in context: http://camel.465427.n5.nabble.com/log4j-not-writing-to-log-file-tp2838161p5731094.html Sent from the Camel - Users

Re: consumer.bridgeErrorHandler=true on netty uri

2013-04-18 Thread fbarbat
Ok, I guess it's not supported then. I find it by looking the source. As I said, NettyConsumer extends DefaultConsumer and DefaultConsumer has that feature. -- View this message in context: http://camel.465427.n5.nabble.com/consumer-bridgeErrorHandler-true-on-netty-uri-tp5731038p5731095.html Se

Re: How to set mock for inner route?

2013-04-18 Thread Raul Kripalani
Could you post the stacktrace, please? *Raúl Kripalani* Enterprise Architect, Open Source Integration specialist, Program Manager | Apache Camel Committer http://about.me/raulkripalani | http://www.linkedin.com/in/raulkripalani http://blog.raulkr.net | twitter: @raulvk On Thu, Apr 18, 2013 at 4:3

Re: Bindy fixed length

2013-04-18 Thread fbarbat
I tried it but I couldn't make it work. It says @Link is for @CsvRecord. Should it work on @FixedLengthRecord too? -- View this message in context: http://camel.465427.n5.nabble.com/Bindy-fixed-length-tp5730980p5731093.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to set mock for inner route?

2013-04-18 Thread horyna
Ok, i gave the secont route routeId(route2ID) and replace: getCamelContext().getRouteDefinition('route2ID').adviceWith(getCamelContext(), new AdviceWithRouteBuilder() { @Override public void configure() throws Exception { weaveById("httpToID").replace().

Re: Issue in Calling REST web service through Camel

2013-04-18 Thread Sergey Beryozkin
Hi This issue looks similar to the one reported recently, but in this case it is quite obvious that CXF JAX-RS runtime gets the wrong portion of the Request URI, specifically, the root resource can match "myservice/users" but what it gets is "cxf-rest-example/myservice/users", which also incl

Create a Simple CXF - Http Route

2013-04-18 Thread Chubutin
Hi, im trying to register a Camel route in Servicemix 4.x. This route is a cxf consumer, xslt and a provider HTTP. I erase the xslt endpoint to avoid any conflicts because that is not relevant. I dont know what is wrong in the xml declaration. http://service.esb.com/"; />

FTP Concurrency - Single threaded or not

2013-04-18 Thread AbhishekSamuel
Hi, Am aware that the ftp component does not support concurrency, that is multiple files cannot be downloaded at the same time, as it is single threaded. So does adding the threads method after the ftp comonent have no effect ? For example while configuring a route like below from(ftp Source).ro

Re: MinaUdpProtocolCodecFactory

2013-04-18 Thread Thomas Termin
Hi Claus, yeah it is the camel-mina. Sorry. We could make this configurable within the camel uri. Something like encode=raw or whatever. Let me know if I should provide a fix/patch or whatever. Cheers, Thomas On Thu, Apr 18, 2013 at 3:29 PM, Claus Ibsen wrote: > Hi > > Yeah it should probabl

How to set mock for inner route?

2013-04-18 Thread horyna
Hello, have a route: from('direct:start').routeId(route1ID).to(direct:anotherRoute) from('direct:anotherRoute').to('http://...').id('httpToID').unmarshall Making test who calls route1ID route and will to replace httpToID route. How to do this? Code below dont work :( getCamelContext().getRouteDe

Re: Setup of JMS message listener invoker failed

2013-04-18 Thread Claus Ibsen
Hi There must be more in the stacktrace that may hint what is a problem. On Thu, Apr 18, 2013 at 4:12 PM, Kesireddy, Chandana (ITD) wrote: > Hi, > > I am using camel 2.6. I have a route which is configured to listen to topic. > > When I run the route its starting fine, but it is not consuming t

Re: File and FTP Components

2013-04-18 Thread Claus Ibsen
See the @dev forum for activity on the 2.11 release. On Thu, Apr 18, 2013 at 4:45 PM, AbhishekSamuel wrote: > Hey, > > Any update on version 2.11 ? Has it been officially released yet ? > > Thanks > Abhishek Samuel > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Fi

RE: JMS Request/Reply

2013-04-18 Thread f.pascal
Hello Claus, We have put stacktrace when camel create, start or stop a JmsProducer for understand what’s append. Attached, I put the logs files and we can to see than camel recreate the JmsProducer 20 hours after camel was started but we don't understand why. Any idea ? Best regards François

Issue in Calling REST web service through Camel

2013-04-18 Thread abhi
Hi, I have written CXF REST web service which I am calling through my camel route as follows / http://camel.apache.org/schema/spring";> http://localhost:8080/cxf-rest-example/myservice/users"; /> / these are 2 different project

RE: JMS Request/Reply

2013-04-18 Thread f.pascal
Claus, Some precision, we don’t have this problem with ActiveMQ, only with MQSeries. The difference it's that we use a custom DestinationResolver with MQSeries for set clientTarget option like it's written in the camel documentation. Our custom DestinationResolver : package fr.pwgroup.camel.

Re: File and FTP Components

2013-04-18 Thread AbhishekSamuel
Hey, Any update on version 2.11 ? Has it been officially released yet ? Thanks Abhishek Samuel -- View this message in context: http://camel.465427.n5.nabble.com/File-and-FTP-Components-tp5730723p5731083.html Sent from the Camel - Users mailing list archive at Nabble.com.

Camel cxfEndpoint testing guidelines

2013-04-18 Thread ddewaele
I wanted to verify if the approach below is the correct one regarding Camel cxfEndpoint usage and testability. I have a camelRoute using an cxfEndpoint (payload dataformat) to consume webservice messages. http://localhost:9080/app/webservices/service1"; endpointN

Setup of JMS message listener invoker failed

2013-04-18 Thread Kesireddy, Chandana (ITD)
Hi, I am using camel 2.6. I have a route which is configured to listen to topic. When I run the route its starting fine, but it is not consuming the message from the topic and giving the WARN: 2013-04-18 10:10:45,104|[aultMessageListenerContainer-1] efaultMessageListenerContainer WARN Setup o

Exchange.isTransacted, splitter and direct

2013-04-18 Thread Fladnag
Hi, The fuse documentation said that we can break a transacted route into fragment with direct component : http://fusesource.com/docs/router/2.8/transactions/TxnDemarcation-ByMarking.html#TxnDemarcation-ByMarking-BreakingARoute but the Exchange.isTransacted() method does not return the same result

Re: MinaUdpProtocolCodecFactory

2013-04-18 Thread Claus Ibsen
Hi Yeah it should probably be byte[] instead of a String. And I assume you refer to camel-mina ? On Thu, Apr 18, 2013 at 1:35 PM, Thomas Termin wrote: > Hello, > > is there a special reason, that the MinaUdpProtocolCodecFactory encode > method always try to convert the message body to a string?

Re: Aggregator and closeCorrelationKeyOnCompletion

2013-04-18 Thread Claus Ibsen
The key is only being added as closed when the aggreaged exchange has been completed. So if the strategy throws an exception then its not completed yet. On Thu, Apr 18, 2013 at 12:25 PM, Sven Bauhan wrote: > Hi, > > I use an aggregator to combine segmented messages (as the channel has > limited s

Re: DeadLetterChanel does not handle exception.

2013-04-18 Thread aram
Change. But same result. -- View this message in context: http://camel.465427.n5.nabble.com/DeadLetterChanel-does-not-handle-exception-tp5731073p5731075.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: DeadLetterChanel does not handle exception.

2013-04-18 Thread Claus Ibsen
Hi You should configure the 2nd route to also use the DL error handler. On Thu, Apr 18, 2013 at 2:38 PM, aram wrote: > Hello.I have some problem with using DeadLetterChannel. Here is an example of > routes that shows the issue: > > // configured error handler > useOriginalMessage="true" >

DeadLetterChanel does not handle exception.

2013-04-18 Thread aram
Hello.I have some problem with using DeadLetterChannel. Here is an example of routes that shows the issue: // configured error handler //producer route //consuming route with exception java.io.IOException

Re: Proxy setting for rss feed

2013-04-18 Thread uzairkamal
Sorry this was a vey bad question to post for camel. Figured it out via java system object. -- View this message in context: http://camel.465427.n5.nabble.com/Proxy-setting-for-rss-feed-tp5731065p5731072.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to enable thread pool for Mina Endpoint (consumer)

2013-04-18 Thread Claus Ibsen
You cannot configure this in camel-mina. Its using thread pools as recommended by mina project final int processorCount = Runtime.getRuntime().availableProcessors() + 1; ExecutorService acceptorPool = getCamelContext().getExecutorServiceManager().newCachedThreadPool(this, "MinaSoc

MinaUdpProtocolCodecFactory

2013-04-18 Thread Thomas Termin
Hello, is there a special reason, that the MinaUdpProtocolCodecFactory encode method always try to convert the message body to a string? Is there a way to avoid the conversion to a String? I would need the falilback method which is a conversion to a ByteBuffer. It would be nice to have that config

Re: HTTP with Jetty as consumer with Client Cert Authenticator

2013-04-18 Thread Claus Ibsen
Hi I assume you have seen the SSL docs at http://camel.apache.org/jetty And this page also http://camel.apache.org/security.html And you can dive into the unit tests of camel-jetty as well, as there should be some with SSL https://svn.apache.org/repos/asf/camel/trunk/components/camel-jetty/ On

Aggregator and closeCorrelationKeyOnCompletion

2013-04-18 Thread Sven Bauhan
Hi, I use an aggregator to combine segmented messages (as the channel has limited size). For each received segment a response message is expected with the appropriate response status. As correlation key the message ID is used; and each segment has a segment number. When a complete message is

Re: cxf producer needs a break?

2013-04-18 Thread Smith-John
Yeah I know. But this doesn't fix the problem. -- View this message in context: http://camel.465427.n5.nabble.com/cxf-producer-needs-a-break-tp5730612p5731067.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: HTTP with Jetty as consumer with Client Cert Authenticator

2013-04-18 Thread Laurentiu Trica
Hi, I think I didn't make myself very clear. I want to bind/expose an HTTP endpoint via a HTTP server as input to a camel route and a possible client to be able to connect to "me" via SSL and should be authenticated by a certificate. I have the client's certificate. Is there a quick and easy way

Proxy setting for rss feed

2013-04-18 Thread uzairkamal
Hi I am using network where proxy is configured, i want to use rss-connector for that. following is the code, please tell me how to put proxy in there try { from("rss:http://mcs.geo.tv/GeoUrdu/headline.xml";).to("direct:simple-rss-send")

Re: receive message from Rest webservice

2013-04-18 Thread Sergey Beryozkin
Hi, that should actually work... Cab you give me a favor and attach your test project to JIRA ? I'll have a look Thanks, Sergey On 17/04/13 23:12, takidean wrote: hi i use to send message from Rest web service but i get this problem qtp18105374-27] JAXRSUtils

Re: Calling WebService with Camel

2013-04-18 Thread valerian.merkling
What about this ? http://camel.465427.n5.nabble.com/How-can-I-call-a-web-service-with-no-parameters-via-a-producerTemplate-td4806257.html -- View this message in context: http://camel.465427.n5.nabble.com/Calling-WebService-with-Camel-tp5731026p5731063.html Sent from the Camel - Users mailing

Re: How to enable thread pool for Mina Endpoint (consumer)

2013-04-18 Thread Hema T
We are using Camel 2.8.1 and Camel-mina. Thanks, Hema -- View this message in context: http://camel.465427.n5.nabble.com/How-to-enable-thread-pool-for-Mina-Endpoint-consumer-tp5731059p5731062.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to enable thread pool for Mina Endpoint (consumer)

2013-04-18 Thread Claus Ibsen
Hi What version of Camel do you use? And is it camel-mina or camel-mina2? On Thu, Apr 18, 2013 at 10:50 AM, Hema T wrote: > I have a Mina Endpoint where I receive xml messages. I guess the default > thread pool size is 10. I need to increase the thread pool size to 30. How > can I increase the p

Re: Giving Processors meaningful names

2013-04-18 Thread Okello Nelson
Hi Claus, Thanks a lot. I use Java DSL. Kind Regards, Okello Nelson. On Thu, Apr 18, 2013 at 11:16 AM, Claus Ibsen wrote: > Hi > > Yeah give them an id in the routes, then that is used in JMX > > > > If you use Java DSL then there is a .id you can use > > .process(new MyProcessor).id("dudeTh

How to enable thread pool for Mina Endpoint (consumer)

2013-04-18 Thread Hema T
I have a Mina Endpoint where I receive xml messages. I guess the default thread pool size is 10. I need to increase the thread pool size to 30. How can I increase the pool size. I tried producerPoolSize, corePoolSize, maximumPoolSize parameters. But I'm getting "Invalid Parameter" error. Can anybod

Re: Giving Processors meaningful names

2013-04-18 Thread Claus Ibsen
Hi Yeah give them an id in the routes, then that is used in JMX If you use Java DSL then there is a .id you can use .process(new MyProcessor).id("dudeThisIsMyName") And for naming the route, you must use .routeId for that. On Thu, Apr 18, 2013 at 10:14 AM, Okello Nelson wrote: > Hi Guys,

Re: CronScheduledRoutePolicy example

2013-04-18 Thread pokkie
Thanks Magnus. All sorted now :) -- View this message in context: http://camel.465427.n5.nabble.com/CronScheduledRoutePolicy-example-tp5730978p5731055.html Sent from the Camel - Users mailing list archive at Nabble.com.

Giving Processors meaningful names

2013-04-18 Thread Okello Nelson
Hi Guys, I'm trying to debug my application in jConsole. The processors are just named 'processo1', 'processor2', etc. Is there a way to give a processor a meaningful name, the same way we do with 'routeId'? I've written some custom processors (custom MBean) to collect statistics, but I can't see