[Splitter] Problem with stopOnException when using threadPoolExecutor

Hi, I'm working with a little proof of concept because I'm having trouble managing exceptions in splitter when I combine stopOnException and the usage of a threadPoolExecutor. I have been working with documentation, and Camel In Action book and source examples but I'm not able to solve this. My

Re: [Splitter] Problem with stopOnException when using threadPoolExecutor

When you use a thread pool then paralllel work happens and the order they are processed can be anyhow the JDK thread pool executes them. If you are not using thread pool then the order is sequential and only 1 work at a time. So with thread pool and stop on exception then the JDK may have already

Re: CookieStore

Hi Claus, thank for your feedback. I've currently override the CookieStore with a noop store. I'll have a deeper look and give you an update or a patch I've I manage to create something :) Cheers Markus 2013/8/19 Claus Ibsen : > I dont think this is supported. Feel free to dive into to see what

Re: [Splitter] Problem with stopOnException when using threadPoolExecutor

Hi Claus, Thank you for your response, it makes sense. I suppose than then the right way to go would be use the aggregationStrategy to propagate back the exception. As in this case I have the same behaviour and only for checking: threadPool shouldn´t interfere in this case, right? Thanks. --

Re: [Splitter] Problem with stopOnException when using threadPoolExecutor

Yeah the aggregate method in AggregationStrategy is thread-safe, and its also invoked in the "order", eg first splitted message, 2nd splitted message, ... N splitted message. Though stop on exception can still make a little sense if the data you split is bigger than the thread pool size + queue si

Re: How to add Vendor Specific Optional Parameter in CamelSmppOptionalParameters

Yes, you have to create a different account [1]. Afterwards you can create an enhancement request at [2]. And as you may know, we love contributions [3]. Feel free to attach your proposed solution which should include unit tests. And helping out with the documentation is also welcome [4]. [1] http

Re: Getting a Header property on a exception in the DSL

barthorre, First, thanks for replying and second, I do that all the time too!!! However, in this particular it does not work. Look at the code, I am passing it when throwing the exception, it is not in the regular DSL where simple will just work. You can try it and you will see. What comes

Re: Apply change to a route after loading camelcontext xml using GenericApplicationContext

Hi Claus, thanks for your reply! So do think whether there is way to set the autoStartup property to a route before the spring code starts the Camel, if I don't want to change the existing camelcontext.xml. Thanks again! -- View this message in context: http://camel.465427.n5.nabble.com/Appl

JSSE for CXF Endpoint

Hi I went through Camel configuration utilities documentation, It is mentioned that it is directly supported in some components. Which I am able to understand. http://camel.apache.org/camel-configuration-utilities.html Also It is mentioned that it is indirectly supported in CXF and HTTP compon

Re: Apply change to a route after loading camelcontext xml using GenericApplicationContext

You can use property placeholders for the auto startup option, then you can control it using that way. And dont have to change the XML. On Tue, Aug 20, 2013 at 3:41 PM, bonnahu wrote: > Hi Claus, thanks for your reply! So do think whether there is way to set the > autoStartup property to a route

Netty UDP and SNMP

I am trying to develop a program that receives SNMP messages over UDP port 161. I have set up a Netty endpoint listening on port 161: from("netty:udp://127.0.0.1:161?sync=false") .log("NETTY") When I run this, I never receive any data even though wireshark shows packets coming in. I have tried

Re: Why can not get the data

camel route:from(" http://localhost:8080/wms/ query_all_handlover_note?type=source ").to("file:d:/temp/outbox?fileName=data1.txt") -- View this message in context: http://camel.465427.n5.

Issues with Camel startup...

Hi, We are using Camel 2.9 in our application. The role of which is to read the message from one end point and pass it to another endpoint which is a POJO which takes care of processing the message. We use Spring xml based configuration to define the JNDITemplate and endpoints and things worke

Re: Issues with Camel startup...

Hi Please do not cross post the same message to many mailing lists. The correct mailinglists for getting help with Camel is the user mailinglist. Also please do not mail the Camel team directly. Apache Camel is an open project and all discussions should happen in the open so everyone can see / pa

Re: Getting a Header property on a exception in the DSL

This is not possible as you use the new constructor in Java that will instantiate the exception once. What you want is to create a new exception when it happens with data from the message. For that you can call a method and let it throw the exception. For throwException to work with your use case

Re: Load test on camel-netty

I would suggest to remove the 100 thread pool sizes as the out of the box settings from Netty is better. Netty is asynchronous and it creates thread pools based on the number of CPU cores etc. Netty creates the threads up-front so having 100+ threads take up some unnecessary memory. On Tue, Aug

Re: Netty UDP and SNMP

Can you try with 2.12 SNAPSHOT and use the networkInterface to specify the network interface to join the existing multicast group. See the page about the option. http://camel.apache.org/netty On Tue, Aug 20, 2013 at 4:40 PM, Tyler Durvik wrote: > I am trying to develop a program that receives SN

Re: Spring Bean represented as endpoint

What version of Camel do you use? On Fri, Aug 16, 2013 at 10:35 PM, MichaelAtSAG wrote: > All, > I am trying to move endpoint properties into a bean, yet the endpoint is not > working this way. I think it is a simple typo but can't find it: > > > THIS WORKS > > > > >

Field support for OGNL/simple

The camel documentation for the simple component shows that it doesn't support fields except in 2.11 onwards for the .length in java arrays. Are fields expected to be added in the future? If not can you tell the simple component to provide a custom getter class for the object? For example (psuedo

Re: MTOM message part not formatted correctly according to RFC 1341 using CRLFLF instead of CRLFCRLF

This bug is fixed in CXF-4482!+ -- View this message in context: http://camel.465427.n5.nabble.com/MTOM-message-part-not-formatted-correctly-according-to-RFC-1341-using-CRLFLF-instead-of-CRLFCRLF-tp5737366p5737610.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Getting a Header property on a exception in the DSL

Thanks Claus...I can find many ways around it, I was just wondering if there was something I was missing or doing wrong...What you are saying makes sense and I don't think we need to add that at this point. On Tue, Aug 20, 2013 at 10:59 AM, Claus Ibsen-2 [via Camel] < ml-node+s465427n5737601...@n

Re: Spring Bean represented as endpoint

Apache Camel 2.11.0 -- View this message in context: http://camel.465427.n5.nabble.com/Spring-Bean-represented-as-endpoint-tp5737433p5737614.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Apply change to a route after loading camelcontext xml using GenericApplicationContext

Hi Claus, If I understand correctly, you are saying adding a property placeholders for the auto startup option, http://camel.apache.org/schema/spring"/> In autostartup.properties, define autostartupOption = true/false Then in the route, add the autoStartup property like followings? -

Re: Apply change to a route after loading camelcontext xml using GenericApplicationContext

Yep, that should work :) On Tue, Aug 20, 2013 at 10:26 AM, bonnahu wrote: > Hi Claus, > If I understand correctly, you are saying adding a property placeholders > for > the auto startup option, > > location="autostartup.properties" > xmlns="http://camel.apache.org/

Re: Mina Synchronous Communication

I am currently using Mina2 V2.11.1. My decoder looks like @Override protected boolean doDecode(IoSession is, IoBuffer ib, ProtocolDecoderOutput pdo) throws Exception { int headerSize=28; byte[] header = new byte[headerSize]; byte[] xmlBuffer = null; byte[]

AMQ DeadLetterStrategy Not Being Respected

I'm using the standard activemq-broker.xml which comes pre-installed with Fuse with a slight change. I have added a deadLetterStrategy for Topics and Queues as indicated by this page http://activemq.apache.org/message-redelivery-and-dlq-handling.html

RE: Load test on camel-netty

Claus, Thanks for your answer, we have done that and nothing changes. Flavio Magacho Gerente de Desenvolvimento Diretoria de Tecnologia da Informação   M4U +55 (21) 2546-4050 ▪ Ramal: 4082 +55 (21) 8889-1572  Antes de imprimir, pense em sua responsabilidade e compromisso com o Meio Ambiente. O

RE: Load test on camel-netty

If Oracle/Sun JDK is in use then maybe ask for a heap dump as the OutOfMemoryError happens: http://docs.oracle.com/cd/E15289_01/doc.40/e15062/optionxx.htm#BABBBEAJ Then you could analyze the dump (e.g. using http://www.eclipse.org/mat/) to see where that huge memory consumption or the leak (if an

RE: Load test on camel-netty

Thank you Vahdat, we will check this out! Flavio Magacho Gerente de Desenvolvimento Diretoria de Tecnologia da Informação   M4U +55 (21) 2546-4050 ▪ Ramal: 4082 +55 (21) 8889-1572  Antes de imprimir, pense em sua responsabilidade e compromisso com o Meio Ambiente. O conteúdo desta mensagem é con

Solace Integration with Camel

Hi, Can you please advise if Camel based Routes can be integrated with Solace channels? Any samples on TIBCO EMS or Solace channels help us a lot. Thanks Ganesh ___ This message is for information purposes only, it is not a recommendation, advice, o

stream result of iterator to a file

I have two questions: I would like to stream the result of an iterator to a file. I succeeded in doing that using a split with a factory class that creates my iterator. The name of the file is set dynamically in the header of the exchange. So far I have no problem at all. But I also want to write

Re: AMQ DeadLetterStrategy Not Being Respected

You should may ask this on the ActiveMQ user mailing list... Best, Christian Am 20.08.2013 20:02 schrieb "nezor" : > I'm using the standard activemq-broker.xml which comes pre-installed with > Fuse with a slight change. I have added a deadLetterStrategy for Topics and > Queues as indicated by thi

Re: Apply change to a route after loading camelcontext xml using GenericApplicationContext

thanks -- View this message in context: http://camel.465427.n5.nabble.com/Apply-change-to-a-route-after-loading-camelcontext-xml-using-GenericApplicationContext-tp5737541p5737628.html Sent from the Camel - Users mailing list archive at Nabble.com.

reading integer values from properties file

Hi I am using Camel API "propertyPlaceholder" to access my properties. All the String values are resolved without any issues. Can you please provide any insight on reading integer values? Camel Version = 2.4 *Configuration:* ... *params.properties* maxRetries.DEV = 10 *Exception:* org.

Re: Solace Integration with Camel

Hi, I think you can write a component[1] to do this kind of job. [1]http://camel.apache.org/component.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.

Re: Mina Synchronous Communication

From the stack trace, it looks like the decoder cannot interpret the data length rightly. Can you double check it with your application? -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http:

Re: Spring Bean represented as endpoint

I think you need to setup the CamelContext on the appWebSocket bean. BTW, what's the exception that you get when using the appWebSocket. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http://

Re: Issues with Camel startup...

Did you try to use JConsole to look up the status of camel routes[1]? From your description I double if the camel-jms can access the JMS broker rightly. [1]http://camel.apache.org/camel-jmx.html -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (

Re: reading integer values from properties file

Can you try it with the latest Camel? As you know you don't provide community support for very old version of Camel. -- 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

Time to deliver a message?

Hi, Assuming that I'm using activemq queues as my components, how quickly should a message be delivered? In a number of routes, I'm moving data from one queue to another queue, and over time the amount of time that it takes for a message to go from A to B to C is steadily increasing. Is this exp

Re: How to add Vendor Specific Optional Parameter in CamelSmppOptionalParameters

Hi Christ, Jira created. #CAMEL-6655. I think I have messed up the code in my last post and revised the method as below. Kindly check and advise if this can work. /* Since it is vendor specified, so users must have the code and type, therefore users should concatenate these infor

RE: Load test on camel-netty

Aha I just tried it out by myself both on Java 6 & Java 7 of Oracle JRE and the right option being still supported is: -XX:+HeapDumpOnOutOfMemoryError And not: -XX:+HeapDiagnosticsOnOutOfMemoryError which used to be for the Oracle JRockit JVM. Babak flavio.magacho wrote > Thank you Vah

Re: Can't find the BindingOperationInfo with operation name

I'm sorry for the delay in replying. After further investigation it seems that scalaxb is not a good choice for code generation from wsdl, so I've switched over to using CXF code generation to java, and that seems to work fine. Thanks! -- View this message in context: http://camel.465427.n5.nab