COBOL data parse in Camel

2015-10-06 Thread contactreji
Hello guys Is there any adapters in Camel which can parse the Cobol dataDump and Copybook and transform the file into XML format? I have the copybook ( supposed to be a structure definition for fixed length records ) and another file containing those fixed length delimiter separated data set.

Re: COBOL data parse in Camel

2015-10-06 Thread contactreji
Thanks Charles I initially locked in on the bindy component. But now i see that there are fields in the data and its repitition / cardinality will depend on value of another field. Find a sample of copybook below. You can see that repetitions of REFR-COLR-DETAILS field can vary from 0-100 based

Re: camel-netty: How to set the netty closeChannelTimeMillis option?

2015-10-06 Thread SteveR
On further investigation, I see that the *closeChannelTimeMillis* option is not a *netty *option, but rather an option for com.linkedin.norbert.javacompat.network.NetworkClientConfig

Possible memory leak with .marshal().json() and stream cache enabled

2015-10-06 Thread Quinta
I think I found a memory leak with stream caching enabled and this code: from("file:src/data?noop=true") .split(new ZipSplitter()).streaming().stopOnException() .split().tokenizeXML("Item").streaming().stopOnException() .unmarshal(jaxb)

camel-netty: How to set the netty closeChannelTimeMillis option?

2015-10-06 Thread SteveR
I have a stand-alone Java 1.7 application using *Camel 2.15.2* and the *camel-netty* component which is running on Linux RHEL6. In production, with a camel route that consumes via *netty:udp*, we appear to be facing an issue similar to this old one: ChannelPool closing channels prematurely

Re: COBOL data parse in Camel

2015-10-06 Thread Charles Moulliard
Hi Reji, You can use camel-bindy which support to process fixedlength dataformat ( camel.apache.org/bindy.html) and generate java classes that next you can use with camel-jaxb to transform them into XML. The opposite is also true xml -> java objects -> fixedlength records Regards, On Wed, Oct

Re: MDC information mess up after sent to activemq endpoint

2015-10-06 Thread chiochuan
i do set in the jms header to return the transactionID using interceptSendToEndpoint to activemq:*. but still it didnt seem work. -- View this message in context: http://camel.465427.n5.nabble.com/MDC-information-mess-up-after-sent-to-activemq-endpoint-tp5772230p5772353.html Sent from the

reference resolver for WSDL on CXF Endpoint

2015-10-06 Thread dsjaxen
Hi! I set up a URL Protocol handler to load the wsdl from a database on the CXFEndpoint. cxfEndpoint.setWsdlURL("db:///...") That works fine, but the schema files referenced by the wsdl need to be resolved in the database as well. They are relative imports: http://test.xxx;

osgi bundle dependency

2015-10-06 Thread chiochuan
Hi Guys, I have created 1 bundle as framework for my project and all other bundle are dependency on this bundle. Due to some environment limitation, i was not able to use it as features, so i have to use manual deployment using osgi:install. If i deploy bundle without the framework, it will

Re: Resequencer inout support

2015-10-06 Thread prasadrao82
Hi Claus, Thanks for your valuable information , Now the question is what is alternate for this requirement. Is there any support provided in Camel or do we need to handle manually. Thanks in advance. Regards, Prasad.V -- View this message in context:

Re: Resequencer inout support

2015-10-06 Thread Claus Ibsen
You should not use the resequencer but a seda or some other queues where the messges on the queue has different priorities so consumers of those queues pickup the most important first. notice camel seda does not out of the box have priority support. But the java api has a queue where you can

Re: Start a route based on a specific time everyday , but stop logic is based on ...

2015-10-06 Thread fxthomas
any hints ? -- View this message in context: http://camel.465427.n5.nabble.com/Start-a-route-based-on-a-specific-time-everyday-but-stop-logic-is-based-on-tp5771696p5772320.html Sent from the Camel - Users mailing list archive at Nabble.com.

Problem with custom aggregation/ custom correlation (data base rows)

2015-10-06 Thread dermoritz
I am fetching data from data base (jdbc component) that contains 1:n relations. That means that i have multiple entries with same id: id1,childId1, childFieldValue1, id1,childId2, childFieldValue2, id2,childId3, childFieldValue1, id2,childId4, childFieldValue2, id2,childId5, childFieldValue3,

Re: Problem with custom aggregation/ custom correlation (data base rows)

2015-10-06 Thread Claus Ibsen
In Camel 2.16 there is a preCompletion mode that makes this use-case possible/easier. On Tue, Oct 6, 2015 at 10:52 AM, dermoritz wrote: > I am fetching data from data base (jdbc component) that contains 1:n > relations. That means that i have multiple entries with same id:

Re: Dynamic datasource with Camel 2.15.x

2015-10-06 Thread burner
Hello Joakim, yes, I am use Spring. your Idea look good. But how can I use parameters in your solution? @Configuration public class InfrastructureConfig { String username = ""; String password = ""; String url = ""; @Bean public DataSource dataSource() { String

Error while using parameterized query with mysql using camel

2015-10-06 Thread sankalp
I am not able to use parameterized query with SQL select statement: http://camel.apache.org/schema/spring;>

Re: Dynamic datasource with Camel 2.15.x

2015-10-06 Thread Joakim Bjørnstad
Well now this isn't a Camel question but rather a Spring one. Anyways, I suggest checking out Spring @Value annotation and PropertyPlaceholderConfigurer. With this you can leverage Camel's BridgePropertyPlaceholderConfigurer to configure your routes as well.

Re: Camel Load Balancer EIP with TCP Endpoints

2015-10-06 Thread Cleocleo
Ok, I'm not sure camel is going to solve this problem for you. You could get a physical or software load balancer capable of load balancing the long lived tcp connections. However, transparently switching a server if one server is down seems challenging (without the client knowing). Seems like

Re: aggreagator completion based on correlation key

2015-10-06 Thread dermoritz
thanks, i did this, but it only works in conjunction with ".eagerCheckCompletion()". So in my processor that sets the correlation id i store the last id and if the id changes (the exchange will start a new group) i set an complete header. i will give a complete solution here:

Re: aggreagator completion based on correlation key

2015-10-06 Thread dermoritz
Ok i made some mistakes. The predicate with eagerCheckCompletion isn't working. It is very hard to test stuff that uses timeout (e.g. completion) with the debugger :-P So how to implement completion here? I know that the last group is complete if the correlation key changed. But where/how to

Re: Problem with custom aggregation/ custom correlation (data base rows)

2015-10-06 Thread dermoritz
Thanks to input from here I created a working solution. Please comment if you have suggestion (especially about: is it possible to get rid of the processor thats sets correlation header, is there

Re: Context Component issue

2015-10-06 Thread Aaron Birkland
Hi All, I had some time to dig into this issue, and it appears more severe than I had initially thought. Right now, there is *no* isolation between endpoint names between camel contexts. In fact, using the context component in its current state results brings *local* endpoint names from