Re: Instagram Component ?

[Christian Müller]

Good idea.
And don't forget to file a JIRA first:
https://issues.apache.org/jira/browse/CAMEL

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Thu, Mar 31, 2016 at 3:07 PM, Mark  wrote:

> Thank you for the information.  I will continue moving along with this
> component.
>
> On Thu, Mar 31, 2016 at 7:13 AM, Claus Ibsen 
> wrote:
>
> > Yeah it is, you can see which ones are valid at
> > http://www.apache.org/legal/resolved.html#category-a
> >
> > And there is a guide for developing a new component here
> > http://camel.apache.org/add-new-component-guide.html
> >
> > On Thu, Mar 31, 2016 at 12:44 PM, Mark  wrote:
> > > I have been evaluating jinstagram.  Is the MIT license compatible for
> > > inclusion into Apache Camel?
> > >
> > >
> > >
> > > On Wed, Mar 30, 2016 at 5:30 PM, Bilgin Ibryam 
> > wrote:
> > >
> > >> In the past I used jinstagram from Camel, but never seen a componet.
> > >> Will be nice to have one.
> > >>
> > >> B.
> > >>
> > >> On 28 March 2016 at 02:56, Mark  wrote:
> > >> > I'm currently investigating whether to use a 3rd party Java
> Instagram
> > API
> > >> > or write one from scratch for this component.  None that I've found
> > work
> > >> > really well and have an Apache-friendly license.
> > >> >
> > >> >
> > >> >
> > >> >
> > >> > On Sat, Mar 26, 2016 at 1:32 AM, Claus Ibsen  >
> > >> wrote:
> > >> >
> > >> >> Hi
> > >> >>
> > >> >> Yeah we do not have such a component. And it would be great to have
> > one.
> > >> >>
> > >> >> We love contributions
> > >> >> http://camel.apache.org/contributing
> > >> >>
> > >> >>
> > >> >> On Fri, Mar 25, 2016 at 7:49 PM, Matt Sicker 
> > wrote:
> > >> >> > No, there isn't an official component, and I don't see any third
> > party
> > >> >> > ones, either.
> > >> >> >
> > >> >> > On 25 March 2016 at 13:40, Mark  wrote:
> > >> >> >
> > >> >> >> I'm wondering if there is an Instagram component in Camel.  If
> not
> > >> I'd
> > >> >> like
> > >> >> >> to start work on one and can submit a pull request back to the
> > >> baseline.
> > >> >> >>
> > >> >> >
> > >> >> >
> > >> >> >
> > >> >> > --
> > >> >> > Matt Sicker 
> > >> >>
> > >> >>
> > >> >>
> > >> >> --
> > >> >> Claus Ibsen
> > >> >> -
> > >> >> http://davsclaus.com @davsclaus
> > >> >> Camel in Action 2: https://www.manning.com/ibsen2
> > >> >>
> > >>
> > >>
> > >>
> > >> --
> > >> Bilgin Ibryam
> > >> Camel Committer at ASF & Integration Architect at Red Hat
> > >> Blog: http://ofbizian.com | Twitter: @bibryam
> > >>
> > >> Camel Design Patterns https://leanpub.com/camel-design-patterns
> > >> Instant Apache Camel Message Routing
> > http://www.amazon.com/dp/1783283475
> > >>
> >
> >
> >
> > --
> > Claus Ibsen
> > -
> > http://davsclaus.com @davsclaus
> > Camel in Action 2: https://www.manning.com/ibsen2
> >
>

Re: Camel Design Patterns ebook

[Christian Müller]

Well done!

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Fri, Apr 1, 2016 at 3:58 PM, Bilgin Ibryam  wrote:

> Hi Camel riders,
>
> tl;dr - check the sample [4] and ToC at the end of the PDF.
>
> This is a quick heads up about the Camel ebook I published recently.
> It is on Amazon [1] and LeanPub [2] and I believe it is very relevant
> for the users on this list.
>
> I've been using Camel for a number of years now and I've seen tens of
> different projects with different customers. Regardless of the stack
> and the architecture, Camel has always been the key to the timely
> delivery of the projects and source of joy for developers (that latter
> might be my perception since my bias though).
>
> During the years I've been getting many questions around designing and
> best practises with Camel based applications. I regularly blog about
> my Camel experiences [3], but this time thought that it is more than a
> blog post or two. So, during the last couple of month I manged to put
> my experiences with Camel into an e-book. It doesn't contain any Camel
> syntax, code examples, or EIP explanations. Instead it contains common
> patterns, use cases, (best) practises, tips to be aware of. It has
> around 20 patterns/practises/use cases, with diagrams explained over
> 35K words.
>
> I cover concepts such as VETRO, Reusable routes, Error Handling,
> Compensating Transactions, Circuit Breaker (hey have you tried the
> Camel-Hystrix connector in master?), different types of retries, etc.
>
> A free sample chapter is available here [4]. If interested, also check
> the list of patterns at the end of the book to get a better idea.
>
> [1] http://www.amazon.co.uk/gp/product/B01D1RERQG
>
> [2] https://leanpub.com/camel-design-patterns
>
> [3] http://www.ofbizian.com
>
> [4] http://samples.leanpub.com/camel-design-patterns-sample.pdf
>
>
> I've enjoying writing it. Hope you find it useful too.
>
> --
> Bilgin Ibryam
> Camel Committer at ASF & Integration Architect at Red Hat
> Blog: http://ofbizian.com | Twitter: @bibryam
>
> Camel Design Patterns https://leanpub.com/camel-design-patterns
> Instant Apache Camel Message Routing http://www.amazon.com/dp/1783283475
>

Re: statement.maxRows not working as expected camel jdbc

[Christian Müller]

Greg and Claus was faster to fix it than me. :-)
You can try the fix with the latest 2.17-SNAPSHOT, 2.16.2-SNAPSHOT or
2.15.6-SNAPSHOT.

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Fri, Jan 8, 2016 at 9:21 AM, fxthomas  wrote:

> hello Christain,
>
> Have created the JIRA https://issues.apache.org/jira/browse/CAMEL-9491
>
> thanks
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/statement-maxRows-not-working-as-expected-camel-jdbc-tp5775898p5776003.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: statement.maxRows not working as expected camel jdbc

[Christian Müller]

Hi Felix,

I have a unit test which confirms your finding. Could you please open an
JIRA and post the ticket number here. I will have a closer look during the
next days.
As workaround, you could also set the limit in the SQL query. Something
like: select * from TBL_DATA_AC LIMIT 2

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Wed, Jan 6, 2016 at 4:04 PM, Felix Thomas  wrote:

> hello,
>
>   I have an issue (not sure if its a bug)  in camel. I have tested in
> multiple versio*n i.e. 2.15.1,2.16.0,2.16.1 *also but still the same
> result.
>
>   I have a route defined below in spring XML . When i start the camel
> instance it works fine at the first time i.e it fetches only 2 records as
> expected . But  when the timer kicks in after 1 minute again it fetchs all
> the rows in the table . I expect it to fetch only 2 again. Is there an
> issue in my route definition ??
>
>
> http://camel.apache.org/schema/spring;>
> 
> 
> select * from TBL_DATA_AC
> 
>
>  uri="jdbc:DSROUTE_TBL_DATA_AC?*statement.maxRows=2&*amp;outputType=StreamList"
> id="to8"/>
> 
> ${body}
> 
>  executorServiceRef="customThreadPoolProfile" id="multicast1">
> 
> 
> uri="rabbitmq://localhost/QUEUE?autoDelete=falseautoAck=falsequeue=DEVusername=guestpassword=guestroutingKey=DEVdurable=true"
> id="to9"/>
> 
> 
> 
> 
>
>
>
> regards,
> Felix
>

Re: [ANNOUNCEMENT] Apache Camel 2.14.4 Released

[Christian Müller]

Great!

On Wed, Nov 11, 2015 at 11:55 PM, Gregor Zurowski 
wrote:

> The Apache Camel community announces the immediate availability of the
> new patch release Apache Camel 2.14.4. This release contains 18 fixes
> applied in the past few weeks by the community on the Camel 2.14.x
> maintenance branch. We expect this to be the last patch release for
> the 2.14.x branch.
>
> The artifacts are published and ready for you to download [1] either
> from the Apache mirrors or from the Maven Central repository. For more
> details please take a look at the release notes [2, 3].
>
> Many thanks to all who made this release possible.
>
> On behalf of the Camel PMC,
> Gregor Zurowski
>
> [1] http://camel.apache.org/download.html
> [2] http://camel.apache.org/camel-2144-release.html
> [3]
> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211=12332478
>

Re: Unit testing Fuse (Karaf) with camel implemented in blueprint (shortcoming 1)

[Christian Müller]

But than it's an integration test (or something similar) and not an unit
test...

Best,
Christian
Am 21.09.2015 16:45 schrieb "ywang9009" :

> Christian, thanks for the reply. Yes I was talking about inter-bundle
> dependency. One example is like this: I have some common code which lives
> in
> another bundle so the current bundle depends on that bundle. I can't unit
> test the code in this bundle unless the common code bundle is loaded. I
> have
> seen example of using pax-exam, but I couldn't get it to work. Do you have
> any suggestion to address this scenario? Thanks
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Unit-testing-Fuse-Karaf-with-camel-implemented-in-blueprint-shortcoming-1-tp5771641p5771717.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: smpp connection info

[Christian Müller]

This is not possible. The underlying jsmpp library doesn't support a
feature like that.

Best,
Christian
Am 21.09.2015 12:22 schrieb "Bova Fabrizio" :

> Hi
> I am trying some performance test on camel.version 2.15.3 running on
> apache-karaf-3.0.4 I have this route:
>
>  xmlns="http://camel.apache.org/schema/blueprint;>
>  
>  uri="jms:tibcoRequest?concurrentConsumers=30asyncConsumer=trueasyncStartListener=true"
> />
>  uri="smpp://smppclient@localhost:23000?password=passwordenquireLinkTimer=3000transactionTimer=5000systemType=producerregisteredDelivery=0"
> />
> 
>  
>
>
> I see that there are 30 threads that take messages from jms:tibcoRequest
> queue and all of them send to smpp the messages correctly, but I see only
> one connection opened on SMSC server.
> How can I configure on Camel route in order to allow camel  smpp opening
> more than one connection (e.g. one per thread)?
>
> Thanks in advance
> Regards
>
> Fabrizio Bova
>

Re: how to get loginConfig into standalone camel salesforce component

[Christian Müller]

Did you checked the tests for this component?

Best,
Christian
Am 21.09.2015 07:27 schrieb "rpcat" :

> My standalone camel instance needs a salesforce component. It has:
>
> public class Driver
> {
> private Main main;
> static final Logger log = LoggerFactory.getLogger(Driver.class);
>
> public void startDriver() throws Exception
> {
> main = new Main();
> main.enableHangupSupport(); //so you can press ctrl-c
> to terminate the jvm
> ...
> SalesforceLoginConfig loginConfig = new
> SalesforceLoginConfig(
> loginUrl, clientId, clientSecret, userName, password,
> lazyLogin);
>
> SalesforceComponent component = new SalesforceComponent();
> component.setLoginConfig(loginConfig);
>
> component.setPackages(new
> String[]{Program_Schedule__c.class.getPackage().getName()});
>
> main.getOrCreateCamelContext().addComponent(componentName,
> component);
> main.addRouteBuilder(new RoutePollSalesforce());
>
> but when i start up the route there's no loginConfig:
>
> Caused by: org.apache.camel.RuntimeCamelException: Cannot auto create
> component: salesforce
> at
>
> org.apache.camel.impl.DefaultCamelContext.getComponent(DefaultCamelContext.java:400)
> at
>
> org.apache.camel.impl.DefaultCamelContext.getComponent(DefaultCamelContext.java:376)
> at
>
> org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:548)
> ... 25 more
> Caused by: java.lang.IllegalArgumentException: loginConfig must be
> specified
> at
> org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:293)
> at
>
> org.apache.camel.component.salesforce.SalesforceComponent.doStart(SalesforceComponent.java:175)
> at
> org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> at
>
> org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:2885)
> at
>
> org.apache.camel.impl.DefaultCamelContext.getComponent(DefaultCamelContext.java:395)
> ... 27 more
> [  Thread-0] MainSupport$HangupInterceptor  INFO
> Received hang up - stopping the main instance.
>
> suggestions would be greatly appreciated.
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/how-to-get-loginConfig-into-standalone-camel-salesforce-component-tp5771694.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: rabbitMQ message forwarding from one queue to another

[Christian Müller]

And there is no log entry?

Best,
Christian
Am 20.09.2015 09:15 schrieb "prajath" :

> Hi Christian,
> message is not publishing from queue 'inbox' to 'outbox'
>
> 1.timer publish current date to queue 'inbox'- this part working
> 2.from 'inbox' to 'outbox' - this is not working
>
>
>
>
> Thanks,
> Pramod
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/rabbitMQ-message-forwarding-from-one-queue-to-another-tp5771632p5771686.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: Unit testing Fuse (Karaf) with camel implemented in blueprint (shortcoming 1)

[Christian Müller]

If you are talking about inter-bundle dependencies, than it's not an unit
test, right.
What kind of issues do you face (details please).

Best,
Christian
Am 18.09.2015 16:13 schrieb "ywang9009" :

> This is one of the 2 shortcoming I discovered with Fuse/Karaf
>
> I have been using Fuse for only 1 year. What I have encountered is it lacks
> the ability to do unit testing because of inter-bundle dependencies. The
> concept is great, or better than the monlithic WAR/EAR deployment. Maybe
> someone else has figured out a way to do this. Please share. Thank you
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Unit-testing-Fuse-Karaf-with-camel-implemented-in-blueprint-shortcoming-1-tp5771641.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: rabbitMQ message forwarding from one queue to another

[Christian Müller]

Facing which problem?

Best,
Christian
Am 18.09.2015 13:20 schrieb "prajath" :

> Hi All,
> could you please help me to resolve the problem I am facing when forwarding
> message from one queue to another , please see the spring xml.
> thanks in advance
> prajath
> http://camel.apache.org/schema/spring;>
> 
> 
> uri="rabbitmq://localhost:5672/outBox?sername=guestpassword=guest"
> />
> 
> 
> 
> 
> uri="rabbitmq://localhost:5672/inbox?username=guestpassword=guest"
> />
> 
> uri="rabbitmq://localhost:5672/outBox?username=guestpassword=guest" />
> 
> 
> 
>
> 
> ${body}Message at
> ${date:now:-MM-dd HH:mm:ss}
> 
>
>  uri="rabbitmq://localhost:5672/inbox?username=guestpassword=guest" />
> 
>
>
> 
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/rabbitMQ-message-forwarding-from-one-queue-to-another-tp5771632.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: Getting JMSConsumer to look for messages every N seconds

[Christian Müller]

Or use the timer component to send a message each 10 seconds to a
processor. This processor could use a consumer template to poll the queue
in a loop and send the message to another camel route with a producer
template (using the direct component ).
The consumer template also has a timeout parameter. You can use it to break
out from the loop, if there is no message in the queue.

I think this is an easier - less sophisticated  - solution.

Best,
Christian
Am 27.08.2015 00:59 schrieb "Raul Kripalani" :

> Currently I think that we only support fixed schedules. So with the cron
> scheduler you could achieve something like: start/resume the route on every
> minute at 00 and 30 seconds, stop/suspend every minute at 10 and 40 seconds
> time marks.
>
> This would effectively keep your route running for 10 seconds every 30
> seconds.
>
> If you want something more sophisticated, like stopping it once the queue
> is empty, you would need to extend what we offer OOTB with your own logic.
>
> Maybe you want to stop the route when t be consumer has been inactive for 1
> second or 500ms, or when queue size is 0 at the broker (checking via JMX).
>
> Raúl.
> On 26 Aug 2015 23:19, "gilboy"  wrote:
>
> > Thanks for the feedback. So just to confirm if I have the following route
> > and
> > I want to consume a message every 30 seconds would I inject in to the
> route
> > a RoutePolicy(e.g. SimpleScheduledRoutePolicy) where I specify the
> > routeStartRepeatInterval(30 seconds). I feel like I am missing something.
> > What shuts down the route etc
> >
> > from("jms:endpointDetails")
> >.routeId("test")
> >.routePolicy(policy)
> >.to("mock:success");
> >
> > Thanks
> > Joe
> >
> >
> >
> > --
> > View this message in context:
> >
> http://camel.465427.n5.nabble.com/Getting-JMSConsumer-to-look-for-messages-every-N-seconds-tp5770986p5770997.html
> > Sent from the Camel - Users mailing list archive at Nabble.com.
> >
>

Re: kyro data format in camel

[Christian Müller]

Implement something more than what? You only shared the Spring bean
definition with us, nothing else.

Best,
Christian
Am 31.08.2015 10:21 schrieb "Felix Thomas" :

> hello,
>
>  I have used kyroformat for marshalling using a bean as below .
>
>  
>
>
>
>   I get the below message in the logs , not sure is its an issue or not
> , since i see the messages marshalled  in the queue..Do i need to implement
> something more
>
> DEBUG 28-08 16:50:19,456[main]
> [org.springframework.beans.factory.support.DefaultListableBeanFactory] |
> Failed to convert bean 'kyroFormat' to required type
> [org.apache.camel.model.DataFormatDefinition]
>
> *org.springframework.beans.ConversionNotSupportedException*: Failed to
> convert value of type 'com.XXX.camel.util.KyroDataFormat' to required type
> 'org.apache.camel.model.DataFormatDefinition'; nested exception is
> *java.lang.IllegalStateException*: Cannot convert value of type
> [com.XXX.camel.util.KyroDataFormat] to required type
> [org.apache.camel.model.DataFormatDefinition]: no matching editors or
> conversion strategy found
>
>at org.springframework.beans.TypeConverterSupport.doConvert(
> *TypeConverterSupport.java:74*)
>
>
>
> Rgrds
> Felix T
>

Re: Transactions without External Transaction Manager

[Christian Müller]

Yes.

Best,
Christian
Am 10.09.2015 15:53 schrieb "Rick Poleshuck" :

> My use is case is to read from a JMS queue and update two different jdbc
> tables with the same datasource. On failure of either update, both database
> actions should be rolled back and the message should be sent to a jms
> dead.letter queue.
>
> Do I need an external transaction manager to ensure that any messages
> received are either processed or end up on the dead.letter queue?
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Transactions-without-External-Transaction-Manager-tp5771407.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: Dynamic DataSource

[Christian Müller]

Is the dataSource configured in your context?

Best,
Christian
Am 10.09.2015 13:56 schrieb "arnaud" :

> Hello,
>
> Id'like to use a dynamic datasource with the camel-sql component but it's
> not woking as I expected:
> After a search on the forum, I have found a topic "Dynamic DataSource for
> SQL", I try to do something similar :
>
> from("direct:create")
> .setHeader("dataSource", constant("myDynamicDataSource"))
> .setHeader(SqlConstants.SQL_QUERY, simple("insert into customer(firstname,
> lastname) values(:?firstName, :?lastName)"))
> .setHeader("destination", new
> QueryBuilder()).recipientList(header("destination"));
>
> class QueryBuilder implements Expression {
>
> @Override
> public  T evaluate(Exchange exchange, Class type) {
>
> StringBuilder query = new StringBuilder();
> query.append("sql:");
>
> query.append(exchange.getIn().getHeader(SqlConstants.SQL_QUERY));
> query.append("?dataSource=#");
> query.append(exchange.getIn().getHeader("dataSource"));
>
> return
> exchange.getContext().getTypeConverter().convertTo(type,
> query.toString());
> }
> }
>
> But I have this error message :
> Failed to resolve endpoint:
>
> sql://insert%20into%20customer(firstname,%20lastname)%20values(:?firstName%2C+%3A%3FlastName%29%3FdataSource=%23myDynamicDataSource
> due to: DataSource must be configured
>
> Any idea of the problem or another solution to implement a dynamic
> datasource?
>
> Thanks,
> Arnaud
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Dynamic-DataSource-tp5771402.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: how to route pojo in camel

[Christian Müller]

Something like this:

from(timer:...)
  .to(sql:...)
  .split(...)
.convertBodyTo(...)
.to(cxf:...)
.to(ftp:...)
  .end();

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Fri, Aug 21, 2015 at 12:38 PM, Amar Sheth shethaa2...@gmail.com wrote:

 Hi,

 I am new to Apache Camel,

 I have an requirement were in I have to route pojo in camel and some
 processing to be done.

 My scenario/requirement is

 I have first component , which do the DB fetch and get the records, now for
 each records, call a webservice, which will return java POJO, we need to
 pass this pojo to route for some processing and ftp

 Pseudo Logic

 from(Java Pojo).Process(Some Process).to(ftp location).

 My question is how do I pass the Java Pojo in from part of the camel?

 Regards,
 Amar S

Re: Apache Camel XA transaction

[Christian Müller]

Have a look here:
https://github.com/muellerc/camel-in-transaction/blob/master/src/test/java/org/apache/cmueller/camel/samples/camelone/tx/JmsAndJdbcCompensationTransactionSampleTest.java

Hope this helps,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Thu, Aug 20, 2015 at 3:52 PM, kishoreJ kishore00...@gmail.com wrote:

 Hi claus

 But in that transactional client it is not specifying anything about what i
 need .


 I have to update a database if the message is sent successfully to a queue
 ,
 if one fails then i have to roll back both the transactions.
 Here i am dealing with a database transaction and a camel transaction.

 If any of one fails i have to roll back both the transactions there is
 nothing mentioned about rolling back both database transaction and camel
 transaction at a time in that article.






 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Apache-Camel-XA-transaction-tp5770836p5770855.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Load Bean Definitions from XML in Camel

[Christian Müller]

I didn't got the question...

You can create a Camel route from (Spring) XML or you can use Java Code,
e.g. implementing a RouteBuilder.

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Fri, Aug 21, 2015 at 11:04 AM, Felix Thomas felix.tho...@gmail.com
wrote:

 hello,

I know we can load RouteDefinations from XML, but can we have the
 same idea of loading for Beans from a XML like Spring. Is there anything
 already available inAPI?

 Regards,
 Felix T

Re: Apache Camel XA transaction

[Christian Müller]

Sorry, I mean this one:
https://github.com/muellerc/camel-in-transaction/tree/master/src/test/java/org/apache/cmueller/camel/samples/camelone/xa

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, Aug 24, 2015 at 10:49 PM, Christian Müller 
christian.muel...@gmail.com wrote:

 Have a look here:

 https://github.com/muellerc/camel-in-transaction/blob/master/src/test/java/org/apache/cmueller/camel/samples/camelone/tx/JmsAndJdbcCompensationTransactionSampleTest.java

 Hope this helps,

 Christian
 -

 Software Integration Specialist

 Apache Member
 V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
 Apache Incubator PMC Member

 https://www.linkedin.com/pub/christian-mueller/11/551/642

 On Thu, Aug 20, 2015 at 3:52 PM, kishoreJ kishore00...@gmail.com wrote:

 Hi claus

 But in that transactional client it is not specifying anything about what
 i
 need .


 I have to update a database if the message is sent successfully to a
 queue ,
 if one fails then i have to roll back both the transactions.
 Here i am dealing with a database transaction and a camel transaction.

 If any of one fails i have to roll back both the transactions there is
 nothing mentioned about rolling back both database transaction and camel
 transaction at a time in that article.






 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Apache-Camel-XA-transaction-tp5770836p5770855.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: action at the end of the split

[Christian Müller]

Check out http://camel.apache.org/splitter.html and look for the paragraph
Split aggregate request/reply sample

Here you have an example of a splitter using a custom aggregation strategy.
In your aggregation strategy, you have to make sure the CamelSplitSize
property is set on the exchange you are returning (you may have to copy it
from the other exchange). Than, this property is also available after the
end().

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Sat, Aug 15, 2015 at 4:08 AM, Wilson MacGyver wmacgy...@gmail.com
wrote:

 thanks, that sadly doesn't work either.

 I tried

 from(direct:testSplit)

 .split(body().tokenize(\n)).streaming()

 .setProperty(totalSize,
 simple(${property.CamelSplitSize}))

 .to(mock:result)

 .end()

 .log(property ${exchangeProperty.totalSize}
 updates)

 .log(should only happen once);


 and exchangeProperty.totalSize isn't set outside of the split.


 Thanks




 On Fri, Aug 14, 2015 at 6:00 PM, Luis Augusto C. Sauerbronn 
 lasa...@gmail.com wrote:

  Hi,
 
  If you want to store an information to use it later during the lifetime
 of
  the request you should place it in the Exchange Properties not in the
  Input/Output Headers.
  Many endpoints and processors do not pass ahead the received headers. If
  you put it on the Exchange properties it will exist through the whole
 life
  cycle of the request.
 
  Best regards,
 
  Luis
 
  2015-08-14 17:49 GMT-03:00 Wilson MacGyver wmacgy...@gmail.com:
 
   tried that, sadly no go. any header I set within the split, isn't
   accessible outside of the split block either.
  
   On Tue, Aug 11, 2015 at 4:54 AM, mailingl...@j-b-s.de 
   mailingl...@j-b-s.de
   wrote:
  
Hi!
   
Try the following: in your split route just set a new header field
 with
the value of splitsize. Ok, this assignment is made more than once
redundantly per each splitted element, but header properties you
 create
   on
the original message are retained (hopefully :-)
   
Jens
   
Von meinem iPhone gesendet
   
 Am 10.08.2015 um 21:49 schrieb Wilson MacGyver 
 wmacgy...@gmail.com
  :

 I'm sorry my message isn't clear. I've read the docs and the
 chapter
   that
 deal with this in the camel book. The issue I have isn't with the
  each
time
 part.

 It's the final log part after the split is done. My goal is after
 the
   end
 of the split block to send an email logging the total number
 updates.

 But as you can see, CamelSplitSize is no longer set outside of the
   split
 block. So I have no way of sending that to a SMTP route.

 On Mon, Aug 10, 2015 at 4:15 PM Christian Müller 
 christian.muel...@gmail.com wrote:

 Sure, that's how stream works. We do not load the entire payload
  into
 memory.
 Why don't you use the property CamelSplitIndex? In this case, the
   output
 will be

 [Test worker] INFO route1 - each time 0

 [Test worker] INFO route1 - each time 1

 [Test worker] INFO route1 - each time 2

 Best,

 Christian
 -

 Software Integration Specialist

 Apache Member
 V.P. Apache Camel | Apache Camel PMC Member | Apache Camel
 committer
 Apache Incubator PMC Member

 https://www.linkedin.com/pub/christian-mueller/11/551/642

 On Mon, Aug 10, 2015 at 4:35 AM, Wilson MacGyver 
  wmacgy...@gmail.com
   
 wrote:

 public class SplitTest extends CamelTestSupport {

@EndpointInject(uri = mock:result)

protected MockEndpoint resultEndpoint;


@Produce(uri = direct:testSplit)

protected org.apache.camel.ProducerTemplate template;


@Test

public void testWithString() throws Exception{

String content = a\nb\nc;


resultEndpoint.expectedMessageCount(3);


template.sendBodyAndHeader(

content,

foo, bar);


resultEndpoint.assertIsSatisfied();

}


@Override

protected RouteBuilder createRouteBuilder() {

return new RouteBuilder() {

public void configure() {

from(direct:testSplit)

.split(body().tokenize(\n)).streaming()

.log(each time
   ${property.CamelSplitSize})

.to(mock:result)

.end()

.log(Processed

Re: Camel CXF cannot be loaded to Karaf 4.0.0

[Christian Müller]

Thanks for the detailed explanation!

Best,
Christian
Am 11.08.2015 14:51 schrieb Daniel Kulp dk...@apache.org:


 The problem is that CXF the 3.0.x features file (which is pulled in via
 Camel 2.15.2) doesn’t support Karaf 4.   CXF only supports Karaf 4 starting
 with CXF 3.1.

 Thus, when the Karaf resolver is trying to resolve the camel-cxf feature
 file, it has a problem with the jetty 8 feature as CXF 3.0.x needs Jetty 8,
 not the Jetty 9 that Karaf 4 provides.

 You can “work around” this by doing:

 feature:install camel-core camel-spring
 install -s mvn:org.apache.camel/camel-cxf-transport/2.15.2
 install -s mvn:org.apache.camel/camel-cxf/2.15.2

 which should work fine.   If you look at the features file for camel-cxf,
 it’s really the same as the above but wouldn’t attempt to look at the 3.0.x
 versions of CXF.


 That said, this MAY be a bug in Karaf’s resolver.   The Camel feature file
 specifies a version range of [2.7,4.0) for CXF and CXF 3.1.1 would already
 be installed and resolved so I have no idea why it’s even looking at the
 3.0.5 features.

 Dan


  On Aug 10, 2015, at 3:52 PM, bocamel johnz...@gmail.com wrote:
 
  Just a heads up.  Tried the latest Karaf 4.0.0.  Cannot load camel-cxf
  feature (Camel 2.15.2/CXF 3.1.1).  Below is the error - looks like
 someone
  needs to bump up Jetty dependency.
 
 
  karaf@root() feature:repo-add cxf 3.1.1
  Adding feature url mvn:org.apache.cxf.karaf/apache-cxf/3.1.1/xml/features
  karaf@root() feature:install cxf cxf-rt-security
  karaf@root() feature:repo-add camel 2.15.2
  Adding feature url
  mvn:org.apache.camel.karaf/apache-camel/2.15.2/xml/features
  karaf@root() feature:install camel-core camel-spring camel-cxf
  Error executing command: Unable to resolve root: missing requirement
 [root]
  osgi
  .identity; osgi.identity=jetty; type=karaf.feature;
 version=[7.0.0,9.0.0)
  karaf@root()
 
 
 
  --
  View this message in context:
 http://camel.465427.n5.nabble.com/Camel-CXF-cannot-be-loaded-to-Karaf-4-0-0-tp5770537.html
  Sent from the Camel - Users mailing list archive at Nabble.com.

 --
 Daniel Kulp
 dk...@apache.org - http://dankulp.com/blog
 Talend Community Coder - http://coders.talend.com

Re: Camel CXF cannot be loaded to Karaf 4.0.0

[Christian Müller]

Apache Camel 2.15.2 was build and tested with CXF 3.0.4 [1] - and not 3.1.1.
Any reason why you have to use CXF 3.1.1?

Camel 2.16.0 will use CXF 3.1.2 (or later) [2].

[1]
https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=parent/pom.xml;h=f2b12514025554cdca72f32f3c78df32cf890526;hb=f27cda0a7a8132259e8caad043f0d63809bd901d
[2]
https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=parent/pom.xml;h=2c1af666471bb6a851bbb81cc92522ec8562ff59;hb=HEAD

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, Aug 10, 2015 at 9:52 PM, bocamel johnz...@gmail.com wrote:

 Just a heads up.  Tried the latest Karaf 4.0.0.  Cannot load camel-cxf
 feature (Camel 2.15.2/CXF 3.1.1).  Below is the error - looks like someone
 needs to bump up Jetty dependency.


 karaf@root() feature:repo-add cxf 3.1.1
 Adding feature url mvn:org.apache.cxf.karaf/apache-cxf/3.1.1/xml/features
 karaf@root() feature:install cxf cxf-rt-security
 karaf@root() feature:repo-add camel 2.15.2
 Adding feature url
 mvn:org.apache.camel.karaf/apache-camel/2.15.2/xml/features
 karaf@root() feature:install camel-core camel-spring camel-cxf
 Error executing command: Unable to resolve root: missing requirement [root]
 osgi
 .identity; osgi.identity=jetty; type=karaf.feature; version=[7.0.0,9.0.0)
 karaf@root()



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-CXF-cannot-be-loaded-to-Karaf-4-0-0-tp5770537.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: action at the end of the split

[Christian Müller]

You can do this by using a custom AggregationStrategy.
I can provide an example tomorrow...

Best,
Am 10.08.2015 22:50 schrieb Wilson MacGyver wmacgy...@gmail.com:

 I'm sorry my message isn't clear. I've read the docs and the chapter that
 deal with this in the camel book. The issue I have isn't with the each time
 part.

 It's the final log part after the split is done. My goal is after the end
 of the split block to send an email logging the total number updates.

 But as you can see, CamelSplitSize is no longer set outside of the split
 block. So I have no way of sending that to a SMTP route.

 On Mon, Aug 10, 2015 at 4:15 PM Christian Müller 
 christian.muel...@gmail.com wrote:

  Sure, that's how stream works. We do not load the entire payload into
  memory.
  Why don't you use the property CamelSplitIndex? In this case, the output
  will be
 
  [Test worker] INFO route1 - each time 0
 
  [Test worker] INFO route1 - each time 1
 
  [Test worker] INFO route1 - each time 2
 
  Best,
 
  Christian
  -
 
  Software Integration Specialist
 
  Apache Member
  V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
  Apache Incubator PMC Member
 
  https://www.linkedin.com/pub/christian-mueller/11/551/642
 
  On Mon, Aug 10, 2015 at 4:35 AM, Wilson MacGyver wmacgy...@gmail.com
  wrote:
 
   public class SplitTest extends CamelTestSupport {
  
   @EndpointInject(uri = mock:result)
  
   protected MockEndpoint resultEndpoint;
  
  
   @Produce(uri = direct:testSplit)
  
   protected org.apache.camel.ProducerTemplate template;
  
  
   @Test
  
   public void testWithString() throws Exception{
  
   String content = a\nb\nc;
  
  
   resultEndpoint.expectedMessageCount(3);
  
  
   template.sendBodyAndHeader(
  
   content,
  
   foo, bar);
  
  
   resultEndpoint.assertIsSatisfied();
  
   }
  
  
   @Override
  
   protected RouteBuilder createRouteBuilder() {
  
   return new RouteBuilder() {
  
   public void configure() {
  
   from(direct:testSplit)
  
   .split(body().tokenize(\n)).streaming()
  
   .log(each time
 ${property.CamelSplitSize})
  
   .to(mock:result)
  
   .end()
  
   .log(Processed ${property.CamelSplitSize}
   updates)
  
   .log(should only happen once);
  
   }
  
   };
  
   }
  
   }
  
  
   running this, I get the following
  
  
  
   [Test worker] INFO route1 - each time
  
   [Test worker] INFO route1 - each time
  
   [Test worker] INFO route1 - each time 3
  
   [Test worker] INFO route1 - Processed  updates
  
   [Test worker] INFO route1 - should only happen once
  
  
   given the input of 3 lines. CamelSplitSize is only set at the end of
 the
   split. so only the 3rd time has the 3 displayed which is correct.
  
   however notice it says  Processed  updates, because the property is
 only
   set within the split..end block
  
   that's what I meant by out of scope
  
  
  
   On Sun, Aug 9, 2015 at 3:23 PM, Christian Müller 
   christian.muel...@gmail.com wrote:
  
What do you mean with is out of scope?
You can use the message header to get this information.
   
Best,
   
Christian
-
   
Software Integration Specialist
   
Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member
   
https://www.linkedin.com/pub/christian-mueller/11/551/642
   
On Thu, Aug 6, 2015 at 5:26 PM, Wilson MacGyver wmacgy...@gmail.com
 
wrote:
   
 I figured out what I was doing wrong.  It's because I was using
  filter
with
 bean. I didn't realize I had to add an end() to terminate the
  filtering


 from()

 .split(body().tokenize(\n)).streaming()

 .process() /do stuff

 .filter().method(MyFilter.class, keepIt)

   .to(mock:result)

 .end()

 .log(final time ${property.CamelSplitSize})

 .to(smtp://)


 now I have a different problem. I need to know the # of total
   processed.
 But the CamelSplitSize property is out of scope. Anyway to work
  around
 that?


 Thanks



 On Thu, Jul 23, 2015 at 2:03 PM, Claus Ibsen 
 claus.ib...@gmail.com
 wrote:

  You must be doing some more inside the splitter and you may need
 2
  x
end
 
  On Thu, Jul 23, 2015 at 7:45 PM, Wilson MacGyver 
   wmacgy...@gmail.com
  wrote:
   hmm, if I understand you correctly, this isn't working for me.
  
   I have
  
   from()
  
   .split(body().tokenize(\n)).streaming()
  
   .process() /do stuff
  
   .end()
  
   .log(${in.body})
  
   .to(smtp

Re: How to validate json schema by using camel avro

[Christian Müller]

Apache Camel Avro doesn't provide a validation option/feature. You have to
check how Avro handle it.

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, Aug 10, 2015 at 9:11 AM, nagak ns.na...@gmail.com wrote:

 I successfully tested Camel Rest Service in json format.Now i want to
 validate json format by using camel avro.Please provide me your guidelines.

 Regards,
 Naga



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/How-to-validate-json-schema-by-using-camel-avro-tp5770506.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How many JMS transactions within a route?

[Christian Müller]

You can read more about the supported cache options here [1], but
CACHE_CONSUMER is the best option in your case.
XA is not needed, because you only interact with one resource/broker.
I'm not sure whether we have to have two JMS sessions here. May be an JMS
expert can answer this question...

[1] http://camel.apache.org/jms.html

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, Aug 10, 2015 at 3:35 AM, kov k...@nyc.rr.com wrote:

 Thanks; to be clear, I'd prefer not to use an XA transaction here, but I'd
 also like to consume from q1 and publish to q2 in a single transaction,
 that's why I asked if an XA transaction was the only choice, even when I'm
 communicating over a single JMS message bus.

 Mostly just trying to understand what the expected behavior with that
 configuration is, and what my options for altering it are? Right now, it
 seems that when a route gets built that references my JMSComponent, a
 session is requested from the JMSComponent which just caches one for each
 consumer. This ends up with a session for the consumer of q1, and a
 distinct
 session for the publisher to q2. Is that pretty much how it works? Just
 wondering what variations on caching behavior exists.

 Thanks!



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/How-many-JMS-transactions-within-a-route-tp5770390p5770502.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: action at the end of the split

[Christian Müller]

http://camel.apache.org/splitter.html

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, Aug 10, 2015 at 10:15 PM, Christian Müller 
christian.muel...@gmail.com wrote:

 Sure, that's how stream works. We do not load the entire payload into
 memory.
 Why don't you use the property CamelSplitIndex? In this case, the output
 will be

 [Test worker] INFO route1 - each time 0

 [Test worker] INFO route1 - each time 1

 [Test worker] INFO route1 - each time 2

 Best,

 Christian
 -

 Software Integration Specialist

 Apache Member
 V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
 Apache Incubator PMC Member

 https://www.linkedin.com/pub/christian-mueller/11/551/642

 On Mon, Aug 10, 2015 at 4:35 AM, Wilson MacGyver wmacgy...@gmail.com
 wrote:

 public class SplitTest extends CamelTestSupport {

 @EndpointInject(uri = mock:result)

 protected MockEndpoint resultEndpoint;


 @Produce(uri = direct:testSplit)

 protected org.apache.camel.ProducerTemplate template;


 @Test

 public void testWithString() throws Exception{

 String content = a\nb\nc;


 resultEndpoint.expectedMessageCount(3);


 template.sendBodyAndHeader(

 content,

 foo, bar);


 resultEndpoint.assertIsSatisfied();

 }


 @Override

 protected RouteBuilder createRouteBuilder() {

 return new RouteBuilder() {

 public void configure() {

 from(direct:testSplit)

 .split(body().tokenize(\n)).streaming()

 .log(each time ${property.CamelSplitSize})

 .to(mock:result)

 .end()

 .log(Processed ${property.CamelSplitSize}
 updates)

 .log(should only happen once);

 }

 };

 }

 }


 running this, I get the following



 [Test worker] INFO route1 - each time

 [Test worker] INFO route1 - each time

 [Test worker] INFO route1 - each time 3

 [Test worker] INFO route1 - Processed  updates

 [Test worker] INFO route1 - should only happen once


 given the input of 3 lines. CamelSplitSize is only set at the end of the
 split. so only the 3rd time has the 3 displayed which is correct.

 however notice it says  Processed  updates, because the property is only
 set within the split..end block

 that's what I meant by out of scope



 On Sun, Aug 9, 2015 at 3:23 PM, Christian Müller 
 christian.muel...@gmail.com wrote:

  What do you mean with is out of scope?
  You can use the message header to get this information.
 
  Best,
 
  Christian
  -
 
  Software Integration Specialist
 
  Apache Member
  V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
  Apache Incubator PMC Member
 
  https://www.linkedin.com/pub/christian-mueller/11/551/642
 
  On Thu, Aug 6, 2015 at 5:26 PM, Wilson MacGyver wmacgy...@gmail.com
  wrote:
 
   I figured out what I was doing wrong.  It's because I was using filter
  with
   bean. I didn't realize I had to add an end() to terminate the
 filtering
  
  
   from()
  
   .split(body().tokenize(\n)).streaming()
  
   .process() /do stuff
  
   .filter().method(MyFilter.class, keepIt)
  
 .to(mock:result)
  
   .end()
  
   .log(final time ${property.CamelSplitSize})
  
   .to(smtp://)
  
  
   now I have a different problem. I need to know the # of total
 processed.
   But the CamelSplitSize property is out of scope. Anyway to work around
   that?
  
  
   Thanks
  
  
  
   On Thu, Jul 23, 2015 at 2:03 PM, Claus Ibsen claus.ib...@gmail.com
   wrote:
  
You must be doing some more inside the splitter and you may need 2 x
  end
   
On Thu, Jul 23, 2015 at 7:45 PM, Wilson MacGyver 
 wmacgy...@gmail.com
wrote:
 hmm, if I understand you correctly, this isn't working for me.

 I have

 from()

 .split(body().tokenize(\n)).streaming()

 .process() /do stuff

 .end()

 .log(${in.body})

 .to(smtp://)


 say if the file has 100 lines, I'd except to see the log once if I
 understand what you are saying correctly. but I see the log 100
  times.


 Thanks,



 On Thu, Jul 23, 2015 at 1:24 PM, Claus Ibsen 
 claus.ib...@gmail.com
wrote:

 You can do that after the splitter

 from
   split
 ... inside splitter
   /split
  .. split done
   to email send email here

 In Java DSL you can use .end() to end the split block.

 On Thu, Jul 23, 2015 at 7:21 PM, Wilson MacGyver 
  wmacgy...@gmail.com
   
 wrote:
  Hi,
 
  I'm processing a large file. so I use .split and .streaming to
   process

Re: action at the end of the split

[Christian Müller]

Sure, that's how stream works. We do not load the entire payload into
memory.
Why don't you use the property CamelSplitIndex? In this case, the output
will be

[Test worker] INFO route1 - each time 0

[Test worker] INFO route1 - each time 1

[Test worker] INFO route1 - each time 2

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, Aug 10, 2015 at 4:35 AM, Wilson MacGyver wmacgy...@gmail.com
wrote:

 public class SplitTest extends CamelTestSupport {

 @EndpointInject(uri = mock:result)

 protected MockEndpoint resultEndpoint;


 @Produce(uri = direct:testSplit)

 protected org.apache.camel.ProducerTemplate template;


 @Test

 public void testWithString() throws Exception{

 String content = a\nb\nc;


 resultEndpoint.expectedMessageCount(3);


 template.sendBodyAndHeader(

 content,

 foo, bar);


 resultEndpoint.assertIsSatisfied();

 }


 @Override

 protected RouteBuilder createRouteBuilder() {

 return new RouteBuilder() {

 public void configure() {

 from(direct:testSplit)

 .split(body().tokenize(\n)).streaming()

 .log(each time ${property.CamelSplitSize})

 .to(mock:result)

 .end()

 .log(Processed ${property.CamelSplitSize}
 updates)

 .log(should only happen once);

 }

 };

 }

 }


 running this, I get the following



 [Test worker] INFO route1 - each time

 [Test worker] INFO route1 - each time

 [Test worker] INFO route1 - each time 3

 [Test worker] INFO route1 - Processed  updates

 [Test worker] INFO route1 - should only happen once


 given the input of 3 lines. CamelSplitSize is only set at the end of the
 split. so only the 3rd time has the 3 displayed which is correct.

 however notice it says  Processed  updates, because the property is only
 set within the split..end block

 that's what I meant by out of scope



 On Sun, Aug 9, 2015 at 3:23 PM, Christian Müller 
 christian.muel...@gmail.com wrote:

  What do you mean with is out of scope?
  You can use the message header to get this information.
 
  Best,
 
  Christian
  -
 
  Software Integration Specialist
 
  Apache Member
  V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
  Apache Incubator PMC Member
 
  https://www.linkedin.com/pub/christian-mueller/11/551/642
 
  On Thu, Aug 6, 2015 at 5:26 PM, Wilson MacGyver wmacgy...@gmail.com
  wrote:
 
   I figured out what I was doing wrong.  It's because I was using filter
  with
   bean. I didn't realize I had to add an end() to terminate the filtering
  
  
   from()
  
   .split(body().tokenize(\n)).streaming()
  
   .process() /do stuff
  
   .filter().method(MyFilter.class, keepIt)
  
 .to(mock:result)
  
   .end()
  
   .log(final time ${property.CamelSplitSize})
  
   .to(smtp://)
  
  
   now I have a different problem. I need to know the # of total
 processed.
   But the CamelSplitSize property is out of scope. Anyway to work around
   that?
  
  
   Thanks
  
  
  
   On Thu, Jul 23, 2015 at 2:03 PM, Claus Ibsen claus.ib...@gmail.com
   wrote:
  
You must be doing some more inside the splitter and you may need 2 x
  end
   
On Thu, Jul 23, 2015 at 7:45 PM, Wilson MacGyver 
 wmacgy...@gmail.com
wrote:
 hmm, if I understand you correctly, this isn't working for me.

 I have

 from()

 .split(body().tokenize(\n)).streaming()

 .process() /do stuff

 .end()

 .log(${in.body})

 .to(smtp://)


 say if the file has 100 lines, I'd except to see the log once if I
 understand what you are saying correctly. but I see the log 100
  times.


 Thanks,



 On Thu, Jul 23, 2015 at 1:24 PM, Claus Ibsen 
 claus.ib...@gmail.com
wrote:

 You can do that after the splitter

 from
   split
 ... inside splitter
   /split
  .. split done
   to email send email here

 In Java DSL you can use .end() to end the split block.

 On Thu, Jul 23, 2015 at 7:21 PM, Wilson MacGyver 
  wmacgy...@gmail.com
   
 wrote:
  Hi,
 
  I'm processing a large file. so I use .split and .streaming to
   process
 it a
  record at a time.
 
  I would like to send an email alert upon completion of
 processing
   the
 file.
 
  but I can't figure out where to do that.
 
  I know I can check to see if it's the last exchange using
 property
  CamelSplitComplete, but it's set to true on the last exchange.
  So
   I
 still
  need to let it finish

Re: Skip duplicate records from CSV when loading to database

[Christian Müller]

Why is the MessageIdempotent repository not working for you?
http://camel.apache.org/idempotent-consumer.html

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Wed, Aug 5, 2015 at 7:07 AM, Raghavan83 raghava...@yahoo.co.in wrote:

 I am trying to load CSV file to table. How can we skip duplicates in
 clustered environment?
 MessageIdempotent Repository is not working.

 Will writing a bean to add all messages to HashSet work in clustered
 environment?
 I am expecting memory issue with this approach. Please suggest some good
 option



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Skip-duplicate-records-from-CSV-when-loading-to-database-tp5770291.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How many JMS transactions within a route?

[Christian Müller]

Why want you use XA when you are talking to only one resource?
Camel creates one transaction per transacted route and consumer (as every
consumer is using its own thread). What do you expect instead?

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Thu, Aug 6, 2015 at 7:30 PM, kov k...@nyc.rr.com wrote:

 Taking the example of a JMS-based application that processes messages from
 a
 JMS message bus:

   camelContext...
 route id=step1
   from uri=msgbus:q1 /
   transacted /
   to uri=msgbus:q2 /
 /route

   /camelContext
   * The 'msgbus' token refers to a JmsComponent with a
 CachedConnectionFactory and cache level=CACHE_CONSUMER.

 What is the expected number of JMS-transactions for the from and to
 endpoints? Playing with this example, it appears that each of the endpoints
 gets a separate JMS-transaction. Does anybody know if that is the case? Are
 there design or other reasons for that, maybe enabling further options I
 haven't considered? Would it be possible for the route to use one
 JMS-transaction for both the consume and send? Or would you have to use XA
 transactions to make that happen?




 --
 View this message in context:
 http://camel.465427.n5.nabble.com/How-many-JMS-transactions-within-a-route-tp5770390.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel XPath....Parsing a part of message Body...

[Christian Müller]

I suggest adding the camel-saxon dependency and use:
xpath saxon=true/CamelData/Provider/text()/xpath

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Thu, Aug 6, 2015 at 9:28 PM, anish.somadevan netan...@gmail.com wrote:

 Am having a similar issue and i get this error message,

 java.lang.ClassCastException: org.apache.xml.dtm.ref.DTMManagerDefault
 cannot be cast to org.apache.xml.dtm.DTMManager:
 java.lang.ClassCastException: org.apache.xml.dtm.ref.DTMManagerDefault
 cannot be cast to org.apache.xml.dtm.DTMManager
 at org.apache.xml.dtm.DTMManager.newInstance(DTMManager.java:137)
 [xalan.jar:]
 at org.apache.xpath.XPathContext.init(XPathContext.java:102)
 [xalan.jar:]
 at org.apache.xpath.XPathContext.init(XPathContext.java:349)
 [xalan.jar:]
 at

 org.apache.xpath.jaxp.XPathExpressionImpl.eval(XPathExpressionImpl.java:113)
 at
 org.apache.xpath.jaxp.XPathExpressionImpl.eval(XPathExpressionImpl.java:99)

 This is how am trying to retrieve the value,

 xpath/CamelData/Provider/text()/xpath

 Can you please let me know how to resolve this?

 Thanks,
 Anish



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-XPath-Parsing-a-part-of-message-Body-tp5749823p5770394.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: SFTP - Twice as many retries as specified in maximumReconnectAttempts

[Christian Müller]

https://issues.apache.org/jira/browse/CAMEL-8639 will be fixed with Camel
2.16.0 and 2.15.3.
This means you should use these SNAPSHOT versions, not 2.14.4-SNAPSHOT...

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Thu, Aug 6, 2015 at 10:16 PM, IgnatiusReilly elpa...@gmail.com wrote:

 Hi Claus,

 Thanks for your reply. I used 2.14.4-SNAPSHOT and the error persists. Any
 other ideas?

 Regards,

 Ignatius



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/SFTP-Twice-as-many-retries-as-specified-in-maximumReconnectAttempts-tp5770168p5770395.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Issue with SetHeader / Xpath

[Christian Müller]

I suggest adding the camel-saxon dependency and use:
xpath saxon=true.../xpath

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Fri, Aug 7, 2015 at 7:01 PM, anish.somadevan netan...@gmail.com wrote:

 I have a similar issue



 My XML is

 CamelData
 ProviderProviderValue/Provider
 /CamelData

 And am trying to set header value like this,

 SetHeader headerName = Provider
 xpath/CamelData/Provider/text()/xpath
 /setHeader

 But i get this error.

 Exhausted after delivery attempt: 1 caught: java.lang.ClassCastException:
 org.apache.xml.dtm.ref.DTMManagerDefault cannot be cast to
 org.apache.xml.dtm.DTMManager: java.lang.ClassCastException:
 org.apache.xml.dtm.ref.DTMManagerDefault cannot be cast to
 org.apache.xml.dtm.DTMManager
 at org.apache.xml.dtm.DTMManager.newInstance(DTMManager.java:137)
 [xalan.jar:]
 at org.apache.xpath.XPathContext.init(XPathContext.java:102)
 [xalan.jar:]
 at org.apache.xpath.XPathContext.init(XPathContext.java:349)
 [xalan.jar:]
 at

 org.apache.xpath.jaxp.XPathExpressionImpl.eval(XPathExpressionImpl.java:113)
 at
 org.apache.xpath.jaxp.XPathExpressionImpl.eval(XPathExpressionImpl.java:99)

 Is there something that am missing?



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Issue-with-SetHeader-Xpath-tp5749368p5770441.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: action at the end of the split

[Christian Müller]

What do you mean with is out of scope?
You can use the message header to get this information.

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Thu, Aug 6, 2015 at 5:26 PM, Wilson MacGyver wmacgy...@gmail.com wrote:

 I figured out what I was doing wrong.  It's because I was using filter with
 bean. I didn't realize I had to add an end() to terminate the filtering


 from()

 .split(body().tokenize(\n)).streaming()

 .process() /do stuff

 .filter().method(MyFilter.class, keepIt)

   .to(mock:result)

 .end()

 .log(final time ${property.CamelSplitSize})

 .to(smtp://)


 now I have a different problem. I need to know the # of total processed.
 But the CamelSplitSize property is out of scope. Anyway to work around
 that?


 Thanks



 On Thu, Jul 23, 2015 at 2:03 PM, Claus Ibsen claus.ib...@gmail.com
 wrote:

  You must be doing some more inside the splitter and you may need 2 x end
 
  On Thu, Jul 23, 2015 at 7:45 PM, Wilson MacGyver wmacgy...@gmail.com
  wrote:
   hmm, if I understand you correctly, this isn't working for me.
  
   I have
  
   from()
  
   .split(body().tokenize(\n)).streaming()
  
   .process() /do stuff
  
   .end()
  
   .log(${in.body})
  
   .to(smtp://)
  
  
   say if the file has 100 lines, I'd except to see the log once if I
   understand what you are saying correctly. but I see the log 100 times.
  
  
   Thanks,
  
  
  
   On Thu, Jul 23, 2015 at 1:24 PM, Claus Ibsen claus.ib...@gmail.com
  wrote:
  
   You can do that after the splitter
  
   from
 split
   ... inside splitter
 /split
.. split done
 to email send email here
  
   In Java DSL you can use .end() to end the split block.
  
   On Thu, Jul 23, 2015 at 7:21 PM, Wilson MacGyver wmacgy...@gmail.com
 
   wrote:
Hi,
   
I'm processing a large file. so I use .split and .streaming to
 process
   it a
record at a time.
   
I would like to send an email alert upon completion of processing
 the
   file.
   
but I can't figure out where to do that.
   
I know I can check to see if it's the last exchange using property
CamelSplitComplete, but it's set to true on the last exchange. So
 I
   still
need to let it finish.
   
Is there a good way to this?
   
Thanks,
Mac
   
--
Omnem crede diem tibi diluxisse supremum.
  
  
  
   --
   Claus Ibsen
   -
   http://davsclaus.com @davsclaus
   Camel in Action 2nd edition: http://www.manning.com/ibsen2
  
  
  
  
   --
   Omnem crede diem tibi diluxisse supremum.
 
 
 
  --
  Claus Ibsen
  -
  http://davsclaus.com @davsclaus
  Camel in Action 2nd edition: http://www.manning.com/ibsen2
 



 --
 Omnem crede diem tibi diluxisse supremum.

Re: Parsing a XML in DSL

[Christian Müller]

You should use Saxon for many reasons...

I suggest adding the camel-saxon dependency and use:
xpath saxon=true/CamelData/Provider/text()/xpath

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Sat, Aug 8, 2015 at 1:33 AM, anish.somadevan netan...@gmail.com wrote:

 I was able to resolve it by uploading a new version of xalan jar

 Thanks



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Parsing-a-XML-in-DSL-tp5770368p5770445.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Choice with xpath

[Christian Müller]

I suggest adding the camel-saxon dependency and use:
xpath saxon=true.../xpath

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Thu, Aug 6, 2015 at 10:22 PM, anish.somadevan netan...@gmail.com wrote:

 Am having a similar issue and i get this error message,

 java.lang.ClassCastException: org.apache.xml.dtm.ref.DTMManagerDefault
 cannot be cast to org.apache.xml.dtm.DTMManager:
 java.lang.ClassCastException: org.apache.xml.dtm.ref.DTMManagerDefault
 cannot be cast to org.apache.xml.dtm.DTMManager
 at org.apache.xml.dtm.DTMManager.newInstance(DTMManager.java:137)
 [xalan.jar:]
 at org.apache.xpath.XPathContext.init(XPathContext.java:102)
 [xalan.jar:]
 at org.apache.xpath.XPathContext.init(XPathContext.java:349)
 [xalan.jar:]
 at

 org.apache.xpath.jaxp.XPathExpressionImpl.eval(XPathExpressionImpl.java:113)
 at
 org.apache.xpath.jaxp.XPathExpressionImpl.eval(XPathExpressionImpl.java:99)

 This is how am trying to retrieve the value,

 xpath/CamelData/Provider/text()/xpath

 This is how my XML looks,

 CamelData
 ProviderProviderValue/Provider
 /CamelData

 Can you please let me know how to resolve this?

 Thanks,
 Anish



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Choice-with-xpath-tp5721410p5770396.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: camel+jms+TLS

[Christian Müller]

Which version of Camel do you use, how do you configured it, how does your
route look like?
What do you mean with everything is fine?
What do you mean with messages are consumed by camel, but I cant see
anything in the queue?

You have to put more effort in describing your problem, if you really want
help.
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, Aug 3, 2015 at 11:38 PM, robertotrgt roberto.trujill...@gmail.com
wrote:

 Hi,

  Im trying to put messages to a jms queue hosted by an openmq
 broker, everything is fine when the broker is not secure, but when i change
 to a secure (tls), messages are consumed by camel, but I cant see anything
 in the queue

 Im trying this two properties


 connectionFactorymq.setProperty(ConnectionConfiguration.imqConnectionType,
 TLS);


 connectionFactorymq.setProperty(ConnectionConfiguration.imqSSLIsHostTrusted,
 true);

 Can you help, please?



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/camel-jms-TLS-tp5770260.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: camel-s3 route : recursive=true doesn't work

[Christian Müller]

No. Please check: http://camel.apache.org/aws-s3.html

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Tue, Aug 4, 2015 at 4:16 PM, rubavathi rubavathi.sriniva...@mobax.com
wrote:

 Hi,

 On creating the following route I am getting exception:

 org.apache.camel.RuntimeCamelException:
 org.apache.camel.FailedToCreateRouteException: Failed to create route
 route1
 at: 

 To[aws-s3://buckettest?recursive=trueamazonS3Endpoint=endpointaccessKey=accesskeyregion=region]
  in route: Route(route1) due to: There are 1 parameters that couldn't be
 set on the endpoint. Check the uri if the parameters are spelt correctly
 and
 that they are properties of the endpoint. Unknown
 parameters=[{recursive=true}]
 at

 org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1619)
 at

 org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:123)
 at

 org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:332)
 at

 org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:98)
 at

 org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:333)
 at

 org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:776)
 at

 org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:485)
 at

 org.springframework.web.context.ContextLoader.configureAndRefreshWebApplicationContext(ContextLoader.java:403)
 at

 org.springframework.web.context.ContextLoader.initWebApplicationContext(ContextLoader.java:306)
 at

 org.springframework.web.context.ContextLoaderListener.contextInitialized(ContextLoaderListener.java:106)
 at

 org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:4992)

 Can't we use recursive=true on defining camel routes?



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/camel-s3-route-recursive-true-doesn-t-work-tp5770278.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Some Stupid Questions

[Christian Müller]

It will create a new instance for each call to the registry. But if you
inject this bean to another bean (which has the singleton scope), than
there is only one instance of this bean.
A workaround could be to call the registry by yourself to get a fresh copy
of this bean.
The solution is to make your bean thread safe. What kind of state do you
have to maintain?

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Tue, Aug 4, 2015 at 1:40 PM, fxthomas felix.tho...@gmail.com wrote:

 Thanks for your answers I will try them out whatever possible.

 I tried the Below things too.

 1) I checked the bean construction the saw that it being created only once
 so i change the bean defination to below

 bean id=CustomProcessorCSV class=com..CustomProcessor
 scope=prototype
   constructor-arg value=CSV/
 /bean

 But still I see only one Instance being created on the Logs, isn',t scope
 prototype supposed to return from registry a new instance so in turn it
 should create multiple instance of the bean. Hope my understanding  is okay
 ?



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Some-Stupid-Questions-tp5770217p5770275.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Need help in running camel in raspberry pi

[Christian Müller]

The bundle org.eclipse.kura.example.camel_osgi imports the following
packages:

Import-Package: org.apache.camel;version=2.15.2,
 org.apache.camel.builder;version=2.15.2,
 org.apache.camel.core.osgi;version=2.15.2,
 org.osgi.framework;version=1.7.0,
 org.slf4j;version=1.6.4

But the bundles, which are exporting these packages, are not installed. You
have to install these bundles before (and these bundles dependencies if
they have any).

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Wed, Jul 15, 2015 at 7:20 AM, Parul parulagrawa...@gmail.com wrote:

 Hi All,

 I have uploaded sample  code @ https://github.com/parulagrawal14/Came-Kura
 .
 Please let me know if i have done anything wrong in the project which might
 have caused the issue.

 Thanks and Regards,
 Parul



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Fwd-Need-help-in-running-camel-in-raspberry-pi-tp5768895p5769318.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Need help in running camel in raspberry pi

[Christian Müller]

Hi Parul,

please use the users mailing list for such kind of questions.

Can you share your MANIFEST.MF file with us? Or the complete project? Maybe
your OSGI metadata are not correct...

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Sat, Jul 4, 2015 at 9:07 AM, Parul Agrawal parulagrawa...@gmail.com
wrote:


 Hi,

 I am trying to run Camel as OSgi bundle in Kura with raspberry as the
 target device.
 Just to get hands on I followed below mentioned steps.

 1) Downloaded Kura from *https://github.com/eclipse/kura
 https://github.com/eclipse/kura* with lwm2m branch since I wanted
 support for Lwm2m in Kura.

 2) Deployed Kura in raspberry pi as steps mentioned in 
 *https://wiki.eclipse.org/Kura/Getting_Started
 https://wiki.eclipse.org/Kura/Getting_Started*

 3) After that followed steps @ 
 *http://java.dzone.com/articles/apache-camel-iot-world-eclipse
 http://java.dzone.com/articles/apache-camel-iot-world-eclipse* to
 bundle camel in Kura.

 As mentioned I installed all the jar files in raspberry pi and finally
 started my- camel-bundle.jar
 But in osgi console if I run ls command camel bundle is shown as
 unsatisfied.
 *33  Unsatisfied
 org.eclipse.kura.example.camel_osgi
 org.eclipse.kura.example.camel_osgi(bid=75)*.

 I have attached the *error.txt* file with the output of command ls, ss
 and comp.
 Request you to help me in debugging this issue.
 Since I am new to Camel,Kura,Raspberry pi kindly guide me in making this
 up and providing pointers or any kind of help
 with respect to this.

 Thanks in advance.

 Thanks and Regards,
 Parul

Call for Papers of ApacheCON EU 2015 - Budapest (Hungary)

[Christian Müller]

Dear committer.

We are pleased to announce that Call for Papers of ApacheCON: Core is
now open, please submit your presentation proposal(s) before July 1.

See Linux Foundation announcement:
http://events.linuxfoundation.org/events/apachecon-core-europe

Linux Foundation, that produces and are responsible for apacheCON,
decided together with the apacheCON team to split apacheCON with a goal
of having a more focused event alongside the traditional apacheCON.

The ApacheCON: Core is the traditional apacheCON representing our
communities and projects. There will be a community track as well as a
incubator track, the rest depend on what the projects submit.

We hope you as we see this as a great opportunity to promote your project.
We look forward to read your presentation suggestion(s).

Please use the link above (and select CFP) to submit presentations.

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

Re: Camel 2.15.2 set up issue

[Christian Müller]

You configured repo.maven.apache.* as non proxy host. This means the
proxy is not used for this host... Can you remove this entry?!

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Thu, May 28, 2015 at 10:49 AM, shekhar.shaw shekhar.s...@mindtree.com
wrote:

 Thank you for your reply.

 I've already did that configuration on settings.xml as well as on IE
 settings, but no luck.

 However I can open below url from local browser.

 https://repo.maven.apache.org/maven2/org/apache/camel/camel-parent/
 2.15.0/camel-parent-2.15.0.pom


 Here are the entries for settings.xml

 **
 proxy
   idoptional/id
   activetrue/active
   protocolhttps/protocol
   username*/username
   password**/password
   host*.*.*.*/host
   port/port
   nonProxyHostsrepo.maven.apache.*/nonProxyHosts
 /proxy

 **


 Regards,
 Shekhar



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-2-15-2-set-up-issue-tp5767584p5767593.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel XQuery 3.0

[Christian Müller]

Feel free to raise a JIRA and request the upgrade to Saxon 9.6.

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Wed, May 27, 2015 at 11:55 PM, Karts kartiksan...@gmail.com wrote:

 In fact it looks like XQuery 3.0 isn't supported in Saxon HE 9.5. It is the
 default on 9.6 but that doesn't seem compatible with the current
 implementation of XQueryBuilder:

 Caused by: java.lang.NoSuchMethodError:
 net.sf.saxon.Configuration.setHostLanguage(I)V
 at

 org.apache.camel.component.xquery.XQueryBuilder.initialize(XQueryBuilder.java:641)
 at

 org.apache.camel.component.xquery.XQueryBuilder.evaluateAsString(XQueryBuilder.java:198)
 at

 org.apache.camel.component.xquery.XQueryBuilder.evaluate(XQueryBuilder.java:120)
 at

 org.apache.camel.component.xquery.XQueryBuilder.evaluate(XQueryBuilder.java:110)
 at

 org.apache.camel.processor.SetBodyProcessor.process(SetBodyProcessor.java:47)
 at

 org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
 at

 org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:163)
 ... 88 more



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-XQuery-3-0-tp5767434p5767575.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel with Tomcat (with or without Spring) doesn't release memory after Stop Restart or Redeployment

[Christian Müller]

Can you provide a heap dump so that we can have a look which classes are
not unloaded!?

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Thu, May 28, 2015 at 1:14 AM, Juan Pablo Converso jpcon...@gmail.com
wrote:

 Dear Camel Experts,

 I'm having a problem using camel with tomcat as the container. For some
 reason after several stop/restarts or redeployments the application
 generate
 a java.lang.OutOfMemoryError And I need to restart tomcat

 I tried to simplify the problem and discover the same behavior using the
 examples in the official release package. Mainly I downloaded:

 http://www.apache.org/dyn/closer.cgi/camel/apache-camel/2.15.2/apache-camel-2.15.2.tar.gz

 And generated the WARs using mvn install for the following examples:
  - camel-example-servlet-tomcat-no-spring
  - camel-example-servlet-tomcat

 Then deployed any of the WARs generated to tomcat: 7.0.55.

 So when I open the tomcat manager and click the button stop, the
 application
 stop gracefully but when I click the button Find Leaks, tomcat manager
 displays the following:

 The following web applications were stopped (reloaded, undeployed), but
 their
 classes from previous runs are still loaded in memory, thus causing a
 memory
 leak (use a profiler to confirm):
 /camel-example-servlet-tomcat-no-spring-2.15.2


 I also verified the same behaviour using a profiler, when start and then
 stop is clicked several times the application generates and the OutOfMemory
 error and tomcat needs to be restarted

 Thanks in advance for any help or guidance!
  Best Regards
Juan Pablo







 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-with-Tomcat-with-or-without-Spring-doesn-t-release-memory-after-Stop-Restart-or-Redeployment-tp5767577.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Unmarshal not working

[Christian Müller]

What do you mean with my real webservice doesnt support PAYLOAD format? I
don't understand it.

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, May 11, 2015 at 7:11 AM, jainmcs03 tojayendran.in...@gmail.com
wrote:

 But my real webservice doesnt support PAYLOAD format thats why chose
 MESSAGE
 format. So just need to remove the soap envelope and do unmarshal. Any
 guide
 pls?



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Unmarshal-not-working-tp5766790p5766948.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Unmarshal not working

[Christian Müller]

Please check the available data formats in the CXF component.

Best,
Christian
Am 07.05.2015 10:00 schrieb jainmcs03 tojayendran.in...@gmail.com:


 Hi Team,

 JAXB can only unmarshall an XML if the soap envelope has already been
 removed. However, the SOAP response I'm trying to unmarshall has its
 namespace declaration on the soap envelope. So how to remove the SOAP
 envelope in camel route.

 Regards,
 Jayendran



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Unmarshal-not-working-tp5766790p5766797.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Proxying with Payload Format

[Christian Müller]

Something like this:
https://github.com/muellerc/esbperformance/blob/master/karaf/proxy/src/main/resources/OSGI-INF/blueprint/bundle-context.xml

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, May 4, 2015 at 3:09 PM, ercan.canlier ercan.canl...@gmail.com
wrote:

 Hi to everybody,
 I am currently encountering problem about proxy by payload format, any help
 would be helpful.
 I followed the tips at report incident tutorial but there, a jax-ws is used
 and want to expose two web services by Apache CXF.
 One is the proxy and the other for real web service. I am currently writing
 the request and response to database but with long format. When i change my
 jax-ws to apache cxf web service and set the message format to PAYLOAD
 mode, i am not able to expose the real one.
 Have you ever exposed web services like i mentioned?
 Thanks.
 Ercan



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Proxying-with-Payload-Format-tp5766651.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: CSV and SQL Component for Batch Processing

[Christian Müller]

Add a processor in between and remove the entries you don't need.

Best,
Christian

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Wed, Apr 29, 2015 at 11:36 AM, imranrazakhan imranrazak...@gmail.com
wrote:

 Hi,

 I am doing batch insertion into db from CSV file like

 from(file:mycsv)
 .unmarshal().csv()
.to(sql:insert into mytable (value1, value2) Values (#,
 #)?batch=true)
.end();

 It works fine if CSV columns and Table columns are same, but my CSV has 10
 column and Table has 7.

 Is there any way to skip last 3 columns from CSV before insertion?

 I can use bindy component but i am looking for option in CSV

 Regards,



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/CSV-and-SQL-Component-for-Batch-Processing-tp5766475.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Issue while installing feature using features:install

[Christian Müller]

You should ask this question on the JBoss Fuse mailing list.

Best,
Christian
Am 20.04.2015 13:10 schrieb Vanshul.Chawla vanshul.cha...@target.com:

 Hello,

 I get an error when I try to install any feature:

 JBossFuse:admin@root features:install fuse-oms-financial-feed-features
 Error executing command:
 sun.security.internal.spec.TlsRsaPremasterSecretParameterSpec.getEncodedSecret()[B
 JBossFuse:admin@root features:install
 fuse-oms-financial-feed-features-config
 Error executing command:
 sun.security.internal.spec.TlsRsaPremasterSecretParameterSpec.getEncodedSecret()[B
 JBossFuse:admin@root features:install camel-scala
 Error executing command:
 sun.security.internal.spec.TlsRsaPremasterSecretParameterSpec.getEncodedSecret()[B
 JBossFuse:admin@root

 Could someone please help with this? Any setting to be enabled in config
 files

 Thanks and Regards,

 Vanshul Chawla

Apache Camel @Netflix

[Christian Müller]

Also Netflix is using Apache Camel in its payment processing engine [1].

[1] https://www.youtube.com/watch?v=k_ckJ7QgLW0#t=515

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

Re: Camel transacted route from JMS to JDBC

[Christian Müller]

Your configuration is not correct. Have a look at
https://github.com/muellerc/camel-in-transaction

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Fri, Mar 20, 2015 at 5:17 PM, Cecilio Alvarez 
cecilio.alva...@hotmail.com wrote:

 Hello

 I tried to create a transacted route, but after 7 retries the message is
 discarded and if the process is killed the message is lost.
 Setting the transacted parameter, the vm connector is repeatedly
 starting/stopping. Why happens this?

 route id=SQLInsert
 from uri=activemq:in.Q?transacted=true/
 transacted/
 to uri=sql:insert into table
 values(:#${body})?dataSource=testDB/
 /route

 Beans

 bean id=transactionManager
 class=org.springframework.jdbc.datasource.DataSourceTransactionManager
 property name=dataSource ref=testDB/
 /bean

 bean id=PROPAGATION_REQUIRED
 class=org.apache.camel.spring.spi.SpringTransactionPolicy
 property name=transactionManager ref=transactionManager/
 property name=propagationBehaviorName
 value=PROPAGATION_REQUIRED/
 /bean

 Is there a better way of doing this?

 Any help will be appreciated.
 Thanks!




 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-transacted-route-from-JMS-to-JDBC-tp5764486.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel Property - UTF 8 issues

[Christian Müller]

We don't have a class DefaultPropertyPlaceholder in Camel...

If you have fixed the issue, it would be good if you can raise a JIRA and
apply your patch.
I propose to add an encoding option to the PropertiesComponent. Than we
can populate the Properties class in DefaultPropertiesResolver with a
Reader instead an InputStream.

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Tue, Mar 17, 2015 at 6:58 PM, contactreji contactr...@gmail.com wrote:

 Can we have a fix for this if its not available.

 Will be cool if next release can include InputStreamReader constructor
 modified to allow specify UTF-8 unicode characterset reading.

 Something like

 FileInputStream fis = new FileInputStream(
 PathToPropertyFile);
 InputStreamReader isr = new InputStreamReader(fis, UTF8);

 In our project, the fix was done by extending DefaultPropertyPlaceholder
 class and overriding the method to instantiate InputStreamReader with
 charset UTF-8 enforced.



 -
 Reji Mathews
 Sr. Developer - Middleware Integration / SOA ( Open Source - Apache Camel
  Jboss Fuse ESB | Mule ESB )
 LinkedIn - http://in.linkedin.com/pub/reji-mathews/31/9a2/40a
 Twitter - reji_mathews
 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-Property-UTF-8-issues-tp5764281p5764291.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: [SQL COMPONENT] mysql transaction

[Christian Müller]

Have a look at [1].

from(direct:start)
.transacted(PROPAGATION_REQUIRED)
.to(sql:INSERT ...)
.to(sql:INSERT ...);

[1]
https://github.com/muellerc/camel-in-transaction/blob/master/src/test/java/org/apache/cmueller/camel/samples/camelone/jdbc/JdbcTransactionSampleTest.java

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, Dec 29, 2014 at 10:55 AM, fabrizio.spataro 
fabrizio.spat...@bizmate.it wrote:

 Hello,

 i would use sql component (http://camel.apache.org/sql-component.html)
 into
 a transactional scenario.

 For example:

 0) begin
 1) insert
 2) insert
 3) commit

 I am using mysql.

 What is the best strategy to do it using camel's component?

 Tnkx





 --
 View this message in context:
 http://camel.465427.n5.nabble.com/SQL-COMPONENT-mysql-transaction-tp576.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: [SQL COMPONENTE] CamelSqlGeneratedKeyRows has a bug?

[Christian Müller]

Which Camel version do you use?

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, Dec 29, 2014 at 12:28 PM, fabrizio.spataro 
fabrizio.spat...@bizmate.it wrote:

 Hello,

 i am using sql component with CamelSqlRetrieveGeneratedKeys=true but after
 an insert operation i don't have any CamelSqlGeneratedKeyRows header.

 Is it a bug?

 I am using mysql server 5.1.

 Tnkx



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/SQL-COMPONENTE-CamelSqlGeneratedKeyRows-has-a-bug-tp5761113.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

ApacheCon NA 2015 :: Austin, TX :: April 13 - 16, 2015

[Christian Müller]

Safe the date

http://events.linuxfoundation.org/events/apachecon-north-america

Best,
Christian

Re: [ANNOUNCE] Apache Camel 2.13.3 Released

[Christian Müller]

Thanks for reporting James!

There was a typo in the title which I have fixed now. The link should work
in a few hours, after the WIKI page [1] is exported.

[1] https://cwiki.apache.org/confluence/display/CAMEL/Camel+2.13.3+Release

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Wed, Nov 5, 2014 at 12:20 PM, James Green james.mk.gr...@gmail.com
wrote:

 The [4] link below does not exist.

 The download page shows 2.13.3 but is linked to 2.13.2.

 On 1 November 2014 07:53, Christian Mueller cmuel...@apache.org wrote:

  The Apache Camel project [1] is a powerful open source integration
  framework based on known Enterprise Integration Patterns [2].
 
  The Camel community announces the immediate availability of the new patch
  release camel-2.13.3.
 
  The artifacts are published and ready for you to download [3] either from
  the Apache mirrors or from the Central Maven repository.
  For more details please take a look at the release notes [4].
 
  Many thanks to the Camel community for the hard work.
 
  Christian
 
  [1]http://camel.apache.org/
  [2]http://camel.apache.org/enterprise-integration-patterns.html
  [3]http://camel.apache.org/download.html
  [4]http://camel.apache.org/camel-2133-release.html
 

Re: executing PL/SQL script

[Christian Müller]

And have a look at the Camel MyBatis/IBatis component.

Best,
Christian
Am 07.11.2014 18:03 schrieb Preben.Asmussen p...@dr.dk:

 Hi M

 You can always uses a regular java bean for executing custom logic. See
 Bean binding http://camel.apache.org/bean-binding.html

 The custom bean could execute your PLSQL using eg. Springs JdbcTemplate

 /Preben



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/executing-PL-SQL-script-tp5758616p5758708.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel - JDBC

[Christian Müller]

http://camel.apache.org/running-camel-standalone-and-have-it-keep-running.html

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Tue, Nov 4, 2014 at 7:47 AM, smilevasu6 srinivas.thu...@gmail.com
wrote:

 Claus Ibsen, if i write these configuration xml files in eclipse (i am
 using)
 how can i run these from eclipse as there is no Java class to call these.

 Could you please help?



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-JDBC-tp5758485p5758488.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel 2.15-SNAPSHOT dependency missing sources in repo

[Christian Müller]

Maybe because the build failed because the source artifact was published.

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Tue, Nov 4, 2014 at 10:02 AM, vasilievip vasilie...@gmail.com wrote:


 https://repository.apache.org/content/repositories/snapshots/org/apache/camel/camel-core/2.15-SNAPSHOT/

 If you take a look at latest snapshot build - it does not contain sources,
 sources as published for the previous snapshot, but maven sees that there
 newest build and ignores sources.
 Something with daily build configuration?

 no_sources.PNG
 http://camel.465427.n5.nabble.com/file/n5758495/no_sources.PNG



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-2-15-SNAPSHOT-dependency-missing-sources-in-repo-tp5758495.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel 2.14 breaks our test

[Christian Müller]

Can you provide a test case which is showing the regression?

Best,
Christian


On Fri, Oct 31, 2014 at 4:06 PM, James Green james.mk.gr...@gmail.com
wrote:

 We just upgraded from 2.13.2 to 2.14.0 and our test now hangs using the
 producerTemplate to send to an ActiveMQ (5.10.0) endpoint.

 The route accepts the message, sends it through JAXB and into a Processor
 which doesn't seem to be executed.

 We set debug logging on, and ActiveMQ seems to increment the enqueuedCount,
 then there's a 20 second delay before Camel logs a timeout.

 The route has been modified to log the inbound message, but this doesn't
 trigger either.

 It works fine if we revert back to Camel 2.13.2. Any ideas?

 Thanks,

 James

Re: SMPP component and problem with valid period (relative) and data message

[Christian Müller]

For your first question, have a look at [1]. This is how we pass the value
to the jsmpp library.

[1]
https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppSubmitSmCommand.java;h=ac5f4f1e8531f8603509a9f72eb67283ae10e8ac;hb=HEAD

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Tue, Oct 28, 2014 at 1:40 PM, hanusto hanu...@gmail.com wrote:

 Hello,

 I have two questions for SMPP camel component:

 1) how to set valid period as relative ? It can be defined in absolute time
 format or relative time format if you provide it as String as specified in
 chapter 7.1.1 in the smpp specification v3.4. in format 010R
 as one day:

 exchange.getIn().setHeader(SmppConstants.VALIDITY_PERIOD,
 constant(010R));

 but in packet trace I see deafult value because this format is incorrect,
 probably, but exactly based upon specification. Maybe bug?

 2) I would like to send push sms (m-notification-ind PDU type). As content
 of message (exchange.getIn().setBody()) I am sending byte array as whole
 message with UDHI segment. Data coding schema is Octet unspecified (8-bit
 binary) (0x04). Problem is that SMPP component calculates length of
 message
 and EsmClass is configured in right way only if length is greater than 140
 number of bytes.

 In SmppSubmitSmCommand:
 template.setEsmClass(new ESMClass(MessageMode.DEFAULT,
 MessageType.DEFAULT,
 GSMSpecificFeature.UDHI).value());

 I think that message size is not related to UDHI and therefore why is
 splitted and after that if segments is more than one, EmsClass with UDHI is
 configured properly?

 Please, is here any solution how to send m-notification-ind PDU type? As
 hot
 fix I checkout SMPP camel component and use custom modification of this
 behaviour.

 Thanks,
 Tomas



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/SMPP-component-and-problem-with-valid-period-relative-and-data-message-tp5758217.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Adding jaas authentication to a cxf endpoint in karaf

[Christian Müller]

The keystore configuration is only needed for HTTPS.
You can use BASIC AUTH without HTTPS.

If you want to leverage on the OSGI HTTP service (it looks so, because you
are using address=/externalWarehouse), you have to configure BASIC AUTH
in your jetty.xml like:

Configure class=org.eclipse.jetty.server.Server
!-- === --
!-- Set connectors --
!-- === --
!-- One of each type! --
!-- === --

Call name=addConnector
Arg
New class=org.eclipse.jetty.server.nio.BlockingChannelConnector
Set name=host
Property name=jetty.host /
/Set
Set name=port
Property name=jetty.port default=8181 /
/Set
Set name=maxIdleTime30/Set
Set name=Acceptors1/Set
Set name=statsOnfalse/Set
Set name=confidentialPort8443/Set
/New
/Arg
/Call

Call name=addBean
Arg
New class=org.eclipse.jetty.plus.jaas.JAASLoginService
Set name=namekaraf/Set
Set name=loginModuleNamekaraf/Set
Set name=roleClassNames
Array type=java.lang.String

Itemorg.apache.karaf.jaas.boot.principal.RolePrincipal/Item
/Array
/Set
/New
/Arg
/Call

Call name=addBean
Arg
New class=org.eclipse.jetty.plus.jaas.JAASLoginService
Set name=namedefault/Set
Set name=loginModuleNamekaraf/Set
Set name=roleClassNames
Array type=java.lang.String

Itemorg.apache.karaf.jaas.boot.principal.RolePrincipal/Item
/Array
/Set
/New
/Arg
/Call
/Configure





If you want to start up a new Jetty instance to expose your web service,
your configuration looks good. As Willem already explained, you has to
configure a complete URL like address=
http://127.0.0.1:9000/externalWarehouse;. And you can remove the keystore
configuration if you are using HTTP.

   httpj:engine-factory bus=*cxf*

  httpj:engine port=*9000*

httpj:threadingParameters minThreads=*5* maxThreads=*20* /

httpj:handlers

!-- BASIC AUTHENTICATION configuration --

ref bean=*securityHandler*/

/httpj:handlers

  /httpj:engine
   /httpj:engine-factory


bean id=*securityHandler* class=
*org.eclipse.jetty.security.ConstraintSecurityHandler*

property name=*authenticator*

bean class=
*org.eclipse.jetty.security.authentication.BasicAuthenticator*/

/property

property name=*constraintMappings*

list

bean class=*org.eclipse.jetty.security.ConstraintMapping*


property name=*constraint*

bean class=
*org.eclipse.jetty.http.security.Constraint*

property name=*name* value=*BASIC*/

property name=*roles* value=*yourRole*/

property name=*authenticate* value=*true*/

/bean

/property

property name=*pathSpec* value=*/**/

/bean

/list

/property

property name=*loginService*

bean class=*org.eclipse.jetty.security.HashLoginService*

property name=*name* value=*karaf* /

property name=*config* value=
*src/test/resources/jetty-realm.properties* /

/bean

/property

property name=*strict* value=*false*/
/bean

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Fri, Oct 31, 2014 at 9:44 AM, Hilderich hilde.sch...@yahoo.de wrote:

 Hello Willem,

 Many thanks for that crucial hint. I did as you said but no Basic
 Authentication was requested. What I am not understand so far is the
 keystore stuff in httpj:tlsServerParameters ...
 As I interpret it correctly this has something to do with SSL/https but I
 have no intentions to switch to https. As a result I have in the meantime
 lt;httpj ... section in blueprint modified to:

 lt;httpj:engine-factory bus=quot;cxfquot;
 httpj:engine port=9000
 httpj:threadingParameters minThreads=5
 maxThreads=20 /
 httpj:handlers
 ref component-id=securityHandler /
 /httpj:handlers
 /httpj:engine
 /httpj:engine-factory


 Do I have get something wrong? 

[RESULT][VOTE] Release Apache Camel 2.13.3

[Christian Müller]

The vote passes with:
[5] +1 (jgenender, joed, akarpe, cmueller, davsclaus)
[2] +1 - non-binding (jbonofre, ggrzybek)
[0] -1

I will proceed with publishing the artifacts later today, if the Nexus repo
is accessable again and make public announcement of the release tomorrow,
after the mirrors sync up.

Many thanks to all contributors,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Tue, Oct 28, 2014 at 7:54 PM, Christian Müller 
christian.muel...@gmail.com wrote:

 This is a vote to release Apache Camel 2.13.3, a patch release coming with
 about 103 issues fixed.

 Release notes:

 https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327165
 https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327166

 Staging repo:
 https://repository.apache.org/content/repositories/orgapachecamel-1022

 Tarballs:

 https://repository.apache.org/content/repositories/orgapachecamel-1022/org/apache/camel/apache-camel/2.13.3/

 Tag:

 https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=7bcf9592cb94b2356f2a60227eaf39478174ad5b
 https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=42850495b5a53878ceb1aec40f57b0b636e96e58

 Please test this release candidate and cast your vote.
 [ ] +1 Release the binary as Apache Camel 2.13.3
 [ ] -1 Veto the release (provide specific comments)
 Vote is open for at least 72 hours.

 Thanks,
 Christian

Re: How to pick multiple file in same route

[Christian Müller]

http://camel.apache.org/aggregator2.html

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Wed, Oct 29, 2014 at 1:07 PM, dkum003 dhananjay.ku...@amadeus.com
wrote:

 Hi,

 Currently we are picking one files and corresponding .md5 file from
 ftp/sftp  server.
 The file name has some naming convention.
 For this we are using PollingConsumerPollStrategy and
 AntPathMatcherGenericFileFilter.

 Now I want to process multiple file based on some condition, what we have
 to
 do?

 Any help will be appreciated.

 Regards,
 Dhananjay



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/How-to-pick-multiple-file-in-same-route-tp5758294.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

[VOTE] Release Apache Camel 2.13.3

[Christian Müller]

This is a vote to release Apache Camel 2.13.3, a patch release coming with
about 103 issues fixed.

Release notes:
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327165
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327166

Staging repo:
https://repository.apache.org/content/repositories/orgapachecamel-1022

Tarballs:
https://repository.apache.org/content/repositories/orgapachecamel-1022/org/apache/camel/apache-camel/2.13.3/

Tag:
https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=7bcf9592cb94b2356f2a60227eaf39478174ad5b
https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=42850495b5a53878ceb1aec40f57b0b636e96e58

Please test this release candidate and cast your vote.
[ ] +1 Release the binary as Apache Camel 2.13.3
[ ] -1 Veto the release (provide specific comments)
Vote is open for at least 72 hours.

Thanks,
Christian

Re: [VOTE] Release Apache Camel 2.13.3

[Christian Müller]

+1

The signature looks good.

The manual looks good.

I could install all Camel features in Karaf except camel-optaplanner [1].

I could also upgrade the Camel in Action source code to Camel 2.13.3. I got
two errors by executing the tests:

[INFO] Compiling 2 source files to
/Users/cmueller/workspaceCamel/camelinaction/chapter11/scala-router/target/classes
at 1414531996073
[ERROR] error: class file needed by RouteBuilder is missing.
[INFO] reference type ClassTag of package reflect refers to nonexisting
symbol.
[ERROR] one error found

[INFO] Compiling 2 source files to
/Users/cmueller/workspaceCamel/camelinaction/chapter11/scala-router-javacontext/target/classes
at 1414532205706
[ERROR] error: class file needed by RouteBuilder is missing.
[INFO] reference type ClassTag of package reflect refers to nonexisting
symbol.
[ERROR] one error found

[1] https://issues.apache.org/jira/browse/CAMEL-7979

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Tue, Oct 28, 2014 at 7:54 PM, Christian Müller 
christian.muel...@gmail.com wrote:

 This is a vote to release Apache Camel 2.13.3, a patch release coming with
 about 103 issues fixed.

 Release notes:

 https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327165
 https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327166

 Staging repo:
 https://repository.apache.org/content/repositories/orgapachecamel-1022

 Tarballs:

 https://repository.apache.org/content/repositories/orgapachecamel-1022/org/apache/camel/apache-camel/2.13.3/

 Tag:

 https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=7bcf9592cb94b2356f2a60227eaf39478174ad5b
 https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=42850495b5a53878ceb1aec40f57b0b636e96e58

 Please test this release candidate and cast your vote.
 [ ] +1 Release the binary as Apache Camel 2.13.3
 [ ] -1 Veto the release (provide specific comments)
 Vote is open for at least 72 hours.

 Thanks,
 Christian

[RESULT][VOTE] Release Apache Camel 2.12.5 - second try

[Christian Müller]

The vote passes with:
[7] +1 (jgenender, joed, cmueller, ningjiang, cschneider, janstey, hadrian)
[1] +1 - non-binding (jbonofre)
[0] -1

I will proceed with publishing the artifacts later today, if the Nexus repo
is accessable again and make public announcement of the release tomorrow,
after the mirrors sync up.

Many thanks to all contributors,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Fri, Oct 24, 2014 at 5:17 PM, Christian Müller 
christian.muel...@gmail.com wrote:

 This is a vote to release Apache Camel 2.12.5, a patch release coming with
 about 74 issues fixed.

 Release notes:

 https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327166

 Staging repo:
 https://repository.apache.org/content/repositories/orgapachecamel-1020

 Tarballs:

 https://repository.apache.org/content/repositories/orgapachecamel-1020/org/apache/camel/apache-camel/2.12.5/

 Tag:

 https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=42850495b5a53878ceb1aec40f57b0b636e96e58

 Please test this release candidate and cast your vote.
 [ ] +1 Release the binary as Apache Camel 2.12.3
 [ ] -1 Veto the release (provide specific comments)
 Vote is open for at least 72 hours.

 Thanks,
 Christian

Re: [VOTE] Release Apache Camel 2.12.5 - second try

[Christian Müller]

+1

I could install almost all features in Karaf 2.3.x.
The signature is good.
The manual looks good.
I could successfully upgrade the Camel in Action code to Camel 2.12.5.

However, I discovered the following issues:

I could not install the feature camel-bean-validator without installing
mvn:com.fasterxml/classmate/1.0.0 before. In Camel 2.12.5 we are using
the version 0.8.0 which doesn't fit the OSGI package import range.

I could not install the feature camel-cache without installing
mvn:org.apache.geronimo.specs/geronimo-jta_1.1_spec/1.1.1 before.

Will add it to the known issue section...

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Fri, Oct 24, 2014 at 5:17 PM, Christian Müller 
christian.muel...@gmail.com wrote:

 This is a vote to release Apache Camel 2.12.5, a patch release coming with
 about 74 issues fixed.

 Release notes:

 https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327166

 Staging repo:
 https://repository.apache.org/content/repositories/orgapachecamel-1020

 Tarballs:

 https://repository.apache.org/content/repositories/orgapachecamel-1020/org/apache/camel/apache-camel/2.12.5/

 Tag:

 https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=42850495b5a53878ceb1aec40f57b0b636e96e58

 Please test this release candidate and cast your vote.
 [ ] +1 Release the binary as Apache Camel 2.12.3
 [ ] -1 Veto the release (provide specific comments)
 Vote is open for at least 72 hours.

 Thanks,
 Christian

[CANCEL][VOTE] Release Apache Camel 2.12.5

[Christian Müller]

-1

As I wrote earlier, this VOTE is cancelt because the Nexus repository
doesn't contain the binary nor the source distributions.
A new release candidate is in progress and will be available for test later
today.

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member



On Thu, Oct 23, 2014 at 7:14 AM, Christian Müller 
christian.muel...@gmail.com wrote:

 This is a vote to release Apache Camel 2.12.5, a patch release coming with
 about 74 issues fixed.

 Release notes:

 https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327166

 Staging repo:
 https://repository.apache.org/content/repositories/orgapachecamel-1017

 Tarballs:

 https://repository.apache.org/content/repositories/orgapachecamel-1017/org/apache/camel/apache-camel/2.12.5/

 Tag:

 https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=42850495b5a53878ceb1aec40f57b0b636e96e58

 Please test this release candidate and cast your vote.
 [ ] +1 Release the binary as Apache Camel 2.12.3
 [ ] -1 Veto the release (provide specific comments)
 Vote is open for at least 72 hours.

 Thanks,
 Christian

[VOTE] Release Apache Camel 2.12.5 - second try

[Christian Müller]

This is a vote to release Apache Camel 2.12.5, a patch release coming with
about 74 issues fixed.

Release notes:
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327166

Staging repo:
https://repository.apache.org/content/repositories/orgapachecamel-1020

Tarballs:
https://repository.apache.org/content/repositories/orgapachecamel-1020/org/apache/camel/apache-camel/2.12.5/

Tag:
https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=42850495b5a53878ceb1aec40f57b0b636e96e58

Please test this release candidate and cast your vote.
[ ] +1 Release the binary as Apache Camel 2.12.3
[ ] -1 Veto the release (provide specific comments)
Vote is open for at least 72 hours.

Thanks,
Christian

[CANCEL][VOTE] Release Apache Camel 2.12.5

[Christian Müller]

This release candidate doesn't contain the Camel distro and Camel source
distro.
I think this happened because I had to re-stage the release after one
reported signate failure in Nexus. Will redo the release upload...

Best,
Christian


On Thu, Oct 23, 2014 at 7:14 AM, Christian Müller 
christian.muel...@gmail.com wrote:

 This is a vote to release Apache Camel 2.12.5, a patch release coming with
 about 74 issues fixed.

 Release notes:

 https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327166

 Staging repo:
 https://repository.apache.org/content/repositories/orgapachecamel-1017

 Tarballs:

 https://repository.apache.org/content/repositories/orgapachecamel-1017/org/apache/camel/apache-camel/2.12.5/

 Tag:

 https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=42850495b5a53878ceb1aec40f57b0b636e96e58

 Please test this release candidate and cast your vote.
 [ ] +1 Release the binary as Apache Camel 2.12.3
 [ ] -1 Veto the release (provide specific comments)
 Vote is open for at least 72 hours.

 Thanks,
 Christian

[VOTE] Release Apache Camel 2.12.5

[Christian Müller]

This is a vote to release Apache Camel 2.12.5, a patch release coming with
about 74 issues fixed.

Release notes:
https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12311211version=12327166

Staging repo:
https://repository.apache.org/content/repositories/orgapachecamel-1017

Tarballs:
https://repository.apache.org/content/repositories/orgapachecamel-1017/org/apache/camel/apache-camel/2.12.5/

Tag:
https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tag;h=42850495b5a53878ceb1aec40f57b0b636e96e58

Please test this release candidate and cast your vote.
[ ] +1 Release the binary as Apache Camel 2.12.3
[ ] -1 Veto the release (provide specific comments)
Vote is open for at least 72 hours.

Thanks,
Christian

Re: Camel Endpoint / Consumer startup

[Christian Müller]

You can find the latest SNAPSHOT versions at
http://repository.apache.org/content/groups/snapshots/org/apache/camel/.
They will be published after a successful Jenkins build, otherwise not...

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Fri, Oct 17, 2014 at 5:34 PM, ddewaele ddewa...@gmail.com wrote:

 OK. We'll test with this on monday first thing.

 Are Camel snapshots automatically built and published on a remote maven
 repo
 somewhere ?
 If we point to 2.15-SNAPSHOT  we should be good to go ?

 Is there a release schedule available for Camel so we can have a look when
 2.15 is scheduled for release ?

 Thx for committing the fix !



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-Endpoint-Consumer-startup-tp5757635p5757737.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: custom converter to string (json, xml, csv)

[Christian Müller]

You are looking for different data formats, not for different type
converters.

Best,
Christian
Am 17.10.2014 20:50 schrieb Mark Webb elihusma...@gmail.com:

 I have a custom object that I will be passing through Camel routes and
 there may be times where I want to convert the object to different formats,
 which means that I need to write custom converters.  My question is, how do
 I write a converter for the different String-based formats such as JSON,
 XML and CSV and have Camel be smart enough to choose the correct one?

 If I have the following methods

 @Converter
 public String myObjectToXml( MyObject event ){
 // do stuff here
 return xmljunk/xml;
 }

 @Converter
 public String myObjectToJson( MyObject event ){
 // do stuff here
 return {stuff:junk};
 }

 @Converter
 public String myObjectToCsv( MyObject event ){
 // do stuff here
 return junk,blah;
 }

 So I would marshal the object to a String-based format, but how does Camel
 know which one I want?

Re: Using a custom SessionStateListener with SMPP

[Christian Müller]

Hi Andrew!

Did you checked http://camel.apache.org/smpp.html?

You can use it e.g. like:
smpp://smppclient@localhost:2775?password=passwordsessionStateListener=myS
essionStateListener

Where mySessionStateListener is the bean name in the registry.

Best,
Christian


On Wed, Oct 8, 2014 at 7:21 AM, Andrew Hine andrew.h...@touchcorp.com
wrote:

 Hi



 I'm attempting to use a custom SessionStateListener with Apache Camel SMPP
 = component (see https://issues.apache.org/jira/browse/CAMEL-5043 )



 I'm new to Camel and cannot seem to find any documentation of how to use
 my=  own SessionStateListener (I want to be notified when the SMPP
 connection i= s lost and later recovered).



 Is anyone able to point me in the correct direction?



 Thanks



 Andrew


 
 This email and any files transmitted with it may be confidential and are
 intended solely for the use of the individual or entity to whom they are
 addressed. This email may contain personal information of individuals, and
 be subject to Commonwealth and/or State privacy laws in Australia. This
 email is also subject to copyright. If you are not the intended recipient,
 you must not read, print, store, copy, forward or use this email for any
 reason, in accordance with privacy and copyright laws. If you have received
 this email in error, please notify the sender by return email, and delete
 this email from your inbox.

Re: XSLT Thread Safety Issue

[Christian Müller]

Hello Sam!

I don't have so much experience with XSLT, but maybe my suggestions are
nevertheless helpful:
- if possible, use the Saxon transformer factory as described here [1]. The
JDK build in is slow, buggy, ...
- if possible, use the Saxon XPath factory as described here [2]. It's much
faster than the JDK build in as I measured [3].
- if it's not possible to use Saxon, may try to update the JDK to get a
newer version of the transformer/XPath factories (I believe it's an issue
there)
- and Willem was referring to the XSLT component options
transformerCacheSize and contentCache, but it looks like you are using the
default values. So, there is no issue here.

[1] http://camel.apache.org/xslt
[2] http://camel.apache.org/xpath.html
[3] http://www.slideshare.net/muellerc/apache-con-na-2013

Best,
Christian


On Tue, Oct 14, 2014 at 3:44 PM, Hendley, Sam sam.hend...@sensus.com
wrote:

 The route endpoint was
 xslt:classpath:xslt/orch-encryptionkey-flowRemoveNamespace.xsl. You may
 have been asking for the actual XSLT which I included but it looks like it
 got pruned by the listserver. I will include it here xml encoded:

 lt;xsl:stylesheet version=quot;1.0quot; xmlns:xsl=quot;
 http://www.w3.org/1999/XSL/Transformquot;gt;
 lt;xsl:output standalone=quot;yesquot;
 omit-xml-declaration=quot;yesquot; /gt;

 lt;xsl:template match=quot;processing-instruction()quot;gt;
 lt;xsl:copygt;lt;xsl:apply-templates/gt;lt;/xsl:copygt;
 lt;/xsl:templategt;

 lt;xsl:template match=quot;*quot;gt;
 lt;xsl:element
 name=quot;{local-name()}quot;gt;lt;xsl:apply-templates select=quot;@
 *|node()quot;/gt;lt;/xsl:elementgt;
 lt;/xsl:templategt;

 lt;xsl:template match=quot;@*quot;gt;
 lt;xsl:attribute
 name=quot;{local-name()}quot;gt;lt;xsl:value-of
 select=quot;.quot;/gt;lt;/xsl:attributegt;
 lt;/xsl:templategt;
 lt;/xsl:stylesheetgt;


 I don't believe we are using either of those options, a full text search
 of our entire codebase didn't yield any references.

 Sam

 -Original Message-
 From: Willem Jiang [mailto:willem.ji...@gmail.com]
 Sent: Monday, October 13, 2014 11:07 PM
 To: users@camel.apache.org
 Subject: Re: XSLT Thread Safety Issue

 Can I have a look at you XSLT endpoint uri?
 Did you use the options of transformerCacheSize or contentCache?

 --
 Willem Jiang

 Red Hat, Inc.
 Web: http://www.redhat.com
 Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com
 (Chinese)
 Twitter: willemjiang
 Weibo: 姜宁willem



 On October 14, 2014 at 9:45:39 AM, Hendley, Sam (sam.hend...@sensus.com)
 wrote:
  We are having a very strange (and intermittent) issue with some of our
 camel routes.
 
  We are in the process of upgrading to a more up-to-date version but
  are still on camel 2.10.7 and running on java 1.6. I have looked
  through the forums and tickets but haven't found anything that looks
 like it could cause this issue.
 
  What appears to be occurring is this:
 
  * An XML document is received from a JMS queue (as a text message)
 
  o The xml is correctly formatted and is what we expect to see
 
  * It is then routed through an XSLT transformation (to strip off
  excess namespacing)
 
  * 99% of the time this works, but very occasionally we get Xpath
  errors when we go onto the next step
 
  * We were able to do a heap dump of a system that was having this
  problem, when we dug through the dump we were able to analyze an
  instance of the failure (same exchangeId)
 
  o It turns out that when the issue occurs the enclosing tags (document
  root) have disappeared rendering the document un-xpathable
 
  Since this works nearly all of the time and there is nothing special
  about the failing documents we suspect it could be a threading or race
 condition in the XSLT processing.
  Are there any known issues that might be related? This route is
  running in a relatively large and busy camel application that makes
  heavy use of XSLT transforms. We believe similar issues have occurred
  in other instances but haven't debugged to this level so that is just a
 hunch.
 
  I have included some details below, let me know if there is more I
  should include. I still have the heap/thread dump if there is anything
 else that might be worth digging into.
 
  Thanks for any help or advise,
 
  Sam Hendley
 
  Jms Timeout message (notice it has xml header and wrapping of
  EncryptionKeyFlow) [cid:image001.png@01CFD7FC.D4F23FD0]
 
 
 
  2193-49984781-keymanager-1411163761368-126275
  orch.encryptionkey.encryptionkeyTimeout.queue
  
  FAIL
  timeout
  Request timed out while waiting for response(s).
 
 
  Camel Body (stripped off top and bottom elements)
  [cid:image002.png@01CFD7FC.D4F23FD0]
 
  2193-49984781-keymanager-1411163761368-126275
  orch.encryptionkey.encryptionkeyTimeout.queue
  ...
  FAIL
  timeout
  Request timed out while waiting for response(s).
 
  Route:
  from(JMS_encryptionkeyTimeout).routeId(JMS_encryptionkeyTimeout)
  .log(LoggingLevel.INFO, 

Re: Handling error per endpoint

[Christian Müller]

Why will onException per route not work for you?

Best,
Christian
Am 29.09.2014 15:04 schrieb Aryan kanwal.is...@gmail.com:

 Hi All,

 We have a camel route and we want to handle exceptions per endpoint. For
 example, if the exception is thrown from processor A, we want A number of
 retries, if thrown from processor B, we want B number of retries and so on.

 We can handle the exception using doTry and throw our customized exception
 per endpoint and then apply different number or retries using OnException.
 Not sure if it is the best approach though. Camel allows exceptions
 policies
 to be applied per route and per context, is it possible to configure it per
 endpoint? Please advice. Or is there any other clean way to do it.

 Thanks!
 Aryan



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Handling-error-per-endpoint-tp5757191.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: FIS Connectivity usingApache Camel

[Christian Müller]

We are using the camel-netty component for a similar requirement (cobal
copybook send to a mainframe system). You have to implement your own
encoder/decoder.

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Thu, Sep 25, 2014 at 7:54 PM, Ravi Gupta 7 rgupt...@sapient.com wrote:

 How we can connect with FIS system using apache camel. FIS system
 understand the request on cobol format?

 Thanks  Regards
 Ravi Gupta

Re: Camel-XmlJson dataformat and ASLV2

[Christian Müller]

Hi Charlie!

It's not complaint with the Apache rules [1]. We will fix this asap.

[1] http://www.apache.org/legal/3party.html#category-x

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Wed, Sep 24, 2014 at 9:28 AM, Charlie Mordant cmorda...@gmail.com
wrote:

 So, I misunderstood that page on the Apache2 license:
 http://www.apache.org/legal/resolved.html

 Can it be updated to reflect that we can use some third party licensed code
 as dependencies (only) in our ASLV2 projects without breaking the rules?
 Should I fill a Jira in the Legal commity space?

 Best too!
 Charlie

 2014-09-23 22:22 GMT+02:00 Christian Müller christian.muel...@gmail.com:

  Thanks for reporting Charlie!
  This is not indeed not complaint with the Apache rules. We will fix this
  soon.
 
  Best,
  Christian
  -
 
  Software Integration Specialist
 
  Apache Member
  V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
  Apache Incubator PMC Member
 
  https://www.linkedin.com/pub/christian-mueller/11/551/642
 
  On Tue, Sep 23, 2014 at 9:03 PM, Charlie Mordant cmorda...@gmail.com
  wrote:
 
   Hi Camel riders!
  
   I just checked the licenses of a project I own.
   This project as a dependency to camel-xmljson dataformat, which itself
  has
   a dependency to XOM.
   The problem is that XOM as a LGPL License that is not compatible ASLv2.
  
   Any info on this? Any XOM ASL compliant alternative?
  
   Best regards,
  
   --
   Charlie Mordant
  
   Full OSGI/EE stack made with Karaf:
   https://github.com/OsgiliathEnterprise/net.osgiliath.parent
  
 



 --
 Charlie Mordant

 Full OSGI/EE stack made with Karaf:
 https://github.com/OsgiliathEnterprise/net.osgiliath.parent

Re: Camel-XmlJson dataformat and ASLV2

[Christian Müller]

Thanks for reporting Charlie!
This is not indeed not complaint with the Apache rules. We will fix this
soon.

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Tue, Sep 23, 2014 at 9:03 PM, Charlie Mordant cmorda...@gmail.com
wrote:

 Hi Camel riders!

 I just checked the licenses of a project I own.
 This project as a dependency to camel-xmljson dataformat, which itself has
 a dependency to XOM.
 The problem is that XOM as a LGPL License that is not compatible ASLv2.

 Any info on this? Any XOM ASL compliant alternative?

 Best regards,

 --
 Charlie Mordant

 Full OSGI/EE stack made with Karaf:
 https://github.com/OsgiliathEnterprise/net.osgiliath.parent

Re: How to run a camel aplication with a cxf web service outside of osgi container

[Christian Müller]

Did you checked our examples? For example the camel-example-cxf at [1]...

[1]
https://git-wip-us.apache.org/repos/asf?p=camel.git;a=tree;f=examples/camel-example-cxf;h=499a63ad4d9df483f503e50a4131aedc822d40eb;hb=HEAD

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Tue, Sep 16, 2014 at 7:29 PM, techybolek techy_bo...@yahoo.com wrote:

 I'm able to run most camel scenarios as a stand-alone java application
 indicating org.apache.camel.spring.Main as the main function. Spring Main
 automatically locates the xml bean file and initializes the camel context
 and the camel routes. I find it very convenient for quick testing an
 debugging.
 However, I could not get the cxf web service endpoints to work that way.
 The
 application builds and launches correctly and the routes that don't include
 the cxf web service endpoints work fine. Also when I deploy the application
 to Service Mix the web service endpoint works fine too.

 Is there any way to get the web service endpoints to work in a standalone
 java application? I'd expect it should be doable, I'd just need to somehow
 initialize the jetty servlet or something...
 Thanks, Thomas





 --
 View this message in context:
 http://camel.465427.n5.nabble.com/How-to-run-a-camel-aplication-with-a-cxf-web-service-outside-of-osgi-container-tp5756600.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: 502 Timeout

[Christian Müller]

http://camel.apache.org/jetty.html

Did you tried the option httpClient.timeout=18?

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642

On Mon, Sep 15, 2014 at 5:51 PM, berdoni berd...@gmail.com wrote:

 Hi,

 I have a simple proxy route deployed on ServiceMix:

 from(jetty:http://
 {{smx.host}}:{{smx.rest-proxy-port}}/{{smx.context}}?matchOnUriPrefix=trueenableMultipartFilter=false)
 .noStreamCaching()
 .to(jetty:http://
 {{target-server-address}}:{{target-ws-port}}/?bridgeEndpoint=truethrowExceptionOnFailure=false);

 All ReST services are proxied without any issue except one where a timeout
 occurs. A direct service call lasts for ~2mins but when the call is proxied
 through SMX it timeouts after 60seconds. How to configure my proxy route to
 timeout on 3mins? My route is deployed on SMX as an OSGi bundle with
 Spring.
 The call is initiated by a CXF producer (i.e. System A) it is proxied
 through SMX and the consumer is a CXF Rest Service on System B.

 SystemA (CXF Rest client) - SMX (camel-hetty proxy route) - System B
 (CXF Rest service)

 thanks



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/502-Timeout-tp5756549.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: apache repository down?

[Christian Müller]

You can check the status here: http://status.apache.org/
There was some failures by accessing the Nexus repository manager...

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Mon, Aug 25, 2014 at 7:05 PM, Matt Raible m...@raibledesigns.com wrote:

 Yeah, it started working again as soon as I sent the message below.
 However, I'm pretty sure it was down today, as well as last week. Does
 anyone know why? Is it possible to publish a beta version of 2.14 to Maven
 Central?

 Thanks,

 Matt

 On Aug 25, 2014, at 11:02 AM, Raul Kripalani r...@evosent.com wrote:

  I was able to access the URLs you posted successfully, with a POM file
  coming back.
  Perhaps check your proxy settings and try a direct curl/wget...
 
  Regards,
 
  *Raúl Kripalani*
  Apache Camel PMC Member  Committer | Enterprise Architect, Open Source
  Integration specialist
  http://about.me/raulkripalani | http://www.linkedin.com/in/raulkripalani
  http://blog.raulkr.net | twitter: @raulvk
 
  On Mon, Aug 25, 2014 at 2:42 PM, Matt Raible m...@raibledesigns.com
 wrote:
 
  Hello all,
 
  I've been using Camel 2.14-SNAPSHOT in my project for the last couple
  months. Last week, and today, it seems that the apache repository has
 been
  down. Has anyone else experienced this as well?
 
  Downloading:
 
 https://repository.apache.org/content/repositories/snapshots/org/apache/camel/components/2.14-SNAPSHOT/components-2.14-20140823.052541-129.pom
  [INFO]
  
  [INFO] BUILD FAILURE
  [INFO]
  
  [INFO] Total time: 01:02 min
  [INFO] Finished at: 2014-08-25T07:41:12-07:00
  [INFO] Final Memory: 12M/245M
  [INFO]
  
  [ERROR] Failed to execute goal on project palogic-services: Could not
  resolve dependencies for project
  com.hidinc.palogic:palogic-services:war:1.0-SNAPSHOT: Failed to collect
  dependencies at org.apache.camel:camel-csv:jar:2.14-SNAPSHOT: Failed to
  read artifact descriptor for
 org.apache.camel:camel-csv:jar:2.14-SNAPSHOT:
  Could not transfer artifact
  org.apache.camel:components:pom:2.14-20140823.052541-129 from/to
  apache.snapshots (
  https://repository.apache.org/content/repositories/snapshots/): Failed
 to
  transfer file:
 
 https://repository.apache.org/content/repositories/snapshots/org/apache/camel/components/2.14-SNAPSHOT/components-2.14-20140823.052541-129.pom
 .
  Return code is: 502 , ReasonPhrase:Proxy Error. - [Help 1]
 
  Thanks,
 
  Matt

Re: Problems with the Wire Tap Pattern

[Christian Müller]

Can you share the Processor's with us?
And which version do you use?

Best,
Christian
Am 19.08.2014 00:30 schrieb Luis Augusto C. Sauerbronn lasa...@gmail.com
:

 Good afternoon,

 I am trying to apply the Wire Tap pattern to an existing (and working)
 route but it seems not to work as I was expecting.
 The original route is a CXF based Webservice. I want to intercept the
 response and post it to a JMS queue for later consumption.

 As I want to use the same queue to different operations (and different
 responses), for each Wire Tap point I created a Processor that creates a
 normalized Exchange with a Serializable Bean in its body.

 As expected, the original route kept working without problems, but the
 thread that is started to answer the Wire Tap is interrupted  with the
 following JMSException informing it was not possible to serialize the
 message.

 org.springframework.jms.UncategorizedJmsException: Uncategorized exception
 occured during JMS processing; nested exception is javax.jms.JMSException:
 Failed to serialize object; nested exception is
 java.io.NotSerializableException: *some.package.someClass*

 The problem is, the message is indicating that it is trying to serialize
 the original WebService response, not the normalized (and serializable)
 object I created.

 My route looks like this:

 from(cxfendpoint)
  .processRef(firstProcessorReference)
  .processRef(secondProcessorReference)
  .processRef(thirdProcessorReference)
  .wiretap(jmsEndpoint)
   .newExchangeRef(wireTapProcessorReference)
  .end()
 .end();

 All endpoints an processor are being injected from the applicationContext.

 Does anybody have an idea of why is it trying to serialize the wrong
 object? I am doing something wrong?

 Thanks in advance.

  Luis

Re: Cannot shutdown CamelContext even call CamelContext.stop/ServiceHelper in another thread

[Christian Müller]

It's a really old version and we improved this in the more recent versions.
Any chance to upgrade?

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Sun, Aug 17, 2014 at 5:57 AM, sckwow sckwow...@gmail.com wrote:

 Hi,
 I am using Camel 2.8.2, sometimes the CamelContext.stop is not working if
 there is inflight message that is retrying forever in the processor due to
 exception. I assume that there will be force shutdown after the timeout...
 but sometimes it do force shutdown but sometimes force shutdown is not
 working... any idea?

 thanks



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Cannot-shutdown-CamelContext-even-call-CamelContext-stop-ServiceHelper-in-another-thread-tp5755306.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Question: camel-sql out of memory error

[Christian Müller]

Yes, of course...
I have opened a JIRA [1] and start working on it.

[1] https://issues.apache.org/jira/browse/CAMEL-7700

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Thu, Aug 14, 2014 at 3:22 PM, Claus Ibsen claus.ib...@gmail.com wrote:

 Hi

 IMHO you should only set that fetch limit if getMaxMessagesPerPoll 
 0. So the user needs to set that option explicit if he/she want to
 limit it.



 On Wed, Aug 13, 2014 at 2:07 PM, Christian Müller
 christian.muel...@gmail.com wrote:
  At present, we do not limit the fetch size on the JDBC driver level which
  will fix this issue (e.g.
  preparedStatement.setFetchSize(getMaxMessagesPerPoll())).
  The drawback is, we don't know how many rows are in the database which
 will
  match our query. We only can assume if fetchSize is equal to
  maxMessagesPerPoll, there are more rows to read.
 
  From my point of view, we should go for this change. If nobody has
  objections, I will will do the needed changes later this week...
 
  Best,
 
  Christian
  -
 
  Software Integration Specialist
 
  Apache Member
  V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
  Apache Incubator PMC Member
 
  https://www.linkedin.com/pub/christian-mueller/11/551/642
 
 
  On Fri, Aug 8, 2014 at 10:34 PM, Matt Payne pa...@mattpayne.org wrote:
 
  I am getting an  java.lang.OutOfMemoryError: Java heap space when using
  camel sql component with a query that returns a large number of rows.
 
  Using a small value for maxMessagesPerPoll=10 does not help[1].
 
  When reading the source[2], I see:
  255   protected ListMapString, Object queryForList(ResultSet rs)
 throws
  SQLException {
  256 ColumnMapRowMapper rowMapper = new ColumnMapRowMapper();
  257 RowMapperResultSetExtractorMapString, Object mapper =
 new
  RowMapperResultSetExtractorMapString, Object(rowMapper);
  258 ListMapString, Object data = mapper.extractData(rs);
  259 return data;
  260 }
 
  It seems that all of the result set, rs, is going to be read regardless
 of
  how large it is.   When stepping through via eclipse's debugger this is
  what I see happening.
 
  It's unclear how to ask camel sql component to only take X rows at a
 time.
Is there a way to do this please?
 
  Thanks! --Matt Payne
 
 
  [1]
 
 http://camel.465427.n5.nabble.com/Fetching-data-in-batches-td5718366.html
  [2]
 
 
 https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlEndpoint.java#l255
 



 --
 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
 hawtio: http://hawt.io/
 fabric8: http://fabric8.io/

Re: Question: camel-sql out of memory error

[Christian Müller]

At present, we do not limit the fetch size on the JDBC driver level which
will fix this issue (e.g.
preparedStatement.setFetchSize(getMaxMessagesPerPoll())).
The drawback is, we don't know how many rows are in the database which will
match our query. We only can assume if fetchSize is equal to
maxMessagesPerPoll, there are more rows to read.

From my point of view, we should go for this change. If nobody has
objections, I will will do the needed changes later this week...

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Fri, Aug 8, 2014 at 10:34 PM, Matt Payne pa...@mattpayne.org wrote:

 I am getting an  java.lang.OutOfMemoryError: Java heap space when using
 camel sql component with a query that returns a large number of rows.

 Using a small value for maxMessagesPerPoll=10 does not help[1].

 When reading the source[2], I see:
 255   protected ListMapString, Object queryForList(ResultSet rs) throws
 SQLException {
 256 ColumnMapRowMapper rowMapper = new ColumnMapRowMapper();
 257 RowMapperResultSetExtractorMapString, Object mapper = new
 RowMapperResultSetExtractorMapString, Object(rowMapper);
 258 ListMapString, Object data = mapper.extractData(rs);
 259 return data;
 260 }

 It seems that all of the result set, rs, is going to be read regardless of
 how large it is.   When stepping through via eclipse's debugger this is
 what I see happening.

 It's unclear how to ask camel sql component to only take X rows at a time.
   Is there a way to do this please?

 Thanks! --Matt Payne


 [1]
 http://camel.465427.n5.nabble.com/Fetching-data-in-batches-td5718366.html
 [2]

 https://git-wip-us.apache.org/repos/asf?p=camel.git;a=blob;f=components/camel-sql/src/main/java/org/apache/camel/component/sql/SqlEndpoint.java#l255

Re: Multiple JMS producer with IBMMQ

[Christian Müller]

Hi Shadab!

Sorry, I overlooked that you are talking about the producer.
What is the source you are reading from?
And may the thread() DSL element is helpful for you:

from(xxx)
   .threads(3, 10, threadName)
   .to(xxx);


Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Tue, Aug 5, 2014 at 8:26 AM, Ali, Mohammad mohammad.a...@genpact.com
wrote:

 Hi Christian,

 Thanks for your reply.

 Will concurrentConsumer option work for producer also? I will give a try
 to this.

 Regards,
 Shadab


 -Original Message-
 From: Christian Müller [mailto:christian.muel...@gmail.com]
 Sent: Tuesday, August 05, 2014 1:40 AM
 To: users@camel.apache.org
 Subject: Re: Multiple JMS producer with IBMMQ

 Is the concurrentConsumer option not working for you?

 Best,
 Christian
 Am 04.08.2014 18:02 schrieb Ali, Mohammad mohammad.a...@genpact.com:

  Hi,
 
  I am using camel-2.9.0. JMS producer component with IBMMQ performance
  is very slow, I want to create multiple JMS producer to send message
  to IBM queue something like multi-threading. Is there a way in camel
  where I can create multiple threads of JMS producer, just like
 concurrent consumers.
 
 
  Thanks,
  Shadab
 
  This e-mail (and any attachments), is confidential and may be privileged.
  It may be read, copied and used only
  by intended recipients. Unauthorized access to this e-mail (or
  attachments) and disclosure or copying of its contents or any action
  taken in reliance on it is unlawful. Unintended recipients must notify
  the sender immediately by e-mail/phone  delete it from their system
  without making any copies or disclosing it to a third person.
 
 

 This e-mail (and any attachments), is confidential and may be privileged.
 It may be read, copied and used only
 by intended recipients. Unauthorized access to this e-mail (or
 attachments) and disclosure or copying of its
 contents or any action taken in reliance on it is unlawful. Unintended
 recipients must notify the sender immediately
 by e-mail/phone  delete it from their system without making any copies or
 disclosing it to a third person.

Re: Multiple JMS producer with IBMMQ

[Christian Müller]

Is the concurrentConsumer option not working for you?

Best,
Christian
Am 04.08.2014 18:02 schrieb Ali, Mohammad mohammad.a...@genpact.com:

 Hi,

 I am using camel-2.9.0. JMS producer component with IBMMQ performance is
 very slow, I want to create multiple JMS producer to send message to IBM
 queue something like multi-threading. Is there a way in camel where I can
 create multiple threads of JMS producer, just like concurrent consumers.


 Thanks,
 Shadab

 This e-mail (and any attachments), is confidential and may be privileged.
 It may be read, copied and used only
 by intended recipients. Unauthorized access to this e-mail (or
 attachments) and disclosure or copying of its
 contents or any action taken in reliance on it is unlawful. Unintended
 recipients must notify the sender immediately
 by e-mail/phone  delete it from their system without making any copies or
 disclosing it to a third person.

Re: Camel ActiveMQ performance

[Christian Müller]

Have a look at [1]. This is the code I used last year for ApacheCon 2013...
There are more JMS/SJMS tests in this project. You can find the
presentation at [2].

[1]
https://github.com/muellerc/apachecon-na-2013/blob/master/jms-component/src/test/java/org/apache/cmueller/camel/apachecon/na2013/JmsMessageInOutExchangePatternTest.java
[2] http://www.slideshare.net/muellerc/apache-con-na-2013

Happy Camel ride,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Sun, Aug 3, 2014 at 8:08 AM, balavino balajieng...@gmail.com wrote:

 I'm using a (producer)camel route to post a message to a activeMQ queue
 broker. I would like to check the performance of the number of messages
 that
 can the posted to the queue in a second.

 Let me know the reliable way of doing the same.



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-ActiveMQ-performance-tp5754747.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Load Testing Camel Routes

[Christian Müller]

Hi Matt!

We are using httpcore-ab [1] to load test our web services. Unfortunately,
you cannot change the payload for each test, but it works well for us.

[1]
http://search.maven.org/#artifactdetails|org.apache.httpcomponents|httpcore-ab|4.3.2|jar

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Tue, Jul 29, 2014 at 10:11 PM, Matt Raible m...@raibledesigns.com
wrote:

 Hello all,

 I'm getting ready to put a Camel / CXF / Spring Boot application into
 production. Before I do, I want to load test and verify it has the same
 throughput as a the IBM Message Broker system it's replacing. Apparently,
 the old system can only do 6 concurrent connections because of remote
 database connectivity issues.

 I'd like to write some tests that make simultaneous requests, with
 different data. Ideally, I could write them to point at the old system and
 find out when it falls over. Then I could point them at the new system and
 tune it accordingly. If I need to throttle because of remote connectivity
 issues, I'd like to know before we go to production. Does JMeter or any
 Camel-related testing tools allow for this?

 Thanks,

 Matt

Re: How to retrieve Sqs message attributes

[Christian Müller]

What did you tried?

Best,
Christian
Am 21.07.2014 08:07 schrieb david.yuan david.y...@propellerhead.co.nz:

 Hi all,
 I created a consumer to poll messages via aws sqs. I can retrieve message
 body but can not get message attributes.

 any suggestions?
 Thanks in advance



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/How-to-retrieve-Sqs-message-attributes-tp5754109.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: JDBC based idempotent repository problem

[Christian Müller]

Done. Should be online in a few minutes.

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Tue, Jul 8, 2014 at 3:10 PM, Chris Melikian ch...@melikian.net wrote:

 Is it possible to update the SQL component documentation to reflect the
 different datatype required for SQL Server?



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/JDBC-based-idempotent-repository-problem-tp4980094p5753546.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to call a bean after all files has been processed?

[Christian Müller]

This is the intended behavior.

To achieve the behavior you want, I propose the followings:
- use the file consumers Exchange property CamelBatchComplete [1] to know
which file is the last one
- use an Aggregator [2] with a custom completion Predicate before you are
calling your teaserService

[1] http://camel.apache.org/file2.html
[2] http://camel.apache.org/aggregator2.html

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Thu, Jul 3, 2014 at 5:25 PM, zzkozak mar...@pikula.de wrote:

 I wrote the following route and expected that the bean 'teaserService'
 should
 be called only one time, at the end of processing of all files, but ...
 it's
 called after processing of each file:

 How to achieve such a behavior?

 Thanks



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/How-to-call-a-bean-after-all-files-has-been-processed-tp5753293.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: CamelTestSupport doesn't run @Test method

[Christian Müller]

Can you share the test class with us?

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Thu, Jul 3, 2014 at 2:08 PM, dermoritz tantea...@hotmail.com wrote:

 I wrote a test where a route is setup within @Test. So i overrode
 isUseRoutebulde to return false but now not even the first line of @Test
 method is reached. The log looks lke that:

 [  main] OcsFtpTest INFO

 
 [  main] OcsFtpTest INFO
 Testing: test(com.sas.o2.cep.routes.OcsFtpTest)
 [  main] OcsFtpTest INFO

 
 [  main] OcsFtpTest INFO

 
 [  main] OcsFtpTest INFO
 Testing done: test(com.sas.o2.cep.routes.OcsFtpTest)
 [  main] OcsFtpTest INFO  Took:
 0.060 seconds (60 millis)
 [  main] OcsFtpTest INFO

 
 [  main] DefaultCamelContextINFO
  Apache
 Camel 2.13.1 (CamelContext: camel-1) is shutting down
 [  main] DefaultCamelContextINFO
  Apache
 Camel 2.13.1 (CamelContext: camel-1) uptime not started
 [  main] DefaultCamelContextINFO
  Apache
 Camel 2.13.1 (CamelContext: camel-1) is shutdown in 0.008 seconds

 (what i tried before - also not working)
 Before this i @Inject my route and for some reason configure() was called
 directly - why is that? What did add the route to the context without
 overriding createRouteBuilder()?




 --
 View this message in context:
 http://camel.465427.n5.nabble.com/CamelTestSupport-doesn-t-run-Test-method-tp5753284.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: doTry problem

[Christian Müller]

Can you try 2.13.1?

Best,
Christian
Am 01.07.2014 21:25 schrieb angryzes roman.selez...@gmail.com:

 Hello,

 I am facing a strange problem when I am trying to execute doTry doCatch
 blocks on exception like this:

 onException(Exception.class)
 .doTry()
 .to(ROUTE_ID)
 .doCatch(Exception.class)
 .convertBodyTo(String.class)
 .log(log:org.apache.camel?level=ERROR)
 .end();

  .to(ROUTE_ID) - throws exception, which is fine but then another exception
 is thrown and I am getting in into infinite loop of exceptions with root
 cause like this:

 [Server:ivr] 19:10:46,368 ERROR [org.quartz.core.JobRunShell]
 (DefaultQuartzScheduler-system-status-camel-context_Worker-1) Job
 Camel_system-status-camel-context.systemStatusJob threw an unhandled
 Exception: : java.lang.NoClassDefFoundError:
 org/apache/camel/processor/FinallyProcessor$1
 [Server:ivr]at

 org.apache.camel.processor.FinallyProcessor.process(FinallyProcessor.java:54)
 [camel-core-2.13.0.jar:2.13.0]
 [Server:ivr]at
 org.apache.camel.processor.TryProcessor.process(TryProcessor.java:111)
 [camel-core-2.13.0.jar:2.13.0]
 [Server:ivr]at
 org.apache.camel.processor.TryProcessor.process(TryProcessor.java:82)
 [camel-core-2.13.0.jar:2.13.0]
 [Server:ivr]at

 org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)
 [camel-core-2.13.0.jar:2.13.0]
 [Server:ivr]at

 org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
 [camel-core-2.13.0.jar:2.13.0]
 [Server:ivr]at
 org.apache.camel.processor.Pipeline.process(Pipeline.java:118)
 [camel-core-2.13.0.jar:2.13.0]
 [Server:ivr]at
 org.apache.camel.processor.Pipeline.process(Pipeline.java:80)
 [camel-core-2.13.0.jar:2.13.0]
 [Server:ivr]at

 org.apache.camel.processor.FatalFallbackErrorHandler.process(FatalFallbackErrorHandler.java:42)
 [camel-core-2.13.0.jar:2.13.0]
 [Server:ivr]at

 org.apache.camel.processor.RedeliveryErrorHandler.deliverToFailureProcessor(RedeliveryErrorHandler.java:839)
 [camel-core-2.13.0.jar:2.13.0]

 The env is (mac), jboss 7.2:
 java version 1.6.0_65
 Java(TM) SE Runtime Environment (build 1.6.0_65-b14-462-11M4609)
 Java HotSpot(TM) 64-Bit Server VM (build 20.65-b04-462, mixed mode)

 Any ideas?



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/doTry-problem-tp5753166.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel-hbase : problem with qualifier id

[Christian Müller]

The issue in your route is:
setHeader(CamelHBaseQualifier, simple(id, String.class))

try:
setHeader(CamelHBaseQualifier, constant(id, String.class))

because:
simple(id, String.class) is evaluated to the input message id as
described at [1].

[1] http://camel.apache.org/simple.html

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Wed, Jun 25, 2014 at 11:33 AM, A577127 antoine.mat...@worldline.com
wrote:

 Hello,

 I'm not sure if this is a bug or an undocumented feature so I put this
 here.

 When using camel-hbase's producer, if you want to use an HBase qualifier
 with the value id, it doesn't work.

 For example : I have an HBase table registrations with a family token
 and a qualifier id. To scan it, I use this route :



 However the result doesn't give the database values. I tryed with another
 qualifier and it worked fine.

 I found out that when the producer tries to resolve the input parameters,
 this instruction goes wrong :



 This should get a String with the value id, but instead it gets the value
 of the breadcrumbID header which is ID-L83577-52983-1403687981986-0-1.

 Thanks



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-hbase-problem-with-qualifier-id-tp5752781.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel-hbase : problem with qualifier id

[Christian Müller]

Checkout the unit test, if you want:
https://git-wip-us.apache.org/repos/asf?p=camel.git;a=commit;h=5e97f9238fc292cc6fde3d75d8b98d4b26b7e66d

Best,

Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Fri, Jun 27, 2014 at 12:44 PM, Christian Müller 
christian.muel...@gmail.com wrote:

 The issue in your route is:
 setHeader(CamelHBaseQualifier, simple(id, String.class))

 try:
 setHeader(CamelHBaseQualifier, constant(id, String.class))

 because:
 simple(id, String.class) is evaluated to the input message id as
 described at [1].

 [1] http://camel.apache.org/simple.html

 Best,

 Christian
 -

 Software Integration Specialist

 Apache Member
 V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
 Apache Incubator PMC Member

 https://www.linkedin.com/pub/christian-mueller/11/551/642


 On Wed, Jun 25, 2014 at 11:33 AM, A577127 antoine.mat...@worldline.com
 wrote:

 Hello,

 I'm not sure if this is a bug or an undocumented feature so I put this
 here.

 When using camel-hbase's producer, if you want to use an HBase qualifier
 with the value id, it doesn't work.

 For example : I have an HBase table registrations with a family token
 and a qualifier id. To scan it, I use this route :



 However the result doesn't give the database values. I tryed with another
 qualifier and it worked fine.

 I found out that when the producer tries to resolve the input parameters,
 this instruction goes wrong :



 This should get a String with the value id, but instead it gets the
 value
 of the breadcrumbID header which is ID-L83577-52983-1403687981986-0-1.

 Thanks



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-hbase-problem-with-qualifier-id-tp5752781.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to secure camel proxy project

[Christian Müller]

HTTPS, HTTP BASIC AUTH, WS-SECURITY, ...
You has multiple possibilities.

Best,
Christian
Am 26.06.2014 12:45 schrieb Royamit amitroy...@gmail.com:

 Hi all,

 I am new to camel and right now i am working on proxy creation using Apache
 Camel. Now i want to secure this proxy service of mine. but i can't find
 anything on it. Please help me on this. Looking forward to your solutions.
 Thanks in advance



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/How-to-secure-camel-proxy-project-tp5752845.html
 Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel-hbase : problem with qualifier id

[Christian Müller]

I can confirm this issue. I have raised a JIRA [1] and work on a fix.

[1] https://issues.apache.org/jira/browse/CAMEL-7547

Best,
Christian
-

Software Integration Specialist

Apache Member
V.P. Apache Camel | Apache Camel PMC Member | Apache Camel committer
Apache Incubator PMC Member

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Wed, Jun 25, 2014 at 11:33 AM, A577127 antoine.mat...@worldline.com
wrote:

 Hello,

 I'm not sure if this is a bug or an undocumented feature so I put this
 here.

 When using camel-hbase's producer, if you want to use an HBase qualifier
 with the value id, it doesn't work.

 For example : I have an HBase table registrations with a family token
 and a qualifier id. To scan it, I use this route :



 However the result doesn't give the database values. I tryed with another
 qualifier and it worked fine.

 I found out that when the producer tries to resolve the input parameters,
 this instruction goes wrong :



 This should get a String with the value id, but instead it gets the value
 of the breadcrumbID header which is ID-L83577-52983-1403687981986-0-1.

 Thanks



 --
 View this message in context:
 http://camel.465427.n5.nabble.com/Camel-hbase-problem-with-qualifier-id-tp5752781.html
 Sent from the Camel - Users mailing list archive at Nabble.com.