Re: A High Level Data Translation Question

2011-11-22 Thread Claus Ibsen
On Mon, Nov 21, 2011 at 5:36 PM, Castyn eric.ben...@gmail.com wrote: I created a custom processor per the links posted previously.  Once in a custom processor, is there a way to marshal the message into java objects? Its Java. So whatever you can do with Java you can do there. If you have

Re: Custom Processor with XPath

2011-11-22 Thread Claus Ibsen
Hi If you use getMandatoryBody then Camel will throw an exception if it cannot convert to the given type. On Mon, Nov 21, 2011 at 10:21 PM, Castyn eric.ben...@gmail.com wrote: I am attempting to convert a SOAP message from one message format to another, and along the way calculating and

Re: How to reset the body content before routing to next endpoint

2011-11-22 Thread Claus Ibsen
Hi The file/ftp components offer options to move files to a error / success folder out of the box. So you do not need to do this with extra routes. The ftp component http://camel.apache.org/ftp2 Has 99% of the options from the file component http://camel.apache.org/file2 See the options - move

RE: converting form JAVA DSL to Spring DSL

2011-11-22 Thread bvahdat
@Omar IMHO eclipse *does* support XML, pretty while ago Jon Anstey (coauther of the Camel in Action book) also created camel specific templates for it, look at [1] for details but be aware that the provided links there are outdated. You find the up-to-date version of them at [2]. Here's how my

Re: Too many OnCompletion threads

2011-11-22 Thread Claus Ibsen
Hi Can you post an example of a route which has the OnCompletion? Just to be sure what you talk about, eg are you using onCompletion or something else? 2011/11/22 Zhemzhitsky Sergey sergey_zhemzhit...@troika.ru: Hi there, I’m using camel 2.6.0 within servicemix and have about 50 camel

Re: Topic consume with polling (connection, thread) Need exmple

2011-11-22 Thread cbenaveen
bvahdat, Thanks for the pointer. More than consuming i need example on how to reuse the connections, sessions. are there any example which show me how to do connection pooling for a Topic Consumer. By the way i did subscribed to the mailing list. -- View this message in context:

Topic consume with polling (connection, thread) Need exmple

2011-11-22 Thread cbenaveen
Hi All, Can some body point me a good example of using camel to consume Topic message from ActiveMQ? Primarily i need to implement the connection/thread/session pooling while consuming message. Thanks -- View this message in context:

Re: Topic consume with polling (connection, thread) Need exmple

2011-11-22 Thread Claus Ibsen
Hi See Torstens blog http://tmielke.blogspot.com/2011/11/consuming-topic-messages-in-spring-and.html He has other great posts on AMQ / Camel etc. On Tue, Nov 22, 2011 at 9:27 AM, cbenaveen cbenav...@gmail.com wrote: Hi All, Can some body point me a good example of using camel to consume

Re: Topic consume with polling (connection, thread) Need exmple

2011-11-22 Thread bvahdat
You could also check the section 'Working with Spring's JmsTemplate' in [1]: The PooledConnectionFactory supports the pooling of Connection, Session and MessageProducer instances so it can be used with tools like Camel and Spring's JmsTemplate and MessagListenerContainer . Connections, sessions

Re: Camle ActiveMQ connection polling and threading issue

2011-11-22 Thread Ioannis Canellos
If I remember correctly you can use a * wildchar in order to avoid looping and creating so many routes: from(CamelConnectionIssue.CONNECTION_NAME + :topic:com.cisco.camel.test.subject.*).to(bean:cBean?method=receiveMessages); In your case I am not sure if this will be enough, but its a great

Re: Camle ActiveMQ connection polling and threading issue

2011-11-22 Thread bvahdat
Hi, when you start your POC client do you rely on the default initial/maximal heap size of the VM or do you explicitly specify some values with the -Xms -Xmx options? As the load you mentioned in your case could be effectively high I could imagine that specifiying those VM-bootstrap parameters

Re: Camle ActiveMQ connection polling and threading issue

2011-11-22 Thread cbenaveen
bvahdat, I did have the -Xmx1024m, but the -Xms set to 512m. Yes your assumption is correct. -- View this message in context: http://camel.465427.n5.nabble.com/Camle-ActiveMQ-connection-polling-and-threading-issue-tp5012594p5013150.html Sent from the Camel - Users mailing list archive at

Re: Camle ActiveMQ connection polling and threading issue

2011-11-22 Thread bvahdat
Do you mind to give a try with the same 1024m value, AFAIK on a 32 bit box you could go up to 4GB but not higher (that's 2^32 possbile memory addresses). Another possbile customization could be also to (carefully) decrease the default stack size using the -Xss option in the favour of the heap

RE: Too many OnCompletion threads

2011-11-22 Thread Zhemzhitsky Sergey
Hi Claus, You are right, I suppose that all those threads are connected with onCompletion. Here is how my route looks route id=route from uri=direct:start / setProperty propertyName=originalBody simple${body}/simple /setProperty to

errorHandler for activemq component example configuration

2011-11-22 Thread baklarz
I'm tried several configurations. Exceptions inside jms/activemq are completly ignored by camel arror handler. This line in log drives me crazy. 2011-11-22 12:59:11,700 WARN [org.apache.camel.component.jms.JmsMessageListenerContainer] - Execution of JMS message listener failed, and no

Camel CXF Blueprint - GracePeriod WARNING

2011-11-22 Thread Chaks
Hello, Please can someone help me on the Camel CXF Blueprint - GracePeriod warning that I am getting. I am using the below CXF Blueprint, and when I deploy the same in ServiceMix 4.3.0 as a bundle, its not getting started. I can see the following warning in the logs, [ 240] [Active ]

Connecting two CXF endpoints

2011-11-22 Thread Tristan23
Hi there, I'd like to connect two existing Web Services with CXF endpoints with each other. How do I transform the incoming data from one CXF endpoint to the format the other CXF endpoints expects it - and back? A link to an existing example / tutorial would be nice :) cheers, T. -- View this

Re: CXF endpoint and properties

2011-11-22 Thread Willem Jiang
No, it is only supported in Camel 2.9.0. On Tue Nov 22 20:53:38 2011, kafe wrote: Is the same thing possible with camel 2.8.2 ? -- View this message in context: http://camel.465427.n5.nabble.com/CXF-endpoint-and-properties-tp4848384p5013449.html Sent from the Camel - Users mailing list

Re: JMX issue when using Camel in ServiceMix

2011-11-22 Thread Craig Taylor
On Mon, Nov 21, 2011 at 6:26 PM, eliotc eliot.c...@macquarie.com wrote: */service:jmx:rmi:///jndi/rmi://futsydapd03:1099/jmxrmi/* The only thing I CAN do is connect to org.apache.karaf.main.Main when I ran ServiceMix locally (Windows), however, it does not seem to be that useful:

Re: Connecting two CXF endpoints

2011-11-22 Thread Claus Ibsen
Hi There is a little CXF proxy example here http://camel.apache.org/cxf-proxy-example.html It may be a start on the way. On Tue, Nov 22, 2011 at 1:25 PM, Tristan23 tristanlst...@gmail.com wrote: Hi there, I'd like to connect two existing Web Services with CXF endpoints with each other.

Re: errorHandler for activemq component example configuration

2011-11-22 Thread Claus Ibsen
On Tue, Nov 22, 2011 at 1:17 PM, baklarz tdrobiszew...@gmail.com wrote: I'm tried several configurations. Exceptions inside jms/activemq are completly ignored by camel arror handler. This line in log drives me crazy. 2011-11-22 12:59:11,700 WARN

Re: How to remove the path from the idempotent messageid

2011-11-22 Thread gilbertlangevin
Thanks for the fast reply, I will check what I can do. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-remove-the-path-from-the-idempotent-messageid-tp5007718p5013787.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Queue/Dequeue perfomance InOut ExchangePattern

2011-11-22 Thread Claus Ibsen
There is API on CamelContext to create a new consumer template. Then you can create it once, and re-use it. A bit like reusing a producer template as stated in this FAQ http://camel.apache.org/why-does-camel-use-too-many-threads-with-producertemplate.html On Mon, Nov 21, 2011 at 5:38 PM, Carlos

Re: Custom Processor with XPath

2011-11-22 Thread Castyn
Good to know. I have the body properly converting to a Document now. I suppose this may end up more of an XPath question, so I apologize in advance but I have looked everywhere for some complicated examples and haven't had much luck. Let's say this is the document that is coming into my custom

Re: Custom Processor with XPath

2011-11-22 Thread Claus Ibsen
XPath can be painful to get working. Usually when nothing comes out, then its a namespace issue. XPath must have namespaces defined if your XML have namspaces, which you do not have. On Tue, Nov 22, 2011 at 5:02 PM, Castyn eric.ben...@gmail.com wrote: Good to know.  I have the body properly

Re: Too many OnCompletion threads

2011-11-22 Thread Claus Ibsen
Hi The onCompletion supports specifying a executorServiceRef where you can refer to a shared thread pool, which other onCompletion can use as well. Then you can re-use threads from the same thread pool. See details here as well http://camel.apache.org/threading-model.html On Tue, Nov 22, 2011

Re: Custom Processor with XPath

2011-11-22 Thread Castyn
I changed my code to use the NamespaceContext, unfortunately I am still not getting any matches (tried some simpler strings to test as well). Also, it seems that adding this bit of code really slowed down the processor, though it may just be how many times I have deployed / undeployed the bundle

CAMEL is throwing error

2011-11-22 Thread newbiee
I have define the following simple route for testing: camelContext trace=true xmlns=http://camel.apache.org/schema/spring; route from uri=netty:tcp://localhost:8000?sync=true / to uri=jms:fromServerToClient / /route /camelContext I've been trying to run this

Re: CAMEL is throwing error

2011-11-22 Thread Claus Ibsen
Some other service is already using port 8000 on your computer. Try using another port number which is free, or stop that other service. On Tue, Nov 22, 2011 at 7:50 PM, newbiee m_ess...@hotmail.com wrote: I have define the following simple route for testing:  camelContext trace=true

Re: NETTY component for network programming

2011-11-22 Thread newbiee
Hi Iocanel : Thanks for the reply. My route will have to open the connection with digi device and automatically send SSH commands to it by pulling them from the database. Can you provide some hints how can I send SSH commands using camel-exec after establishing connection with the digi device.

Re: CAMEL is throwing error

2011-11-22 Thread newbiee
Claus: Thanks for the reply. As I have mentioned in my question. I have Java Client/Server program which opens the socket conneciont using the same port i.e 8000. I am able to run my java program and pass messages back and forth. When the program is being run I applied the following command

Re: [PROBLEM] GenericFileOperationFailedException: Cannot rename file

2011-11-22 Thread cherry
Hello Groulubao, I am running into the same issue. Since we are using the file component, May i ask how to close the InputStream?? Do you write a custom component to overwrite the behavior?? Thanks! Cheers, Cherry -- View this message in context:

Re: CAMEL is throwing error

2011-11-22 Thread Hadrian Zbarcea
Newbie, that probably means that your program tries to open a socket on the same port twice. But seriously, if you are having trouble with this kind of issues, this is really not the place where you learn how to investigate and resolve them. Cheers, Hadrian On 11/22/2011 02:15 PM, newbiee

Re: CAMEL is throwing error

2011-11-22 Thread newbiee
Hadrian: I have sent my route. Here is the complete XML file ?xml version=1.0 encoding=UTF-8? beans xmlns=http://www.springframework.org/schema/beans; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xmlns:camel=http://camel.apache.org/schema/spring;

Re: CAMEL is throwing error

2011-11-22 Thread Tim
Could it be a stupid error of having localhost:8080 as your brokerURL? Anyways, in the same line as Hadrian's answer. Why not just change 8080 to something else like and give it another try? On Tue, Nov 22, 2011 at 1:55 PM, newbiee m_ess...@hotmail.com wrote: Hadrian: I have sent my

Re: CAMEL is throwing error

2011-11-22 Thread newbiee
Tim Prior to posting this question, I tried it using 9900 port but no luck! -- View this message in context: http://camel.465427.n5.nabble.com/CAMEL-is-throwing-error-tp5014337p5014654.html Sent from the Camel - Users mailing list archive at Nabble.com.

Defining a CXF bus in Blueprint for use with cxfbean endpoint

2011-11-22 Thread Brian Topping
Hi all, I'd like to secure a cxfbean resource using Spring Security and SS authorization annotations. To do so, it appears that it will require adding an interceptor to the CXF endpoint as an element of a bus. So far, I have been trying to do everything in blueprint. But it doesn't appear

Re: CAMEL is throwing error

2011-11-22 Thread Tim
Then I'm inclined to think that Hadrian's suggestion is correct and you are using the same port twice in your program or you are starting up twice for some reason. On Tue, Nov 22, 2011 at 2:38 PM, newbiee m_ess...@hotmail.com wrote: Tim Prior to posting this question, I tried it using 9900

Re: CSV to database

2011-11-22 Thread Christian Müller
Do you mean long (code) or slow (performance)? I would expect something like: from(jpa://XXX) .convertBodyTo(Foo.class) .to(jpa://YYY) or from(jpa://XXX) .process(new MyConverter()) .to(jpa://YYY) or from(jpa://XXX) .to(bean://myConverter?method=convert) .to(jpa://YYY) Right?

IBM WAS - Aries 0.1 and Camel

2011-11-22 Thread mattmadhavan
Hello, I have been struggling with this issue for a while and any help/insights will be greatly appreciated! I'm struck with WAS v7 and hence Aries 0.1. And I want to replace the SCA bindings (IBM's Tuscany) with Camel as it seems to be lot more easy to set up and am awesome product. I have two

Re: Custom Processor with XPath

2011-11-22 Thread Castyn
Figured it out. I had forgotten the @ sign in the xpath string. -- View this message in context: http://camel.465427.n5.nabble.com/Custom-Processor-with-XPath-tp5011728p5014998.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: CSV to database

2011-11-22 Thread Idriss
Hi, I mean with long that is slow. I'm using this : from(jpa://XXX) .process(new MyProcess()) and in the class MyProcess I'm using EntityManagerFactory, EntityManager and TransactionManager (with myTransManager.begin() and myTransManager.commit(), and I think that is the cause of low

Re: CSV to database

2011-11-22 Thread Romain Manni-Bucau
Hi, Do you create an entitymanager factory for each message? - Romain Le 23 nov. 2011 00:40, Idriss doulmakhzo...@gmail.com a écrit : Hi, I mean with long that is slow. I'm using this : from(jpa://XXX) .process(new MyProcess()) and in the class MyProcess I'm using

Re: JMX issue when using Camel in ServiceMix

2011-11-22 Thread eliotc
Hi Craig, Thanks for your reply! The root cause of my problem is that I forgot to put in JMX username and password :-( Cheers, Eliot -- View this message in context: http://camel.465427.n5.nabble.com/JMX-issue-when-using-Camel-in-ServiceMix-tp5009646p5015411.html Sent from the Camel - Users

Re: CAMEL is throwing error

2011-11-22 Thread Taariq Levack
Can you post a running maven project? Taariq On Tue, Nov 22, 2011 at 11:51 PM, Tim che...@gmail.com wrote: Then I'm inclined to think that Hadrian's suggestion is correct and you are using the same port twice in your program or you are starting up twice for some reason. On Tue, Nov 22,

Re: CAMEL is throwing error

2011-11-22 Thread Hadrian Zbarcea
@Taariq, I suspect newbiee modified a sample I put out [1]to help him (hopefully others too). But he did it in mysterious ways. Hadrian [1] https://github.com/hzbarcea/camel-samples/tree/master/camel-digi On 11/22/2011 11:05 PM, Taariq Levack wrote: Can you post a running maven project?

Is RMS faster than JMS?

2011-11-22 Thread KingAndrew
Hi All, I have a client that has an RMI/Corba/IIOP SOA application. For scaleablity I plan on them using Camel/ActiveMQ. Scaling is good but it must be as performant as the current RMI implementations. So my question is: Is RMI inherently faster than JMS? I was thinking that since we won't

RE: Too many OnCompletion threads

2011-11-22 Thread Zhemzhitsky Sergey
Hello Claus, Does it mean that I can export custom ExecutorService as OSGi service and then reuse it across all the camel applications I have? Is that way safe enough to avoid different classloading issues in OSGi environment? Regards, Sergey -Original Message- From: Claus Ibsen

Re: How to write or append content to XML file without XML declaration

2011-11-22 Thread Claus Ibsen
Hi Have you tried using xpath for splitting? camel:split camel:xpath/city/camel:xpth ... /camel:split There is some examples here http://camel.apache.org/splitter http://camel.apache.org/xpath On Tue, Nov 22, 2011 at 11:13 PM, santoshjoshi santoshjoshi2...@gmail.com wrote: Environment