JMS option " recieveTimeout"

Hello. In the case of used JmsSource ,I don't know why it is ignored when recieveTimeout is smaller than 1000. If recieveTimeout is 2000, JMSSource is polling a Queue by intervals of two seconds. But recieveTimeout is 250, JMSSource is polling a Queue by intervals of a second. My Camel version is

Re: CamelSpringTestSupport with multiple Camel-Contexts, not working

On Thu, Sep 29, 2011 at 9:57 PM, wrote: > Hi, > > I am trying to run a unit test with multiple camelcontexts defined. > > The test extends CamelSpringTestSupport. > > Whenever I run the test, I get the message: Should have at least one route. > You can override a method named something like int

Re: XPath expression in log

On Thu, Sep 29, 2011 at 7:35 PM, Tristan23 wrote: > Hi there, > > I am just learning Java :) > > At the moment I am reading XML files. I'd like to use XPath expression in > the log() method. > > I am already familiar with how to use Simple language, e.g. >   from("file:data/in") >   .log("${header

http4 component

I am trying to use the http4 component to send information to a web service. I keep getting an error on the http4 endpoint: SendProcessor.java:102 - >>> Endpoint[http4://localhost:9090/service?name=Jay] Exchange[null] CamelLogger.java:186 - Failed delivery for exchangeid: On delivery attempt: 0

Re: Activemq dynamic endpoint configuration

Thanks Clause, I will give it a try this week end and see how it goes. Starting and stoping the route seems a bit expensive, can I use suspend and resume? Thanks Kal On Sep 28, 2011, at 2:01 AM, Claus Ibsen-2 [via Camel] wrote: > Hi > > Yes you would need to stop the route. Adjust the endp

CamelSpringTestSupport with multiple Camel-Contexts, not working

Hi, I am trying to run a unit test with multiple camelcontexts defined. The test extends CamelSpringTestSupport. Whenever I run the test, I get the message: Should have at least one route. However, when I run exactly the same camelcontext via the Mainsupport of Camel, everything works fine as e

Re: SMPP to SMPP using camel

May I misunderstood something, but I don't think this is possible with the underling jsmpp library. Christian On Thu, Sep 29, 2011 at 11:28 AM, Ioannis Canellos wrote: > From what I make out of the jsmpp documentation, jsmpp could support this > type of functionality, so in theory it wouldn't be

XPath expression in log

Hi there, I am just learning Java :) At the moment I am reading XML files. I'd like to use XPath expression in the log() method. I am already familiar with how to use Simple language, e.g. from("file:data/in") .log("${headers.CamelFileName}"); But how would I do this with XPath? I'd li

Re: Messages being lost from route

no connection pool. What was disturbing was the first message sent to the broker after a restart and clean out of the data dir, disappeared. There's a similar route on the broker that works fine. The only difference is the producer for the wonky route is on windows and is up to 1min ahead of the

Re: Messages being lost from route

Well with only 17 you definitely aren't hitting any prefetch limits or anything like that. Are you using a connection pool? On Thu, Sep 29, 2011 at 5:05 PM, Alistair Young wrote: > I think this way madness lies. > > 17 sent to topicA, dispatchCount = 15, dequeueCount = 12 > topicB enqueueCount =

The SFTP component: the keyboard-interactive auth method support

Hi Camel gurus. I've got some small improvement for the SFTP component which probably might be handy. It appeared that our sftp share we get files from doesn't support the ssh password auth method and we're not allowed to put the public key to there. So the only ssh auth method we can use is the

Re: Messages being lost from route

I think this way madness lies. 17 sent to topicA, dispatchCount = 15, dequeueCount = 12 topicB enqueueCount = 12 so 17 came in, 12 made it through, of the 5 that went missing it claims to have sent 3 to topicB but they never arrived and the last 2 just simply vanished completely. What on earth

Re: recipientList inside SEDA route with CXF

FYI created https://issues.apache.org/jira/browse/CAMEL-4503 for the recipient list bug and Achim is trying out another approach to workaround this issue. On Thu, Sep 29, 2011 at 11:46 AM, Achim Nierbeck wrote: > I did take a look at the sources and I think I found the > root of my problem, thoug

Re: Problems with jetty component and posts with more then one value for a field.

Hi the camel masters, Just wanted to clarify the CAMEL-4211 fix works not only for http related URIs? I created my own endpoint extending the DefaultEndpoint and passed this uri="feed:trades?params=param1¶ms=param2" to it. In the endpoint itself I put the private Collection params; and th

Re: Messages being lost from route

nup - cleaned out the data dir and restarted the broker. First message in vanished. Wasn't persisted. So something is fundamentally broken. topicA inflightCount = dispatchCount = enqueueCount = 1 topicB is completely empty so the message wasn't persisted, wasn't processed, wasn't routed and just

Copy File - catch non existing file

Hello I have a route that copy each hour a file and process it, but, at some part of the day the file won't be there and I wan't to catch this to look at another file in another folder is this possible? Thanks -- View this message in context: http://camel.465427.n5.nabble.com/Copy-File-catch-no

Re: Need help on using Ant path matcher

Ah... solved by adding excludes=cvat/*.* that is filtering away all files in dir dir instead of filtering the actual dir. Thanks for inputs! /L -- View this message in context: http://camel.465427.n5.nabble.com/Need-help-on-using-Ant-path-matcher-tp4852531p4853277.html Sent from the Camel - Use

Re: recipientList inside SEDA route with CXF

I did take a look at the sources and I think I found the root of my problem, though I'm not sure how to get around it: RecipientList class contains a producer cache, in this cache the RecipientListProcessor class does store the endpoints depending on the uri as key. Now since only my header change

Re: Messages being lost from route

route goes from topicA -> topicB, transacted. topicA inflightCount = 96 and increases on each batch of incoming messages topicB dispatchCount = enqueueCount wondering if the missing messages are connected to topicA inflightCount. I noticed there are two consumers for topicB. The main consumer get

Re: Properties Component and Processor

Hi There is API on CamelContext to access the properties, using the resolvePropertyPlaceholders method. On Thu, Sep 29, 2011 at 3:08 PM, llt wrote: > Hi, > I'm using PropertiesComponent to configure my endpoints and it works fine, > but sometimes I need to access to the same properties also ins

Re: SMPP to SMPP using camel

never mind, I was able to open the Jira. https://issues.apache.org/jira/browse/CAMEL-4501 Allow CAMEL to act as SMPP router/gateway -- View this message in context: http://camel.465427.n5.nabble.com/SMPP-to-SMPP-using-camel-tp4845410p4853112.html Sent from the Camel - Users mailing list archiv

Re: Need help on using Ant path matcher

:( According to GenericFileConsumer.java and the method protected boolean isMatched(GenericFile file, boolean isDirectory) { I can see following code snippet: // directories so far is always regarded as matched (matching on the name is only for files) if (isDirectory) {

Re: Need help on using Ant path matcher

:( According to GenericFileConsumer.java and the method protected boolean isMatched(GenericFile file, boolean isDirectory) { I can see following code snippet: // directories so far is always regarded as matched (matching on the name is only for files) if (isDirectory) {

Re: Need help on using Ant path matcher

Hi! Tried both them without success. What I think is strange is that org.apache.camel.spring.util.SpringAntPathMatcherFileFilter is only TRACE'in when filtering on the files, never see it filtering on directories. Is it really supported to filter on directory name? Example - I can see this i

Re: SMPP to SMPP using camel

sure, have you a link to instructions for creating a Jira? can I use same login and password as I do for this forum? -- View this message in context: http://camel.465427.n5.nabble.com/SMPP-to-SMPP-using-camel-tp4845410p4853054.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: recipientList inside SEDA route with CXF

Ok, some more worrying details. Right now I have two Remote Hosts After a successful run on Host A a second run is done (not parallel but sequential) on Host B. And I'm able to see that the header.address is set to host B still I see that the request is made on Host A. Is this intentional, are t

Properties Component and Processor

Hi, I'm using PropertiesComponent to configure my endpoints and it works fine, but sometimes I need to access to the same properties also inside my Processor class (or bean). Is it possible? I found, I think, how to extract my PropertiesComponent from my context using context.getComponent("properi

recipientList inside SEDA route with CXF

Hi using Camel 2.8.0 I'm having the following scenario. I'm using the CXF for connecting to a couple .NET Webservices. http://tempuri.org/"; xmlns:a="http://schemas.microsoft.com/2003/10/Serialization/Arrays"; xmlns:i="http://www.w3.org/2001/XMLSc

Re: Where is the .handled method? Migrating from 2.5 to 2.8.1

On Thu, Sep 29, 2011 at 1:18 PM, heinrichheine wrote: > And a general question regarding the wireTap situation: > > i found some other locations, e.g. choice where i can not place a wireTap > inside a when and place a second when afterwards. > > Example > > .choice() >   .when().xpath("expr") >  

Re: Where is the .handled method? Migrating from 2.5 to 2.8.1

On Thu, Sep 29, 2011 at 1:11 PM, heinrichheine wrote: > Ah, > yes its still there but the location must be changed. > My 2.5 code: >        route.onException( ExchangeTimedOutException.class ) >            .setHeader( "incomingroute", constant(config.getRouteName()) ) >            .wireTap( DEAD_L

Re: Where is the .handled method? Migrating from 2.5 to 2.8.1

And a general question regarding the wireTap situation: i found some other locations, e.g. choice where i can not place a wireTap inside a when and place a second when afterwards. Example .choice() .when().xpath("expr") .wireTap("log:somewhere") .to("direct:here") .when()

Re: Messages being lost from route

Sorry you might have tried this since I haven't been following this thread. But can you check your jmx console. In particular check 2 things.. the route to see if the number of exchanges match what you think and how if any exchanges failed. Also check the JMX console on activemq for the queue or to

Re: Where is the .handled method? Migrating from 2.5 to 2.8.1

Ah, yes its still there but the location must be changed. My 2.5 code: route.onException( ExchangeTimedOutException.class ) .setHeader( "incomingroute", constant(config.getRouteName()) ) .wireTap( DEAD_LETTER ) .setHeader( RoutingConstants.RESULT_CODE, c

threadpool hangs when terminating app.

I have a small camel route that calls a database server, then splits the result list using parallelprocessing and a executorserviceref (threadpool). When I close the application i writes that it is closing down by hangs... and leaves a java process taking 100% cpu. hope someone can help... brgds

Re: Need help on using Ant path matcher

Hi Try setting something like "f/**" or "**/f/**" to exclude any f directories. On Thu, Sep 29, 2011 at 12:20 PM, lenp wrote: > Camel 2.8.1 > > Using FTP endpoint that should recursively find all xml-files, but not look > into a specific directory. > > Scenario: > Parent dir: /a/b/c > > There

Re: Where is the .handled method? Migrating from 2.5 to 2.8.1

On Thu, Sep 29, 2011 at 12:52 PM, heinrichheine wrote: > Hi, > i currently migrating my Camel Java DSL route from Camel 2.5 to 2.8.1 > and i figured out, that in the onException clause, there is no > .handled(true) method anymore. > Where is it gone or how should i mark my messages as handled now?

Re: When will 2.8.2 be released?

On Thu, Sep 29, 2011 at 11:57 AM, lenp wrote: > Ok, is it 'stable' enough to check out for almost prod testing, kind of… :) > Yeah we love feedback, so give the 2.8.2-SNAPSHOT a spin. > mvh, > > /L > > > > > 29 sep 2011 kl. 11:55 skrev Christian Schneider [via Camel]: > >> There is a discussio

Where is the .handled method? Migrating from 2.5 to 2.8.1

Hi, i currently migrating my Camel Java DSL route from Camel 2.5 to 2.8.1 and i figured out, that in the onException clause, there is no .handled(true) method anymore. Where is it gone or how should i mark my messages as handled now? Thanks martin -- View this message in context: http://camel.

Re: Messages being lost from route

dunno - nothing works. Random messages are just vanishing once they reach the broker. No trace, no logs, no dead letter queue. Just vanishing. I've removed and but it doesn't help. The producer is a few secs behind the broker: sent : 11:25:26 arrived : 11:24:57 timstamp on message : 131729189

Need help on using Ant path matcher

Camel 2.8.1 Using FTP endpoint that should recursively find all xml-files, but not look into a specific directory. Scenario: Parent dir: /a/b/c There we find directories d, e, f, g and h. Each of them having sub directories with files. Directory f am I not allowed to take files from. How do I c

Re: When will 2.8.2 be released?

Ok, is it 'stable' enough to check out for almost prod testing, kind of… :) mvh, /L 29 sep 2011 kl. 11:55 skrev Christian Schneider [via Camel]: > There is a discussion about this on the dev list. > > It looks like we could have the release around the 15th of October. > > Christian > >

Re: When will 2.8.2 be released?

There is a discussion about this on the dev list. It looks like we could have the release around the 15th of October. Christian Am 29.09.2011 11:52, schrieb lenp: /L -- View this message in context: http://camel.465427.n5.nabble.com/When-will-2-8-2-be-released-tp4852467p4852467.html Sent fr

Re: Camel Netty Producer creating new connection on every message?

No worries. This is a small Unit Test that shows the problem. Hope it helps: -- package netty; import java.util.Arrays; import java.util.Collection; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import j

Re: SMPP to SMPP using camel

>From what I make out of the jsmpp documentation, jsmpp could support this type of functionality, so in theory it wouldn't be hard to add this kind of support to camel too. Could you create a jira for it? -- *Ioannis Canellos* * FuseSource ** Blog: http://iocanel.blogspo

Re: Messages being lost from route

just saw your info about transacted being before from - will change that and monitor again. thanks, Alistair -- mov eax,1 mov ebx,0 int 80 On 29 Sep 2011, at 10:18, Alistair Young wrote: > just noticed a batch of identical 5 messages, three were missing and another > single messa

Re: Messages being lost from route

Hi For topics you ought to set an unique clientId and subscription name the consumer side. http://camel.apache.org/jms http://activemq.apache.org/how-do-durable-queues-and-topics-work.html On Thu, Sep 29, 2011 at 11:18 AM, Alistair Young wrote: > just noticed a batch of identical 5 messages, t

Re: Messages being lost from route

just noticed a batch of identical 5 messages, three were missing and another single message vanished. tracer logged nothing. No errors, dead letter queue empty. One thing that happens is another machine polls the stats topic in activemq every 2mins. Would that cause a problem? It asks for stats

Re: Messages being lost from route

Yes should be before the . We may add a validation check in the future | Camel 3.0 for that so you cannot mis configure it. On Thu, Sep 29, 2011 at 10:36 AM, Alistair Young wrote: >> Should be after > it is after from - do you mean it should be before? >     >       >       >       >       >

Re: SMPP to SMPP using camel

ok, I think that Ioannis Canellos has clearly outlined what I was hoping to do, but had indicated that this is not possible. Would this be considered a limitation of Camel that could be (easily) enhanced or a limitation in the SMPP component (that could also be considered for enhancement). Thank y

Re: SMPP to SMPP using camel

Hi, No, I dont want CAMEL to play the function of an ESME per se. I want it to play the function of a broker/gateway between SMPP peers ( peers fulfilling the role of both ESMEs and SMSCs). Is this possible through route configuration or otherwise? -- View this message in context: http://cam

Re: TypeConversion with JAXB when calling "remote" EJB

Hi Jean-Baptiste, since your mail I wasn't thinking in that direction (setting up a JndiContext on the EJB). So thanks for the input! I used the Camel EJB component to integrate the EJB in my Camel route. Since both deployments run in same application server (ergo the same JVM) the default JndiCo

Re: Messages being lost from route

> Should be after it is after from - do you mean it should be before? thanks for the dead letter tips, will apply them. Alistair -- mov eax,1 mov ebx,0 int 80 On 29 Sep 2011, at 09:20, Claus Ibsen wrote: > Hi > > Should be after > > > On

Re: Messages being lost from route

And its better to use the native redelivery / dead letter queue, features of the AMQ message broker, than from Camel. http://activemq.apache.org/message-redelivery-and-dlq-handling.html http://activemq.apache.org/redelivery-policy.html So remove the matrixDeadLetterErrorHandler and use the DLQ fro

Re: TypeConversion with JAXB when calling "remote" EJB

Hi Sven, FYI, I blogged about calling remote EJBs in Camel routes: http://blog.nanthrax.net/2011/08/use-a-remote-ejb-in-camel-routes/ I make a remote JNDI lookup on the EJB (session stateless) and use it as a bean in a route. Regards JB On 09/29/2011 10:19 AM, smythewin wrote: Hi Claus, t

Re: Messages being lost from route

Hi Should be after On Thu, Sep 29, 2011 at 10:09 AM, Alistair Young wrote: >> Do you use message expiry? > no > >> timestamp plugin > > using that > > activemq 5.5.0 > camel 2.8.0 > spring 3.0.5 > > noticed sl4j errors on startup, fixed that and now the tracer is logging so > hopefully I can

Re: TypeConversion with JAXB when calling "remote" EJB

Hi Claus, thanks for your answer. You are pretty well dedicated in this forum! I am using Glassfish V3.1.1 with EJB V3.0, as you already assumed correctly. I stated at Willem within my last post: it is possible to call the "remote" EJB via an alternative EJB call (in my case from a Servlet refer

Re: Messages being lost from route

> Do you use message expiry? no > timestamp plugin using that activemq 5.5.0 camel 2.8.0 spring 3.0.5 noticed sl4j errors on startup, fixed that and now the tracer is logging so hopefully I can see any errors.

Re: TypeConversion with JAXB when calling "remote" EJB

On Wed, Sep 28, 2011 at 4:27 PM, smythewin wrote: > Hi, > > if I get Willem's point right, I would NOT be able to call the EJB remotely > in either way (using camel ejb or any ordinary ejb invocation mechanism). > > But I can perfectly do that, when running a Servlet (in the same deployment > arti

Re: Camel Netty Producer creating new connection on every message?

On Wed, Sep 28, 2011 at 4:17 AM, maccamlc wrote: > OK, when I use the option "disconnect=true" on the Client (NettyProducer) it > works, ie. does not stop routing after 10 messages. > That sounds like it hit some default thread pool limits, which has 10 in the core pool size. Do you mind creating

Re: Messages being lost from route

Hi Do you use message expiry? Make sure clocks between server/clients is synced as much as possible. There is a timestamp plugin http://activemq.apache.org/timestampplugin.html And do you use queue or topic. What version of AMQ and Camel are you using? And how have you configured the AMQ broker,

Re: SMPP to SMPP using camel

It also provides a consumer (Receiver) to receive messages (short messages > or > short message delivery notifications) from the SMSC in your Camel powered > application (from("smpp:...")). I think this is all you need, isn't? > I think that the user needs more. He also wants to be able to accept