Re: TarAggregationStrategy - /tmp directory is full !!

I'm using camel ver 2.17 and I added route code. thk from(src_uri).convertBodyTo(String.class) .setHeader("REAL_AGGREGATION_ID", constant("REAL_AGGREGATION")) .log("Aggregation ${file:onlyname} ") .aggre

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I didnt understand properly. Was I doing some mistake? With the new version it will be resolved? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-rx-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp5781482p5781512.html Sent from the Camel - Us

Re: How to return early from a direct: subroute?

Is there a reason you don't want to throw an exception? If you have multiple processors in a row like that all of which might throw exceptions that certainly seems reasonable. The other possibility here is to inject your processors into one another in a chain of responsibility. I usually use a c

Re: Need an interceptSendTo hook

Hi Jeff Did you know that you could weave in mock end points anywhere in your route during unit testing? That way it doesn’t pollute your production route while your application is running normally. http://camel.apache.org/advicewith.html Does that h

Re: Need an interceptSendTo hook

By the way, I noticed that as of Camel 2.16 they've added an "ignoreInvalidEndpoint" flag which may be for exactly the reasons you need. During testing you'd set up an endpoint to receive messages but in production those test endpoints, not used for monitoring, wouldn't have endpoints associated w

Re: Need an interceptSendTo hook

I'll let others comment on this more fully but will make on observation that will depend very much on your needs outside of testing. The wiretap allows you to get a full copy of an exchange and send it off on a separate route. That is actually a good mechanism if you might later use that for moni

Kafka 2.17 consumer options

Hello All, We have 2 parameters in consumer for Camel kafka 2.17 component consumerStreams and consumersCount Please could someone help me with the difference between two? And in case we need to improve performance/throughput of Kafka consumer job, which one should be used? Vanshul

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

Hi Okay fixed by https://issues.apache.org/jira/browse/CAMEL-9899 Its because you stop the jms consumer from the event thread which is the thread that consumed the message. The ticket resolves this by stopping using a thread pool for those tasks so they dont steal the thread from RX. On Thu, A

Camel Spring Boot adding XML routes

Hello, >From a project based on the camel-archetype-spring-boot I'm trying to add additional routes defined in XML as described in the documentation[0]. However when starting the application it fails with a java.util.NoSuchElementException. The full stacktrace can be found here[1]. I use Camel 2

Re: TarAggregationStrategy - /tmp directory is full !!

What version of Camel do you use, and can you show the route code you have with that TAR strategy. On Tue, Apr 19, 2016 at 8:27 AM, sungkwon.eom wrote: > Hello, > > I'm using TarAggregationStrategy for create tar.gz file. > > BUT, I found TarAggregationStrategy don't delete /tmp directory files

Re: How to return early from a direct: subroute?

Thank you all very much for responding to my question and for offering solutions. I have implemented my application using a combination of headers and . But I also concluded that there is not a simple and elegant way to do what I intended to do. I wish the great Camel team will add such a featur

Need an interceptSendTo hook

I've got a route that I'd like to do some unit testing on at various stages. It does a few splits, sets some headers, etc. The problem is that there's no actual endpoint for me to intercept until the very end, but I'd like to do some verification midway through. I suppose I could add arbitrary moc

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I have created a sample project and uploaded the zip to the github location https://github.com/arunkabraham/Camel-RX Its just a main program which sends a messages to activemq and fetch it from there using camel-RX. But the connection to the active-mq i

Jetty adds query parameters as header values

I noticed in the populateRequestParameters function of the DefaultHttpBinding class that query parameters are added as header values in requests. Once this is done then the query parameters continue to exist on the url and also exist as headers which seems redundant. Why are these query parameter

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

Test with latest code, which you can build yourself http://camel.apache.org/building And build an example project / unit test to reproduce the issue. You can put the sample project on github etc for easy to try for others. On Thu, Apr 21, 2016 at 5:04 PM, arunkabraham wrote: > I am using camel-r

RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I am using camel-rx to observe some messages from Active MQ. After I complete the subscription I am getting onCompleted() event also. But If I look in Active MQ console, I can still see the consumer live. How to release this connection once subscription is over? Is it an issue with Camel? Code :

Re: Errors with SFTP producer and large files

I am using camel 2.11.0 version, still facing similar issue. We are sending files via sftp, so why it is giving us Storage exception. Strange thing is files are getting delivered to users successfully, but our process is getting this exception, which is not letting us throw the correct alert. And w

Re: Camel RabbitMQ

Ok I figured out what the issue is. You must explicitly set the exchangepattern to InOut otherwise the replyto headers and queues are not created by default. -- View this message in context: http://camel.465427.n5.nabble.com/Camel-RabbitMQ-tp5781455p5781457.html Sent from the Camel - Users mai

Camel RabbitMQ

Hello, I am trying to create a simple camel producer to send a text message to an exchange. I am expecting component to publish to the exchange, create a random queue to receive the reply to from. The exchange is of type topic. However, what happens is that the component simply publishes the messa