Re: RecipientList or DynamicRouter or RoutingSlip
Thanks for your reply, The Dynamic RecipientList allow only to send the same messages to a Dynamic list of endpoints. My need, is to send the same message and overriding his header=Receiver following endpoints Receiver=A for endpoint =A Receiver=B for endpoint =B ...etc Thanks for help -- View this message in context: http://camel.465427.n5.nabble.com/RecipientList-or-DynamicRouter-or-RoutingSlip-tp5745069p5745092.html Sent from the Camel - Users mailing list archive at Nabble.com.
camel-zookeeper: ZooKeeperProducer does implement doStop()
Hi the ZooKeeperProducer class does not stop/close the Zookeeper connections properly when stopped. After closing the Camel context, the connection threads still remain active. I fixed this and pushed to github: https://github.com/klauss42/camel/commit/491e07dbb941818b00fec9cfa256931e78dd480a and https://github.com/klauss42/camel/commit/65fde427ce531f239d24dc367cb460a0cb36d319 Please integrate in one of the next Camel releases thanks Klaus -- View this message in context: http://camel.465427.n5.nabble.com/camel-zookeeper-ZooKeeperProducer-does-implement-doStop-tp5745096.html Sent from the Camel - Users mailing list archive at Nabble.com.
camel-zookeeper: Allow multiple Zookeeper servers in endpoint
Hi I have fixed a minor issue in the camel-zookeeper component to allow connecting to a cluster of Zookeeper servers by using the comma-separated syntax in the endpoint string. I pushed the change to github: https://github.com/klauss42/camel/commit/7f22df2cdf8da4ada20017e57259ee2967b95908 Would be nice if the change could be integrated in one of the next Camel releases thanks Klaus -- View this message in context: http://camel.465427.n5.nabble.com/camel-zookeeper-Allow-multiple-Zookeeper-servers-in-endpoint-tp5745095.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel-zookeeper: Allow multiple Zookeeper servers in endpoint
Hi Klaus, Thanks for your contribution, I’m reviewing your patch. It will be commit to the camel repo shortly. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com(http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com(http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo: 姜宁willem On December 20, 2013 at 4:33:09 PM, Klaus Schroeder (klasc...@gmail.com) wrote: Hi I have fixed a minor issue in the camel-zookeeper component to allow connecting to a cluster of Zookeeper servers by using the comma-separated syntax in the endpoint string. I pushed the change to github: https://github.com/klauss42/camel/commit/7f22df2cdf8da4ada20017e57259ee2967b95908 Would be nice if the change could be integrated in one of the next Camel releases thanks Klaus -- View this message in context: http://camel.465427.n5.nabble.com/camel-zookeeper-Allow-multiple-Zookeeper-servers-in-endpoint-tp5745095.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: camel-zookeeper: ZooKeeperProducer does implement doStop()
Hi Klaus, Thanks for your contribution, I’m reviewing your patch. It will be commit to the camel repo shortly. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com(http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com(http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo: 姜宁willem On December 20, 2013 at 4:33:16 PM, Klaus Schroeder (klasc...@gmail.com) wrote: Hi the ZooKeeperProducer class does not stop/close the Zookeeper connections properly when stopped. After closing the Camel context, the connection threads still remain active. I fixed this and pushed to github: https://github.com/klauss42/camel/commit/491e07dbb941818b00fec9cfa256931e78dd480a and https://github.com/klauss42/camel/commit/65fde427ce531f239d24dc367cb460a0cb36d319 Please integrate in one of the next Camel releases thanks Klaus -- View this message in context: http://camel.465427.n5.nabble.com/camel-zookeeper-ZooKeeperProducer-does-implement-doStop-tp5745096.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to monitor number of open files in camel?
On Fri, Dec 20, 2013 at 7:57 AM, Bharath bharath4...@gmail.com wrote: Number of open files in the sense the files which are in process Questions on Hawtio: I am using Fuse ESB Enterprise which is running as fabric containers I installed hawtio feature to this fabric containers I am not getting fabric option in the browser As per the documentation i could see Currently this hawtio plugin requires JBoss Fuse 6.1 or later. For earlier versions of Fuse, hawtio works great for Camel, ActiveMQ, OSGi, JMX and so forth; but hawtio requires the new JMX MBean in version 6.1 of Fuse Fabric to enable the Fabric plugin. I referred http://hawt.io/plugins/fabric/ Ah yeah the fabric plugin itself, yeah sorry, that relies on new logic needed which is introduced in Fabric 6.1. But the other plugins for AMQ, Camel, et all should work with older releases of Camel, AMQ and so forth. Though this is the mailing list for Apache Camel, if you or others is talking about hawtio (when its not related to Camel), then its better to talk at the hawtio community http://hawt.io/community/index.html Cheers!!! Bharath.R -- View this message in context: http://camel.465427.n5.nabble.com/How-to-monitor-number-of-open-files-in-camel-tp5745033p5745089.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
How to read aggregation from HawtDB when Camel cannot read it by index
Hi Camel users I am trying to recover data from a Camel aggregator persistent hawtdb repository (Camel 2.9.x). The aggregator was killed unexpectedly because of an out-of-memory-error. I wrote a small Java class that opens the hawtdb file, creates a HawtDBAggregationRepository instance that uses the file and tried to get the index keys and aggregations from it. I was able to get almost all aggregations from it, only two of them throw the exception below when I try to access them. Can I access them in another way to recover the aggregated data? Thanks for any help Stephan WARN | HawtDBFile | Error executing work Getting key [7601003010220_XML400]. Will do rollback. org.fusesource.hawtdb.api.IndexException: java.io.EOFException at org.fusesource.hawtdb.api.AbstractStreamPagedAccessor.load(AbstractStreamPagedAccessor.java:66) at org.fusesource.hawtdb.internal.index.BTreeIndex.loadNode(BTreeIndex.java:238) at org.fusesource.hawtdb.internal.index.BTreeNode.getChild(BTreeNode.java:261) at org.fusesource.hawtdb.internal.index.BTreeNode.getLeafNode(BTreeNode.java:772) at org.fusesource.hawtdb.internal.index.BTreeNode.get(BTreeNode.java:652) at org.fusesource.hawtdb.internal.index.BTreeIndex.get(BTreeIndex.java:85) at org.apache.camel.component.hawtdb.HawtDBAggregationRepository$2.execute(HawtDBAggregationRepository.java:150) at org.apache.camel.component.hawtdb.HawtDBAggregationRepository$2.execute(HawtDBAggregationRepository.java:144) at org.apache.camel.component.hawtdb.HawtDBFile.doExecute(HawtDBFile.java:165) at org.apache.camel.component.hawtdb.HawtDBFile.execute(HawtDBFile.java:119) at org.apache.camel.component.hawtdb.HawtDBAggregationRepository.get(HawtDBAggregationRepository.java:144) at ch.visana.ke.concierge.VisanaHawtDbRecovery.readExchangeByKeyFromRepository(VisanaHawtDbRecovery.java:81) at ch.visana.ke.concierge.VisanaHawtDbRecovery.testGetAggregationExchangeByKey(VisanaHawtDbRecovery.java:70) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:44) at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15) at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:41) at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:20) at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:28) at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:31) at org.junit.rules.TestWatchman$1.evaluate(TestWatchman.java:48) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:76) at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50) at org.junit.runners.ParentRunner$3.run(ParentRunner.java:193) at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:52) at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:191) at org.junit.runners.ParentRunner.access$000(ParentRunner.java:42) at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:184) at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:31) at org.junit.runners.ParentRunner.run(ParentRunner.java:236) at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50) at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:467) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:683) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:390) at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:197) Caused by: java.io.EOFException at org.fusesource.hawtdb.internal.page.ExtentInputStream.read(ExtentInputStream.java:80) at java.io.DataInputStream.readFully(DataInputStream.java:178) at java.io.DataInputStream.readFully(DataInputStream.java:152) at org.fusesource.hawtbuf.codec.AbstractBufferCodec.decode(AbstractBufferCodec.java:40) at org.fusesource.hawtbuf.codec.AbstractBufferCodec.decode(AbstractBufferCodec.java:30) at org.fusesource.hawtdb.internal.index.BTreeNode.read(BTreeNode.java:207) at org.fusesource.hawtdb.internal.index.BTreeNode$DataPagedAccessor.decode(BTreeNode.java:228) at org.fusesource.hawtdb.internal.index.BTreeNode$DataPagedAccessor.decode(BTreeNode.java:214) at org.fusesource.hawtdb.api.AbstractStreamPagedAccessor.load(AbstractStreamPagedAccessor.java:64) ... 38 more
Printing with Camel
Hi all, I am printing via camel using the function sendBodyAndHeaders. I tried to print using my PDF printer on Mac and it does perfectly. When I tried it in my Toshiba network printer it does the printing but a part of the upper and left part missed during printing (it does not respect the indent of the page). Do you think something in the Camel configuration should change? Any one have an idea how to set the indent and the margin? regards, -- View this message in context: http://camel.465427.n5.nabble.com/Printing-with-Camel-tp5745102.html Sent from the Camel - Users mailing list archive at Nabble.com.
@MockEndpointsAndSkip appears to not mock all endpoints when testing with Spring
Hi,
I am using Camel 2.12.2 and Spring 3.2.4. I have the following route
definition:
camelContext xmlns=http://camel.apache.org/schema/spring;
route id=route1
from uri=direct:route1 /
to uri=direct:route2/
/route
/camelContext
My expectation would be that the following test succeeds:
@RunWith(CamelSpringJUnit4ClassRunner.class)
@ContextConfiguration
@MockEndpointsAndSkip
public class RouteTest {
@Produce(uri=direct:route1) private ProducerTemplate producer;
@EndpointInject(uri=mock:direct:route2) private MockEndpoint endpoint;
@Test public void test_fails() throws Exception {
final Object body = new Integer(42);
endpoint.expectedBodiesReceived(body);
producer.sendBody(body);
endpoint.assertIsSatisfied(); // fails, 0 messages received
}
}
The test succeeds when I use @MockEndpointsAndSkip(direct:route2) instead.
Manipulating the route definition with the AdviceWithRouteBuilder works as
well:
context.getRouteDefinition(route1).adviceWith(context, new
AdviceWithRouteBuilder() {
@Override public void configure() throws Exception {
mockEndpointsAndSkip(*);
}
});
Is that intended?
--
View this message in context:
http://camel.465427.n5.nabble.com/MockEndpointsAndSkip-appears-to-not-mock-all-endpoints-when-testing-with-Spring-tp5745105.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: @MockEndpointsAndSkip appears to not mock all endpoints when testing with Spring
Maybe try with
@MockEndpointsAndSkip(*)
On Fri, Dec 20, 2013 at 12:31 PM, sebh sebastian.haeh...@gmail.com wrote:
Hi,
I am using Camel 2.12.2 and Spring 3.2.4. I have the following route
definition:
camelContext xmlns=http://camel.apache.org/schema/spring;
route id=route1
from uri=direct:route1 /
to uri=direct:route2/
/route
/camelContext
My expectation would be that the following test succeeds:
@RunWith(CamelSpringJUnit4ClassRunner.class)
@ContextConfiguration
@MockEndpointsAndSkip
public class RouteTest {
@Produce(uri=direct:route1) private ProducerTemplate producer;
@EndpointInject(uri=mock:direct:route2) private MockEndpoint
endpoint;
@Test public void test_fails() throws Exception {
final Object body = new Integer(42);
endpoint.expectedBodiesReceived(body);
producer.sendBody(body);
endpoint.assertIsSatisfied(); // fails, 0 messages received
}
}
The test succeeds when I use @MockEndpointsAndSkip(direct:route2) instead.
Manipulating the route definition with the AdviceWithRouteBuilder works as
well:
context.getRouteDefinition(route1).adviceWith(context, new
AdviceWithRouteBuilder() {
@Override public void configure() throws Exception {
mockEndpointsAndSkip(*);
}
});
Is that intended?
--
View this message in context:
http://camel.465427.n5.nabble.com/MockEndpointsAndSkip-appears-to-not-mock-all-endpoints-when-testing-with-Spring-tp5745105.html
Sent from the Camel - Users mailing list archive at Nabble.com.
--
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
Make your Camel applications look hawt, try: http://hawt.io
Re: Printing with Camel
Hi The camel-printer component has these options http://camel.apache.org/printer It uses the java printer api, and it has many options AFAIR. Though maybe try to see if one of the mediaSize fits you, eg A4 vs US-A4 or what they are named. They can have different margins. If not you may drill down in the java printer api and find details about how to set margins etc. We could maybe expose more options out of the box in camel-printer to easily set those. Though they key thing to find is what API in java printer to use for doing what you need. If you find this, then let us know, then we can likely improve camel-printer component to make this easier to configure for you and others. On Fri, Dec 20, 2013 at 11:52 AM, joe.sat yousof.alsa...@akquinet.de wrote: Hi all, I am printing via camel using the function sendBodyAndHeaders. I tried to print using my PDF printer on Mac and it does perfectly. When I tried it in my Toshiba network printer it does the printing but a part of the upper and left part missed during printing (it does not respect the indent of the page). Do you think something in the Camel configuration should change? Any one have an idea how to set the indent and the margin? regards, -- View this message in context: http://camel.465427.n5.nabble.com/Printing-with-Camel-tp5745102.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: @MockEndpointsAndSkip appears to not mock all endpoints when testing with Spring
I tried that, doesn't work either. -- View this message in context: http://camel.465427.n5.nabble.com/MockEndpointsAndSkip-appears-to-not-mock-all-endpoints-when-testing-with-Spring-tp5745105p5745116.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Oracle Procedure Calls with Camel
Hi CAMEL-4725 is not implemented in any Camel version. We love contributions, so anyone can help implement the logic needed. You can use camel-mybatis as MyBatis support stored procedures http://camel.apache.org/mybatis On Fri, Dec 20, 2013 at 1:55 PM, james555 luke...@gmx.net wrote: is it possible calling Oracle PL/SQL procedure/function calls with camel ? Since I've read https://issues.apache.org/jira/browse/CAMEL-4725 it should be fixed in Version 2.12.0 but I couldnt see it in the release notes ?! If it is already fixed, do you have an example for me ? The Documenttion of Component jdbc / sql doesn's say anything about it. -- View this message in context: http://camel.465427.n5.nabble.com/Oracle-Procedure-Calls-with-Camel-tp5745115.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: @MockEndpointsAndSkip appears to not mock all endpoints when testing with Spring
Check the unit tests to see what they do. On Fri, Dec 20, 2013 at 1:57 PM, sebh sebastian.haeh...@gmail.com wrote: I tried that, doesn't work either. -- View this message in context: http://camel.465427.n5.nabble.com/MockEndpointsAndSkip-appears-to-not-mock-all-endpoints-when-testing-with-Spring-tp5745105p5745116.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
RE: Oracle Procedure Calls with Camel
Yes,
Using spring DSL
setBody
simple exec myStoreProcedure('')/simple
/setBody
to uri:JDBC:Datasource /
Where Datasource is a bean
-Original Message-
From: james555 [mailto:luke...@gmx.net]
Sent: Friday, December 20, 2013 7:55 AM
To: users@camel.apache.org
Subject: Oracle Procedure Calls with Camel
is it possible calling Oracle PL/SQL procedure/function calls with camel ?
Since I've read https://issues.apache.org/jira/browse/CAMEL-4725 it should be
fixed in Version 2.12.0 but I couldnt see it in the release notes ?!
If it is already fixed, do you have an example for me ? The Documenttion of
Component jdbc / sql doesn's say anything about it.
--
View this message in context:
http://camel.465427.n5.nabble.com/Oracle-Procedure-Calls-with-Camel-tp5745115.html
Sent from the Camel - Users mailing list archive at Nabble.com.
___
This message is for information purposes only, it is not a recommendation,
advice, offer or solicitation to buy or sell a product or service nor an
official confirmation of any transaction. It is directed at persons who are
professionals and is not intended for retail customer use. Intended for
recipient only. This message is subject to the terms at:
www.barclays.com/emaildisclaimer.
For important disclosures, please see:
www.barclays.com/salesandtradingdisclaimer regarding market commentary from
Barclays Sales and/or Trading, who are active market participants; and in
respect of Barclays Research, including disclosures relating to specific
issuers, please see http://publicresearch.barclays.com.
___
Route message based on Tag Value - Apache Camel Spring
I am trying to learn Apache Camel Routes. For a basic example, I would like
to know how to route based on values in an XML tag. For example, if we have
3 xml files with parent tags:
item type=n1 /item type=n2 /item type=n3 /
I want to route these 3 into 3 different pipes...
so here is my idea (in Spring):
route id=NormalizeMessageData
from uri=jms:incomingOrders /convertBodyTo type=java.lang.String /
choicewhen
simple${body} contains '?xml'/simple !-- to make sure its xml
file only --
*
*
*
unmarshal
jaxb contextPath=org.fusesource.camel /
/unmarshal
to uri=jms:orders //when/choice
see the stars (*), this is where we need to put some checking. But how?
--
Regards,
Raheel Hasan
Re: Splitting, processing and aggregating a list
I found this old post while I was trying to do same thing but using a class
that extends AbstractListAggregationStrategy to rebuild a List after the
completion of the split.
Using this aggregator way of doing, I found a problem : at the end of the
split, the body is not replaced by the agregated list -
AbstractListAggregationStrategy.onCompletion(Exchange exchange) is never
called.
Here is what I do :
from(HANDLE_A_LIST)//
.split(body(), new ListAggregationStrategy())// body is an
arrayList of String
.to(log:foo)//
.end()// end split
// the body is a string instead of a List
.end()// end route
class ListAggregationStrategy extends
AbstractListAggregationStrategyString
{
@Override
public String getValue(Exchange exchange)
{
return exchange.getIn().getBody();
}
}
Is it a bug ?
As workaround, I use .setBody(property(Exchange.GROUPED_EXCHANGE)) after the
end of the split.
Kind Regards,
Yves.
--
View this message in context:
http://camel.465427.n5.nabble.com/Splitting-processing-and-aggregating-a-list-tp5716013p5745127.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Zipping multiple files to one Zip-File
Dear Community,
I'm new to Camel (2.12.0) and like it very much. I'm trying to build a zip
route which handles a lot of PDF-Files and zip them all together to one
Zip-File. No success so far :-(
from(direct:zip)
.from(file:c:/temp/camel/batch/result?move=.movedinclude=.*pdf)
.marshal().zipFile()
.to(file:c:/temp/camel/batch/result/zip?fileName=${file:name});
at the end, i'm getting one zip for every pdf file.
Is my approach completely wrong?
Best regards
Alex (from Germany)
--
View this message in context:
http://camel.465427.n5.nabble.com/Zipping-multiple-files-to-one-Zip-File-tp5745128.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to set proxy excludes on http component?
Hi Henrique, Unless something has changed from the discussion in this thread, camel does not respect the http proxy system properties. The properties must be set in the camel context, not as a java system property. Also, the http.nonProxyHosts is ignored when set in the camel context or system property as noted in this thread and in my personal trials. Thanks, -- View this message in context: http://camel.465427.n5.nabble.com/How-to-set-proxy-excludes-on-http-component-tp5726744p5745139.html Sent from the Camel - Users mailing list archive at Nabble.com.
AW: Zipping multiple files to one Zip-File
I am missing a part which Camel instructs to collect the exchanges and not
to process every for its own ...
Jan
-Ursprüngliche Nachricht-
Von: alex [mailto:alex.koe...@gmx.de]
Gesendet: Freitag, 20. Dezember 2013 16:39
An: users@camel.apache.org
Betreff: Zipping multiple files to one Zip-File
Dear Community,
I'm new to Camel (2.12.0) and like it very much. I'm trying to build a
zip route which handles a lot of PDF-Files and zip them all together to
one Zip-File. No success so far :-(
from(direct:zip)
.from(file:c:/temp/camel/batch/result?move=.movedinclude=.*pdf
)
.marshal().zipFile()
.to(file:c:/temp/camel/batch/result/zip?fileName=${file:name});
at the end, i'm getting one zip for every pdf file.
Is my approach completely wrong?
Best regards
Alex (from Germany)
--
View this message in context:
http://camel.465427.n5.nabble.com/Zipping-multiple-files-to-one-Zip-
File-tp5745128.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Zipping multiple files to one Zip-File
You'll need the aggregator EIP, http://camel.apache.org/aggregator2.html.
It's a perfect fit for this case.
On Fri, Dec 20, 2013 at 4:39 PM, alex alex.koe...@gmx.de wrote:
Dear Community,
I'm new to Camel (2.12.0) and like it very much. I'm trying to build a zip
route which handles a lot of PDF-Files and zip them all together to one
Zip-File. No success so far :-(
from(direct:zip)
.from(file:c:/temp/camel/batch/result?move=.movedinclude=.*pdf)
.marshal().zipFile()
.to(file:c:/temp/camel/batch/result/zip?fileName=${file:name});
at the end, i'm getting one zip for every pdf file.
Is my approach completely wrong?
Best regards
Alex (from Germany)
--
View this message in context:
http://camel.465427.n5.nabble.com/Zipping-multiple-files-to-one-Zip-File-tp5745128.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Acknowledgement to JMS Topic on activemq
A couple of additional notes: Camel SJMS does have an issue identified with the aggregator and JMS transactions. SJMS is currently closing the transaction, batch included, as the messages pass through the route. It doesn't recognize the fact that an aggregator is participating in the route which is effectively holding copies of the messages. This gap can cause a loss of messages should there be a failure in the aggregator if the batch number has been met. I am going to be looking at this over the break and hopefully come up with a solution. I will be spending my down time over the holidays taking a look at this issue to see if it can be be solved before the introduction of JTA to the Camel project. Best Regards, Scott ES On Wed, Dec 18, 2013 at 2:00 AM, Claus Ibsen claus.ib...@gmail.com wrote: You can use transacted acknowledge mode with the camel-jms component. Just set transacted=true, and setup the TX stuff. http://camel.apache.org/jms http://camel.apache.org/transactional-client.html Mind that camel-jms only supports one message at a time, eg consume one message in a TX. The other camel-sjms has some support for batch consuming, but this component is not as hardened as the camel-jms one. On Tue, Dec 17, 2013 at 5:06 PM, Sri sri.tec...@googlemail.com wrote: Hi All, I am consuming message from a topic and wanted send it to SOLR server as a batch for a commit as committing on SOLR is expensive operation. How ever I wanted to keep the message on the topic till the commit operation completes successfully. I want to send successful acknowledgement in that case otherwise no acknowledgement. I am using aggregator for batching the messages how ever I couldn't get any hold acknowledgement. Aggregator sends successful acknowledgement as soon as it reads from the topic. I do not want to loose any messages if by any chance SOLR doesn't commit successfully. Your help will be much appreciated. Thanks Sri -- View this message in context: http://camel.465427.n5.nabble.com/Acknowledgement-to-JMS-Topic-on-activemq-tp5744954.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io -- -- Scott England-Sullivan Apache Camel Committer Principal Consultant / Sr. Architect | Red Hat, Inc. FuseSource is now part of Red Hat Web: fusesource.com http://www.fusesource.com | redhat.comhttp://www.redhat.com Blog: sully6768.blogspot.com Twitter: sully6768
Can Camel process PGP files which would exceed available JVM memory?
We are looking at mule and camel and one feature which seemed promising in Camel was the PGP component. My simple tests seem to indicate that when decrypting a file, the entire contents are read into memory. We deal with huge files and it was pretty easy for me to produce an OutOfMemory exception. I am low on the Camel learning curve, but from what I have seen so far, the pgp component does not stream. Ideally I would like to write a custom bean which is given an InputStream which contains the decrypted pgp file contents. Is this possible? Dave -- View this message in context: http://camel.465427.n5.nabble.com/Can-Camel-process-PGP-files-which-would-exceed-available-JVM-memory-tp5745144.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Jetty component and overlapping urls when a consumer
It was my understanding of the contrary. I'm currently using servicemix where there are 20+ bundles each with a camel context and each of those with routes starting with a jetty consumer (eg: from uri=jetty:http:0.0.0.0:8080/... /). We haven't had any problems with each of these camel routes listening on the common 8080 port. In fact each of these routes are differentiated by a different context path (eg: jetty:http://0.0.0.0:8080/a vs jetty:http://0.0.0.0:8080/b) and it all seems to route correctly. Also with current versions of servicemix there is a commons configuration of jetty.xml which I believed to be the configuration of the common jetty server for all inbound from uri=jetty:... / requests. I thought the jetty Camel Component is able to do this via a single jetty server that is started up on servicemix and where each bundle (via the jetty Camel Component) registers a CamelContinuationServlet. Am I wrong with any of this? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Jetty-component-and-overlapping-urls-when-a-consumer-tp5745068p5745145.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Camel Jetty component and overlapping urls when a consumer
No you are correct, the camel-jetty component can share the same port across bundles. On Sat, Dec 21, 2013 at 1:52 AM, samslara samsl...@yahoo.com wrote: It was my understanding of the contrary. I'm currently using servicemix where there are 20+ bundles each with a camel context and each of those with routes starting with a jetty consumer (eg: from uri=jetty:http:0.0.0.0:8080/... /). We haven't had any problems with each of these camel routes listening on the common 8080 port. In fact each of these routes are differentiated by a different context path (eg: jetty:http://0.0.0.0:8080/a vs jetty:http://0.0.0.0:8080/b) and it all seems to route correctly. Also with current versions of servicemix there is a commons configuration of jetty.xml which I believed to be the configuration of the common jetty server for all inbound from uri=jetty:... / requests. I thought the jetty Camel Component is able to do this via a single jetty server that is started up on servicemix and where each bundle (via the jetty Camel Component) registers a CamelContinuationServlet. Am I wrong with any of this? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Jetty-component-and-overlapping-urls-when-a-consumer-tp5745068p5745145.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: Camel Jetty component and overlapping urls when a consumer
On Thu, Dec 19, 2013 at 9:16 PM, samslara samsl...@yahoo.com wrote: Hello, I have a question about the behavior of the jetty component when in an OSGi environment (such as in ServiceMix). If I have two bundles each with a camel context where one has a route such as: from uri=jetty:http://0.0.0.0:8080// ... and the other has a route such as: from uri=jetty:http://0.0.0.0:8080/application1/ ... and I call the container with http://myip:8080/application1/a/b/c Because of the overlapping url but with the second route being more specific will this request go to the 2nd route, the 1st route, randomly to either or will something else occur? The urls is not overlapping, the 1st is only matched if a client connects to / And the 2nd is only matched when you hit /application1. You need to use matchOnUriPrefix to allow matching on wildcards, see more details at http://camel.apache.org/jetty -- View this message in context: http://camel.465427.n5.nabble.com/Camel-Jetty-component-and-overlapping-urls-when-a-consumer-tp5745068.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
Re: How to set proxy excludes on http component?
On Fri, Dec 20, 2013 at 12:40 AM, JaredBoucher jboucher1...@gmail.com wrote: Hi Willem, I have a requirement for my current project using camel to be able to exclude internal hosts in our network from a proxy which allows outbound traffic. All external traffic would go through the proxy. Is there any plans to support proxy exclusions in the camel context for the HttpComponent/HttpEndpoint in the near future, as this would be very useful for our requirements. You should log a JIRA ticket and as we love contributions people is welcome to work on a patch http://camel.apache.org/contributing.html Then we can have some new options to set the exclude host name(s) http://camel.apache.org/http Thank you, -- View this message in context: http://camel.465427.n5.nabble.com/How-to-set-proxy-excludes-on-http-component-tp5726744p5745070.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen Make your Camel applications look hawt, try: http://hawt.io
