Re: VM component, URI for matching

On Tue, May 8, 2012 at 6:12 PM, Thomas Johansen wrote: > Hi again, > > The problem goes for both seda and vm. BUT I discovered that the problem > only arises when the vm/seda route is adviced with > interceptSendToEndpoint(). And still only on 2.9.1/2.9.2, not 2.9.0. > > I'm attaching my stripped

Re: Failed to get thread context

On Tue, May 8, 2012 at 10:27 PM, rdifrango wrote: > Anyone ever seen this before and know the cause and/or resolution: > > [ERROR] Failed to get thread context. > [ERROR] Failed to get thread context in ptReadContextFromThread. > No. Its hard to know what it is, when you dont report more details.

LDAP Component lose headers

Hi all, I´m working with the Camel LDAP component. As we can read in the http://camel.apache.org/ldap.html LDAP page "The result is returned in the Out body". I´ve seen in the code of LdapProducer.java (process method), that we only have this line related to the Out message: exchange.getOut().s

Re: Graceful shutdown with drain stopping

On Wed, May 9, 2012 at 8:13 AM, Thomas Johansen wrote: > Hi, > > I've been looking at the shutdown strategy support, but can't find a way to > drain stop my routes. > > I.e. I have an application with several Mina TCP and Jetty consumer routes. > When shutting down the first thing I want to happen

Re: Integration Testing Best Practices...

On Tue, May 8, 2012 at 8:14 PM, James Carman wrote: > Can we introduce this advice using blueprint XML?  I'm trying to set up > simple examples that the testing folks can use to add this stuff into > existing routes.  Is that possible? > Yes from Camel 2.10 onwards we got a camel-test-blueprint c

Re: How to send ack and then resume route with original message

On Tue, May 8, 2012 at 9:19 PM, barry_allen wrote: > Ok, thank you both very much, I got it. I needed to use inOnly tags on the > route as sekaijin mentioned. I was using tags (which apparently > allowed those steps to return output into the mina route), and simply > changed them to tags. What t

Graceful shutdown with drain stopping

Hi, I've been looking at the shutdown strategy support, but can't find a way to drain stop my routes. I.e. I have an application with several Mina TCP and Jetty consumer routes. When shutting down the first thing I want to happen is that these routes stop consuming any more messages which in prac

Waiting for Routes to Finish

Is there a way to programatically check to see if a route is finished? Basically, I want an intelligent shutdown loop that checks to see if routes are still processing work before shutting down my Camel Context. -- View this message in context: http://camel.465427.n5.nabble.com/Waiting-for-Route

Failed to get thread context

Anyone ever seen this before and know the cause and/or resolution: [ERROR] Failed to get thread context. [ERROR] Failed to get thread context in ptReadContextFromThread. Here are my routes: context.addRoutes(new RouteBuilder { "sftp://myid@myserver//prod/msp/logs/prtlf_logs/msp_prtlf_qps_07/

Re: How to send ack and then resume route with original message

Ok, thank you both very much, I got it. I needed to use inOnly tags on the route as sekaijin mentioned. I was using tags (which apparently allowed those steps to return output into the mina route), and simply changed them to tags. What this does is not let any output from those steps of the route

Re: How to set the CRL path for Camel HTTP component?

Hi, Claus Ibsen-2 Thanks. we will check these components.:) Regards. Leng Yong. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-set-the-CRL-path-for-Camel-HTTP-component-tp5692798p5696357.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Help with a Karaf/Camel/Cxf/ActiveMQ setup that results in an NPE

Hi Did you use the jre.properties.cxf? eg to replace that with the existing jre.properties. And after installing all the bundles and whatnot. Have you tried restarting Karaf? And have you tried downgrading to CXF 2.5.x? And again what you assemble is essentially a like Apache ServiceMix, however

Re: CXF webservice asyn

Hi Yogesh, Thanks for ur response. Yes, I am looking for a thread pool for from point as well. Appreciate your help Thanks -- View this message in context: http://camel.465427.n5.nabble.com/CXF-webservice-asyn-tp5695918p5696434.html Sent from the Camel - Users mailing list archive at Nabble.com

Re: CXF webservice asyn

Hi Deepthi, Claus has a blog post about concurrency that might point you in the right direction. Do you want a thread pool for your 'from' file endpoint? http://davsclaus.blogspot.com/2009/05/on-road-to-camel-20-concurrency-with.html Thanks, Yogesh -- View this message in context: http://camel

Re: dynamically creating directory with current date in yyyyMMdd format

Hi Mahesh, You can try setting your file name with the dynamic format: ${date:now:MMdd}/someFileName.xml This will create a folder with the dynamic date and then put 'someFileName.xml' inside of it. This should work in the Java DSL as well. Thanks, Yogesh -- View this message in conte

Re: Waiting for Routes to Finish

Hi, Camel offers some graceful shutdown functionality out of the box: http://camel.apache.org/graceful-shutdown.html Take a look and see if this fits your needs. Thanks, Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/Waiting-for-Routes-to-Finish-tp5695837p5696383.htm

Re: How to set the CRL path for Camel HTTP component?

Hi Yoleng, I believe Camel uses not-yet-commons SSL under the covers. This page details how to set the CRL checking: http://juliusdavies.ca/commons-ssl/ssl.html It says that by default it will check the CRL: client.setCheckCRL( true ); // default setting is "true" for SSLClient Thanks, Y

Re: SNMP traps - missing information in the Camel message?

On 8 May 2012 01:07, Ed Manero wrote: > Hi Jonathan/Claus, > > It looks like there is a deficiency in camel-snmp.  SnmpConverters.java only > uses org.snmp4j.PDU.getVariableBindings() to construct a camel message based > on snmp traps received by the component.  However this is only supported fo

CXF webservice asyn

Hi, I am exposing a Restful webservice and in the same camel context file I am consuming it. In my route, I am reading files from my local folder (data in the file is the request for webservice) and the destination is webservice. After I read a file from source and invoke the webservice, I want a

Re: Integration Testing Best Practices...

Can we introduce this advice using blueprint XML? I'm trying to set up simple examples that the testing folks can use to add this stuff into existing routes. Is that possible? -- View this message in context: http://camel.465427.n5.nabble.com/Integration-Testing-Best-Practices-tp5691310p5695537

Re: VM component, URI for matching

Hi again, The problem goes for both seda and vm. BUT I discovered that the problem only arises when the vm/seda route is adviced with interceptSendToEndpoint(). And still only on 2.9.1/2.9.2, not 2.9.0. I'm attaching my stripped down test. It is all green on Camel 2.9.0 and 2 out of 4 fail on Cam

Aries TransactionManager + OpenJPA + ActiveMQ

Hi everyone, I use the Geronimo TransactionManager with org.jencks.amqpool.XaPooledConnectionFactory for ActiveMQ and OpenJPA for a database. Everything is configured with spring. I've done a simple test that take a message from a queue ("input queue"), persist it in a database and then send t

Re: Incompatibility in wireTap() between 2.9.0 and 2.9.1/2.9.2

And in your custom thread pool, you need to set the rejection policy you want to use. for example the Abort from the JDK java.util.concurrent.ThreadPoolExecutor.AbortPolicy On Tue, May 8, 2012 at 4:17 PM, Claus Ibsen wrote: > On Tue, May 8, 2012 at 4:15 PM, Thomas Johansen wrote: >> Hi, >> >>

Re: Configure json to use jaxb annotations

Hi Christian I used the jettison library shipped with the jaxrs implementation. Here you can find some more information: http://jersey.java.net/nonav/documentation/latest/json.html This is a link for the library: http://jettison.codehaus.org/Download And this is a marshal method I used to crea

Re: How to send ack and then resume route with original message

I too need to do a try/catch block with ack/nak being sent accordingly. That's why I don't think I can wiretap the message processing and send the ack on the mina route (I need to send a nak instead of an ack if it fails). Part of the problem is that my ACK needs to be created from information that

Re: How to send ack and then resume route with original message

If you use non percistant queue the risk is to lost a massage. you receive a message put it on queue sent ACKand the reste of traiment raise exception the message is lost by principle never avoyer an ACK before sure everything is OK or avaoir percité message A+JYT -- View this message in cont

Re: How to send ack and then resume route with original message

On Tue, May 8, 2012 at 3:58 PM, barry_allen wrote: > Thank you for the example and for your insight. In my case, I have a need in > which I have to send the ACK before processing the message. Is this > possible? The ways shown will send the ACK and process in parallel. eg its 2 different threads,

Re: Invoking a bean returned by a previous bean invocation

On Thu, May 3, 2012 at 8:24 PM, gavindscott wrote: > > Claus Ibsen-2 wrote >> >> On Tue, May 1, 2012 at 8:11 PM, Purple Tea wrote: >>> Thank you for your reply. >>> >>> Does the simple language also allows us to send multiple method >>> parameters >>> like the new features offered

Re: VM component, URI for matching

On Tue, May 8, 2012 at 4:08 PM, Thomas Johansen wrote: > Hi Claus, > > So what's the deal? This is certainly an incompatibility between 2.9.0 and > 2.9.1/2.9.2? On 2.9.1/2.9.2 the producer and consumer don't communicate > when having the option on the consumer and not on the producer. This makes >

Re: Incompatibility in wireTap() between 2.9.0 and 2.9.1/2.9.2

On Tue, May 8, 2012 at 4:15 PM, Thomas Johansen wrote: > Hi, > > There's obviously a difference in how the wireTap()-processor handles > exceptions in 2.9.0 and 2.9.1/2.9.2. > In 2.9.0, when the wireTap() encounters a RejectedExecutionException on its > ExecutorService, the exception is swallowed.

Re: VM component, URI for matching

Hi Claus, So what's the deal? This is certainly an incompatibility between 2.9.0 and 2.9.1/2.9.2? On 2.9.1/2.9.2 the producer and consumer don't communicate when having the option on the consumer and not on the producer. This makes upgrading Camel in my product from 2.9.0 to 2.9.2 difficult. Takk

Incompatibility in wireTap() between 2.9.0 and 2.9.1/2.9.2

Hi, There's obviously a difference in how the wireTap()-processor handles exceptions in 2.9.0 and 2.9.1/2.9.2. In 2.9.0, when the wireTap() encounters a RejectedExecutionException on its ExecutorService, the exception is swallowed. In 2.9.1/2.9.2 the exception is propagated to the errorHandler of

Re: How to send ack and then resume route with original message

On Tue, May 8, 2012 at 3:50 PM, sekaijin wrote: > I'm use > > from mina > .doTry >  .process message >  .inOnly jsm:queue //send to backbone >  .bean prepare ACK > .doCatch >  .bean prepare NACK > .end > > with this method I'm sure the message is persisted in the JMS queue before > sending an ACK

Re: How to send ack and then resume route with original message

On Tue, May 8, 2012 at 3:45 PM, barry_allen wrote: > I apologize, but I'm pretty new to Camel, and I don't quite understand. On > the wiretap tag in spring, I have to make a call to the bean that creates > the ack, but I wouldn't send it yet? Where is the ack message that I created > in the bean s

Re: How to send ack and then resume route with original message

Thank you for the example and for your insight. In my case, I have a need in which I have to send the ACK before processing the message. Is this possible? Thank you -- View this message in context: http://camel.465427.n5.nabble.com/How-to-send-ack-and-then-resume-route-with-original-message-tp56

Re: How to send ack and then resume route with original message

I'm use from mina .doTry .process message .inOnly jsm:queue //send to backbone .bean prepare ACK .doCatch .bean prepare NACK .end with this method I'm sure the message is persisted in the JMS queue before sending an ACK if the route raise an error, a NACK is returned A+JYT -- View this

Re: How to send ack and then resume route with original message

I apologize, but I'm pretty new to Camel, and I don't quite understand. On the wiretap tag in spring, I have to make a call to the bean that creates the ack, but I wouldn't send it yet? Where is the ack message that I created in the bean stored? When do I send it? And then where does the original m

Re: VM component, URI for matching

Hi Yeah only the name of the queue ought to be enough. Its only on the consumer side the ?concurrentConsumers option matter. The only trick is though if you want the queue to have a fixed size, then its frankly the first endpoint created that dicate the queue size, eg if you use vm:foo?size=5000

Re: File Processor Not deleting the files

I was doing just that, what I found that works is to create multiple routes that are in effect chained off one of another like the following works [meaning the files get properly deleted]: context.addRoutes(new RouteBuilder { "file:perf?delete=true" ==> { process(myProcessor).to("file:pe

Re: How to send ack and then resume route with original message

On Tue, May 8, 2012 at 2:18 PM, barry_allen wrote: > Thanks for responding, Claus. Just a little clarification on wiretap: > > 1.) If I wiretap in this fashion, and I set getIn().body(ack) on the wiretap > thread from the mina route, will the ack be able to find it's way back to > the server (that

RE: OSGi - CAMEL and Custom Namespace

Hi, My objective is the following to implement: - A single bundle containing all my beans info (Java Objects + XML bindings for JiBX + Schema files) - Multiple bundles defining CAMEL Routes to process and route these XML messages (coming from FTP, WS..) My XML message contains Name

VM component, URI for matching

Hi, Camel 2.9.0 apparently does not require that URI parameters are part of the URI on both consumer and producer side of a VM queue, while 2.9.1 and 2.9.2 does. Is this by purpose or mistake? For example, I had a test which was using a ProducerTemplate to test a route: template().requestBody("v

Re: How to send ack and then resume route with original message

Thanks for responding, Claus. Just a little clarification on wiretap: 1.) If I wiretap in this fashion, and I set getIn().body(ack) on the wiretap thread from the mina route, will the ack be able to find it's way back to the server (that set the original message) correctly, as with the wiretap I a

Re: OSGi - CAMEL and Custom Namespace

Hi Whats the use case for using a bundle to expose a namespace. I am not sure all this is avail during the namespace parsing. The usual approach is just to define the namespace mapping in the XML stanza, and then refer to it in your xpath On Tue, May 8, 2012 at 11:15 AM, PAC Kieffer Guillaume

Re: Jasypt - Encrypted user name / password not available outside route or inside processor

Hi At point (1) you use the logger of the class, which is just a regular logger. It just logs what ever you type in the String. When you use the Camel Java DSL to define routes, eg in the configure() method and you use the Camel API for that. Then there is a .log which is the Log EIP http://camel

Re: Integration Testing Best Practices...

We are using Jenkins for our continuous integration. We have not set it up to auto-deploy anything to the integration environment as of yet (guidance on that with ServiceMix/OSGi would be helpful :). We are merely using it to run our unit tests, deploy snapshots to Nexus, and publish build inform

Jasypt - Encrypted user name / password not available outside route or inside processor

Hi Team, I am trying to use Jasypt for encryption or userid/password used to connect to 3rd party services. But While doing so I notice that the encrypted userid/pwd are available only inside the route definitiion i.e: @Override public void configure() throws Exception { log.i

RE: camel restlet : Accept header

Hi, Thank you for the response. Please find the log file along with Monitor snapshot (Monitor captures request before handover it to CXF rest service). We are using camel 2.8.3 with servicemix 4.3 version. Please suggest. Regards, pchakinala From: Claus Ibsen-2 [via Camel] [

Re: camel restlet : Accept header

On Tue, May 8, 2012 at 9:47 AM, pchakinala wrote: > Hi , >  We have restful service developed with CXF. Now we are planning to consume > it using camel-restlet component. We are setting below headers to return > response message in XML format. > > Camel client  Processor code: > >  exchange.getIn(

RE: OSGi - CAMEL and Custom Namespace

Hi Claus, I upgraded to 2.8.5 and still the same issue: Caused by: org.apache.xpath.domapi.XPathStylesheetDOM3Exception: Prefix must resolve to a namespace: scs Is it worh trying 2.9.2 ? I do not know if the upgrade on ServiceMix would be as smooth as 2.8.4 -> 2.8.5.. Regards, Guillaume. ---

Re: Mina:TCP MllpHl7 NACK and onComplete().OnFailed () howto ?

sorry an error in my post // 2) with catch the transform bean raise exception. // the exception is catched // the NACK is sent to socket // the route finish without error // the onComplete().ononComplete is activated ans log *KO* A+JYT -- View this message in context: htt

Re: Mina:TCP MllpHl7 NACK and onComplete().OnFailed () howto ?

Hi I do not use onComplete to send ACK or NACK. I use onComplete().onCompleteOnly() to log Ok and onComplete().OnFailed() to log KO in my main route, if I do not catch the error the NACK is not sent to the socket and onComplete() log KO the If i catch the error, the NACK is sent to the socket

Re: How to set the CRL path for Camel HTTP component?

Hi camel-http uses the old Http Client 3.1 library. So you need to check its doc if and how that is possible. You may look at newer http libraries such as camel-ahc camel-http4 camel-jetty (jetty client is not as powerful as its server) Also many of the Camel components have uniform SSL configur

Re: Mina:TCP MllpHl7 NACK and onComplete().OnFailed () howto ?

Hi As mentioned on the on completion web page http://camel.apache.org/oncompletion.html Camel spins of a new and separate thread to process the on completion. So its *extra* work that runs on the side of the original route. So you should NOT use that to send back a ACK or NACK. That should be com

Re: SNMP traps - missing information in the Camel message?

Hi Thanks for the patch. I wonder if we should add an attribute in the XML output of camel-snmp to include what type the message is (eg as you say there is some differences between them.) Eg something alike: ... If that is possible to determine and include. And yes most people dont work w

Re: Unable to rollback exchange while unmarshalling a file

On Tue, May 8, 2012 at 9:18 AM, priya wrote: > Hi, > Thanks for the reply.We are able to achieve the complete Exchange rollback > by shareUnitOfWork option on splitter with camel-core-9.2.0 when an > exception occurs during unmarshalling. And further spillting of exchange > stops.But all the excha

Re: Unable to rollback exchange while unmarshalling a file

Hi, Thanks for the reply.We are able to achieve the complete Exchange rollback by shareUnitOfWork option on splitter with camel-core-9.2.0 when an exception occurs during unmarshalling. And further spillting of exchange stops.But all the exchange's before unmarshaller exception still aggregates an

Re: How to send ack and then resume route with original message

Hi Check out the wire tap EIP, something alike http://camel.apache.org/wire-tap from mina wire tap -> direct:foo prepare ack from direct foo process message On Tue, May 8, 2012 at 12:38 AM, barry_allen wrote: > Hello. I have a tcp endpoint defined with mina in which I receive a message

Re: camel-jsch in sink mode for one time copy from a remote host using SCP

Thanks for the update :-) -- View this message in context: http://camel.465427.n5.nabble.com/camel-jsch-in-sink-mode-for-one-time-copy-from-a-remote-host-using-SCP-tp5680887p5691711.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: multicast and setting header

Hi Yogesh is right when he suggest to use the aggregation strategy of the multicast. This allows you full control of the assembly of the outgoing message when all the parallel multicasted messages is complete. By default the multicast will just keep the last message as the outgoing message. (eg

Re: File Processor Not deleting the files

On Mon, May 7, 2012 at 6:11 PM, rdifrango wrote: > OK...so it does not seem to fully correct the issue: > > public void configure() { > > from("file:perf?delete=true&idempotent=true").convertBodyTo(String.class) >                                                 > .split(body().tokenize("\n")).stre