Re: NoTypeConversionAvailableException

Hi , Thanks for your help. I can able to see the size of the queue. This is my requirement, i am sending a message to external ActiveMQ broker. I wand to receive the same message from my camel code. Please send the sample code for this. Thanks in advance. Regards, Bharathi S. -- View this m

Re: Camel Velocity Template throwing error

Hi Henryk, I tried JUnit sample to test velocity in camel given by Claus at http://camel.apache.org/velocity.html private Exchange createLetter() { Exchange exchange = context.getEndpoint("direct:a").createExchange(); Message msg = exchange.getIn(); ms

Re: creating routes dynamically

You could use a Dynamic Router: http://camel.apache.org/dynamic-router.html On Thu, Jul 5, 2012 at 11:03 AM, Sri wrote: > Hi, > > I wanted to create routes dynamically based on the msg header I receive and > send msg to that route . > > This routes can grow to thousands over the period of tim

"Could not find conduit initiator for address" using SOAP-JMS

Hi all, I am (attempting) to use SOAP over JMS within Fuse ESB (v4.4.1-fuse-06-03). I have a web service in one bundle that I wish to call from another. The service exposes a simple getAll() method which return a list of Users. I have had the wsdl/Java code running as a conventional web service o

"Could not find conduit initiator for address" using SOAP-JMS

Hi all, I am (attempting) to use SOAP over JMS within Fuse ESB (v4.4.1-fuse-06-03). I have a web service in one bundle that I wish to call from another. The service exposes a simple getAll() method which return a list of Users. I have had the wsdl/Java code running as a conventional web service ov

IdempotentRepository

Hello! I am fetching files from a FTP server (severall GB for the next years). The files are produced daily in directories which correspond to the date, like - 20120501 - 20120502 - ... I have only read rights and I am not the only consumer. This means that they keep the last

Re: Camel 2.10.0 and Bindy/CSV

Ok, thanks. One of the committers (may be me) will have a look on it. Best, Christian On Thu, Jul 5, 2012 at 9:05 PM, Reynald wrote: > Hi Chris, > > Sorry for the delay. > > I just created: > > https://issues.apache.org/jira/browse/CAMEL-5423 > > If you need anything else, let me know. > > tks.

Re: Multiprocessing a single message into multiple messages

Study the following EIP's: - http://camel.apache.org/dynamic-router.html - http://camel.apache.org/recipient-list.html Best, Christian On Thu, Jul 5, 2012 at 11:04 PM, wjmcdonald < william.mcdon...@transcentra.com> wrote: > How do I process a single message with multiple dynamic list of processo

Re: creating routes dynamically

Yeah, reconsider your design. and instead of CamelContext context = new DefaultCamelContext(); the preferred way is CamelContext context = exchange.getContext(); if you use a processor to build your routes dynamically. Best, Christian On Thu, Jul 5, 2012 at 6:31 PM, Henryk Konsek wrote: > H

Re: Testing a Route which de-queues message from Topic in CLIENT_ACKNOWLEDGE mode

You can use the consumer template to consume one message from the queue and check the received exchange is not null. Best, Christian On Thu, Jul 5, 2012 at 4:24 PM, gilboy wrote: > Hi Folks > > It was also unclear to me how to ensure that the message was de-queued or > not. > > Ideally, after s

Re: Is it a good idea to store very large data (100,000 records) in StringBuffer and then write to file using Apache camel's File Component?

Yeah, depends on the line size, your available memory, ... And by the way, you know the file component has a 'append' option? Best, Christian On Thu, Jul 5, 2012 at 4:50 PM, Sam (Stephen Samuel) wrote: > Bit of a vague question. If each record is 1 byte then you have 100k so > yes. If each recor

Re: Help with newline while writing to the file.

It works for me on OSX. You may have to use '\r\n' if your OS in Windows... And by the way, you know you can use System.getProperty("line.separator");... Best, Christian On Thu, Jul 5, 2012 at 4:42 PM, dmhatre wrote: > Hi Folks, >Need help adding newline while writing to the file. > I am wr

Re: Processors in onException block remove message headers in certain cases

I think it's already covered in [1] and fixed in Camel 2.8.5. [1] https://issues.apache.org/jira/browse/CAMEL-5052 Best, Christian On Thu, Jul 5, 2012 at 3:04 PM, Pointless wrote: > Hello, > > I'm using Camel with Servicemix (2.7.1.fuse-00-43) with the following > route: > > > The problems is

Re: NoTypeConversionAvailableException

Looks like the message was empty: size = 0 bytesOut =null/ What should the content be? Best, Christian On Thu, Jul 5, 2012 at 3:01 PM, bharathi_camel_learn < bharathi...@cognizant.com> wrote: > Hi all, > > i am getting below exception when i receive a message from external > ActiveMQ > broker.

Re: Camel 2.10.0 and Bindy/CSV

Hi Chris, Sorry for the delay. I just created: https://issues.apache.org/jira/browse/CAMEL-5423 If you need anything else, let me know. tks. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-2-10-0-and-Bindy-CSV-tp5715387p5715565.html Sent from the Camel - Users mailin

Re: creating routes dynamically

Hi Sri, > I wanted to create routes dynamically based on the msg header I receive and > send msg to that route . Yes, you can. CamelContext context = new DefaultCamelContext(); context.addRoutes(new RouteBuilder() { @Override public void configure() throws Exception { from("direct:start1

Re: Testing a Route which de-queues message from Topic in CLIENT_ACKNOWLEDGE mode

Hi, You can get the statistics from the BorkerService object. To be honest I have never tested this with topics but for a queue the calls are like this. -- ActiveMQDestination queryDest = ActiveMQDestination.createDestination("myQueue",

HTTP Component Proxy Settings

I try to make sense out of the HTTP and HTTP4 component proxy properties. I expected as described in https://issues.apache.org/jira/browse/CAMEL-1687 and in the documentation of the HTTP4 component that you could specify settings by using the System properties (http.proxyHost etc.). If you specify

creating routes dynamically

Hi, I wanted to create routes dynamically based on the msg header I receive and send msg to that route . This routes can grow to thousands over the period of time. And is it feasble to have this kind of architecture?. Regards Sri -- View this message in context: http://camel.465427.n5.nabbl

Re: Is it a good idea to store very large data (100,000 records) in StringBuffer and then write to file using Apache camel's File Component?

Bit of a vague question. If each record is 1 byte then you have 100k so yes. If each record is 1mb then you have a slight problem. On Thu, Jul 5, 2012 at 3:49 PM, dmhatre wrote: > Hi Folks, >Is it a good idea to store very large data (100,000 records) in > StringBuffer and then write to file

Is it a good idea to store very large data (100,000 records) in StringBuffer and then write to file using Apache camel's File Component?

Hi Folks, Is it a good idea to store very large data (100,000 records) in StringBuffer and then write to file using Apache camel's File Component? -- View this message in context: http://camel.465427.n5.nabble.com/Is-it-a-good-idea-to-store-very-large-data-100-000-records-in-StringBuffer-and-t

Re: Testing a Route which de-queues message from Topic in CLIENT_ACKNOWLEDGE mode

Hi Folks It was also unclear to me how to ensure that the message was de-queued or not. Ideally, after starting up the broker service in my junit test I would like to put a message on to the queue and then verify I have successfully de-queued the message at the end of my testcase by ensuring the

Failing FTP Component

Hey everybody, I made wrote a little piece of camel to consume a ftp server. But after it was running for some time, it throws an exception, keeps running but doesn't consume anything any more. Also when I start it again and there are a larger number of file waiting to be consumed it will crash a

Failing FTP Component

Hey everybody, I made wrote a little piece of camel to consume a ftp server. But after it was running for some time, it throws an exception, keeps running but doesn't consume anything any more. Also when I start it again and there are a larger number of file waiting to be consumed it will crash a

Failing FTP Component

Hey everybody, I made wrote a little piece of camel to consume a ftp server. But after it was running for some time, it throws an exception, keeps running but doesn't consume anything any more. Also when I start it again and there are a larger number of file waiting to be consumed it will crash a

Processors in onException block remove message headers in certain cases

Hello, I'm using Camel with Servicemix (2.7.1.fuse-00-43) with the following route: The problems is when a system exception is thrown from CashManagementV01Endpoint, like "org.apache.xml.security.encryption.XMLEncryptionException: Illegal key size" (the full stacktrace is below - the reason is k

NoTypeConversionAvailableException

Hi all, i am getting below exception when i receive a message from external ActiveMQ broker. /org.apache.camel.RuntimeCamelException: org.apache.camel.NoTypeConversionAvailableException: No type converter available to convert from type: org.apa che.activemq.command.ActiveMQStreamMessage to the re

Re: Bean binding @Body and Exchange

Hi, I am using camel 2.9.2 installed in Apache Karaf. Java 6 update 33 (java version "1.6.0_33") START of Stack trace karaf@root> log:display-exception org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchan

Re: CXF Producer configuration URI Options

Hi Jaffa, using the payload mode you have to provide XML body payload, so no objects are needed. What you have to specify is header values - *operationName*, *operationNamespace *and eventualy *soapAction*. Carpe diem Gabriel -- View this message in context: http://camel.465427.n5.nabble.

Re: Bean binding @Body and Exchange

Hi Can you post the stacktrace. And what version of Camel are you using? And what JDK. On Thu, Jul 5, 2012 at 11:33 AM, dealbitte wrote: > Hi, > > I have the following camel route (defined in blueprint) > > > > > > > > > > > > > > In the method "createXML(Exchange exchange)", I create a Documen

Re: Important difference in behaviour between processRef and beanRef

The REQUEST_QUEUE_ENDPOINT has a say what MEP is being used. On Thu, Jul 5, 2012 at 12:13 PM, iamniche wrote: > So I have had a look at the exchange pattern and appears that the following > route defaults to InOnly: > > from(REQUEST_QUEUE_ENDPOINT) > .processRef(EnricherProcessor

Re: Important difference in behaviour between processRef and beanRef

So I have had a look at the exchange pattern and appears that the following route defaults to InOnly: from(REQUEST_QUEUE_ENDPOINT) .processRef(EnricherProcessor.ENRICHERPROCESSOR_ID) .to(RESPONSE_QUEUE_ENDPOINT); So if I do the following: from(REQUEST_QUEUE_ENDPOI

Bean binding @Body and Exchange

Hi, I have the following camel route (defined in blueprint) In the method "createXML(Exchange exchange)", I create a Document (org.w3c.dom.Document) and set it as a exchange Body as follows: exchange.getIn().setBody(doc)

Re: Camel SMPP issue - alphabet option/data_coding issue (2.10.0)

Hi, I managed to get the SmppSubmitSmCommand.java to behave how I would like it to by changing: template.setDataCoding(new GeneralDataCoding(false, true, MessageClass.CLASS1, determinedAlphabet).value()); to: template.setDataCoding(new GeneralDataCoding(false, false, MessageClass.CLASS0, determin

Re: Important difference in behaviour between processRef and beanRef

Hi See this FAQ http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html On Thu, Jul 5, 2012 at 11:06 AM, iamniche wrote: > Hello, > > I have found an important difference in behaviour between processRef and > beanRef, which maybe someone can explain to me, please. > > For example

Important difference in behaviour between processRef and beanRef

Hello, I have found an important difference in behaviour between processRef and beanRef, which maybe someone can explain to me, please. For example, take the following route, which consumes from a queue, enriches the message and then finally sends the message to another queue (where EnricherProce