RE: upgrading to Scala 2.11

2015-04-06 Thread shreyas
Scala 2.11 does not have native XML support, you need to add the dependency: 
https://github.com/scala/scala-xml

For SBT: libraryDependencies += "org.scala-lang.modules" %% "scala-xml" % 
"1.0.3"



Thanks,
Shreyas



> Date: Tue, 7 Apr 2015 11:12:25 +0430
> Subject: upgrading to Scala 2.11
> From: behr...@gmail.com
> To: users@camel.apache.org
>
> When I upgraded to Scala 2.11 (my Camel is 2.14.0) I'm getting this error:
>
> AnnotationTypeConverterLoader - Ignoring converter type:
> org.apache.camel.scala.converter.ScalaTypeConverter as a dependent class
> could not be found: java.lang.NoClassDefFoundError: scala/xml/Elem
> java.lang.NoClassDefFoundError: scala/xml/Elem
>
>
>
> --
> --Behrad
  

upgrading to Scala 2.11

2015-04-06 Thread Behrad
When I upgraded to Scala 2.11 (my Camel is 2.14.0) I'm getting this error:

AnnotationTypeConverterLoader - Ignoring converter type:
org.apache.camel.scala.converter.ScalaTypeConverter as a dependent class
could not be found: java.lang.NoClassDefFoundError: scala/xml/Elem
java.lang.NoClassDefFoundError: scala/xml/Elem



-- 
--Behrad


Re: Custom Load Balancing based on Inflight Exchange

2015-04-06 Thread Claus Ibsen
Hi

Yeah maybe we have a few different strategies already. But one based
on "pick first the ones who are doing no or the least amount of work"
sounds like a useable use-case.

So yeah you are welcome to get back when you have something working
and contribute. We love that
http://camel.apache.org/contributing.html

On Mon, Apr 6, 2015 at 1:52 PM, franktva  wrote:
> Thanks for the quick response.  That's the exact approach I'm taking.  Do you
> think this feature would be useful for a future release?
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Custom-Load-Balancing-based-on-Inflight-Exchange-tp5765328p5765358.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/


Re: SFTP: RequiredAuthentications2

2015-04-06 Thread Claus Ibsen
Hi

Thanks for sharing this information with the community. Great to hear
its supported and works.

On Tue, Apr 7, 2015 at 7:06 AM, shreyas  wrote:
> For anyone wondering in future, camel sftp works with 
> RequiredAuthentications2 or multiple auth types (both key & password). I 
> tested it on OSX.
>
> Thanks,
> Shreyas
>
>
> 
>> From: claus.ib...@gmail.com
>> Date: Fri, 27 Mar 2015 16:34:39 +0100
>> Subject: Re: SFTP: RequiredAuthentications2
>> To: users@camel.apache.org
>>
>> Hi
>>
>> Camel uses jcraft for sftp. You may want to check what it supports.
>> http://www.jcraft.com/jsch/
>>
>>
>>
>> On Thu, Mar 26, 2015 at 8:02 PM, shreyas  wrote:
>>> Does camel support SFTP with RequiredAuthentications2 as provided in this 
>>> link for auth: 
>>> http://security.stackexchange.com/questions/17931/possible-to-use-both-private-key-and-password-authentication-for-ssh-login?
>>>
>>> Thanks
>>> Shreyas
>>
>>
>>
>> --
>> 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/
>



-- 
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: Custom Load Balancing based on Inflight Exchange

2015-04-06 Thread franktva
Thanks for the quick response.  That's the exact approach I'm taking.  Do you
think this feature would be useful for a future release?



--
View this message in context: 
http://camel.465427.n5.nabble.com/Custom-Load-Balancing-based-on-Inflight-Exchange-tp5765328p5765358.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Spring Boot component is missing CamelSpringBootApplicationController

2015-04-06 Thread Claus Ibsen
Hi

Yeah wonder if we can backport this to 2.15.2.

Henryk any thoughts on this?

On Tue, Apr 7, 2015 at 1:51 AM, ccampo  wrote:
> Just a follow up - it appears that CamelSpringBootApplicationController won't
> be available until 2.16.0, per
> https://issues.apache.org/jira/browse/CAMEL-8532. Unfortunately, this
> renders the Camel Spring Boot component effectively broken until then.
>
> A work-around for anybody encountering this issue is just to write the code
> yourself. Create a the class CamelSpringBootApplicationController.java
> somewhere in your codebase using the code
> https://github.com/apache/camel/blob/master/components/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/CamelSpringBootApplicationController.java
> (and of course, follow the license and give credit where it's due). Then in
> your main method, just use the code:
>
> final ApplicationContext applicationContext = new
> SpringApplication(MainClass.class).run(args);
> final CamelSpringBootApplicationController applicationController =
>
> applicationContext.getBean(CamelSpringBootApplicationController.class);
> applicationController.blockMainThread();
>
> ... similar to what's shown in
> https://github.com/apache/camel/blob/master/components/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/FatJarRouter.java
> (again, follow the license).
>
> Finally declare a bean of type CamelSpringBootApplicationController, like
> so:
>
> @Bean
> public CamelSpringBootApplicationController applicationController(final
> ApplicationContext applicationContext,
> final CamelContext camelContext) {
> return new CamelSpringBootApplicationController(applicationContext,
> camelContext);
> }
>
> Everything should be OK then.
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Spring-Boot-component-is-missing-CamelSpringBootApplicationController-tp5765405p5765406.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/


Re: BeanIODataFormat giving exception in OSGI compliant Karaf Server Camel

2015-04-06 Thread Claus Ibsen
What versions of the software are you using? And are you using spring
or blueprint?

On Mon, Apr 6, 2015 at 11:23 PM, gargankur007  wrote:
> I am using CAmel for one of my projects.The bundles are deployed in OSGI. I
> have a usecase in which I would need to unmarshal a CSV to POJO. I am using
> BeanIODataFormat for that.
>
> Somehow I am bale to unmarshal the same in Camel Main Program but when I put
> the same piece of code in OSGI I get following exception
>
> "stackTrace=java.lang.NullPointerException at
> org.apache.camel.dataformat.beanio.BeanIODataFormat.readModels(BeanIODataFormat.java:142)
> at
> org.apache.camel.dataformat.beanio.BeanIODataFormat.unmarshal(BeanIODataFormat.java:110)
> at
> com.hcentive.wig.wem.route.UnmarshallerRouteBuilder$2.process(UnmarshallerRouteBuilder.java:85)
> at
> org.apache.camel.processor.DelegateSyncProcessor.process(DelegateSyncProcessor.java:63)
> at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)
> at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398)
> at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:118) at
> org.apache.camel.processor.Pipeline.process(Pipeline.java:80) at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
> at
> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105)
> at
> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87)
> at
> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:103)
> at
> org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:562)
> at
> org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:500)
> at
> org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:468)
> at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)
> at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
> at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1101)"
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/BeanIODataFormat-giving-exception-in-OSGI-compliant-Karaf-Server-Camel-tp5765404.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/


Re: Stop split after reading first line

2015-04-06 Thread Claus Ibsen
Hi

I would then not use the splitter, but you can use a java bean /
processor and read the file by line and read the first and then
validate it.

Java has API for a LineNumberReader or something like that so you can
read the file one line at a time.




On Mon, Apr 6, 2015 at 6:09 PM, manojdevendran  wrote:
> How can I stop the split after reading the first line of a file?
>
> Looking for something like "break" in the for loop.
>
> The requirement is to read and validate first line from a large file. Please
> let me know if any suggestions.
>
> Thanks in advance!!
>
>
>
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/Stop-split-after-reading-first-line-tp5765370.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/


Spring Boot component is missing CamelSpringBootApplicationController

2015-04-06 Thread ccampo
Using Camel 2.15.1 - Camel Spring Boot from Maven Central and Spring Boot
1.2.3

The class CamelSpringBootApplicationController is not available in the
camel-spring-boot jar from Maven, despite being referenced in the
documentation HERE: http://camel.apache.org/spring-boot.html

Additionally, I cannot get my program to run without shutting down
immediately. I've created a simple route which copies a file from one
directory to the other, yet when I run the app (./gradlew bootRun or just
running the main method), Spring Boot shuts down immediately after startup.
Here's the code:

import org.apache.camel.builder.RouteBuilder;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class AdapterApplication {

public static void main(final String[] args) {
new SpringApplication(AdapterApplication.class).run(args);
}

@Bean
RouteBuilder Router() {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
from("file:target/input").to("file:target/output");
}
};
}
}

I would appreciate any help with either of these issues.



--
View this message in context: 
http://camel.465427.n5.nabble.com/Spring-Boot-component-is-missing-CamelSpringBootApplicationController-tp5765405.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Stop split after reading first line

2015-04-06 Thread manojdevendran
How can I stop the split after reading the first line of a file? 

Looking for something like "break" in the for loop.

The requirement is to read and validate first line from a large file. Please
let me know if any suggestions. 

Thanks in advance!! 



--
View this message in context: 
http://camel.465427.n5.nabble.com/Stop-split-after-reading-first-line-tp5765370.html
Sent from the Camel - Users mailing list archive at Nabble.com.


BeanIODataFormat giving exception in OSGI compliant Karaf Server Camel

2015-04-06 Thread gargankur007
I am using CAmel for one of my projects.The bundles are deployed in OSGI. I
have a usecase in which I would need to unmarshal a CSV to POJO. I am using
BeanIODataFormat for that.

Somehow I am bale to unmarshal the same in Camel Main Program but when I put
the same piece of code in OSGI I get following exception

"stackTrace=java.lang.NullPointerException at
org.apache.camel.dataformat.beanio.BeanIODataFormat.readModels(BeanIODataFormat.java:142)
at
org.apache.camel.dataformat.beanio.BeanIODataFormat.unmarshal(BeanIODataFormat.java:110)
at
com.hcentive.wig.wem.route.UnmarshallerRouteBuilder$2.process(UnmarshallerRouteBuilder.java:85)
at
org.apache.camel.processor.DelegateSyncProcessor.process(DelegateSyncProcessor.java:63)
at
org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)
at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398)
at
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:118) at
org.apache.camel.processor.Pipeline.process(Pipeline.java:80) at
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105)
at
org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87)
at
org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:103)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:562)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:500)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:468)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)
at
org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
at
org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1101)"



--
View this message in context: 
http://camel.465427.n5.nabble.com/BeanIODataFormat-giving-exception-in-OSGI-compliant-Karaf-Server-Camel-tp5765404.html
Sent from the Camel - Users mailing list archive at Nabble.com.


RE: SFTP: RequiredAuthentications2

2015-04-06 Thread shreyas
For anyone wondering in future, camel sftp works with RequiredAuthentications2 
or multiple auth types (both key & password). I tested it on OSX.

Thanks,
Shreyas



> From: claus.ib...@gmail.com
> Date: Fri, 27 Mar 2015 16:34:39 +0100
> Subject: Re: SFTP: RequiredAuthentications2
> To: users@camel.apache.org
>
> Hi
>
> Camel uses jcraft for sftp. You may want to check what it supports.
> http://www.jcraft.com/jsch/
>
>
>
> On Thu, Mar 26, 2015 at 8:02 PM, shreyas  wrote:
>> Does camel support SFTP with RequiredAuthentications2 as provided in this 
>> link for auth: 
>> http://security.stackexchange.com/questions/17931/possible-to-use-both-private-key-and-password-authentication-for-ssh-login?
>>
>> Thanks
>> Shreyas
>
>
>
> --
> 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: camel-ftp 2.15.1 return ftp error code 421

2015-04-06 Thread Willem Jiang
OK, here is another change CAMEL-8513[1] in Camel 2.15.1 which improves the 
download speed. I guess it may cause the ftp server complain about the server 
load. So the workaround could be set the receiveBufferSize option to 1024 to 
slow down the processing speed. 

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

--  
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 April 6, 2015 at 10:35:40 PM, alexey-s (alex...@mail.ru) wrote:
> Honestly. 2.15.0 On this effect is much less than 2.15.1.
> I used to
> CronScheduledRoutePolicy ftpDocReadRoutePolicy = new
> CronScheduledRoutePolicy();
> ftpDocReadRoutePolicy.setRouteStartTime(routePolicyStartTime);
> ftpDocReadRoutePolicy.setRouteStopTime(routePolicyStopTime);
> ftpDocReadRoutePolicy.setRouteStopGracePeriod(routePolicyStopGracePeriod);  
>  
> I used to have broke the connection when receiving the contents of files
> from ftp server.
> Now the volume of data to be processed has increased by 50 times.
> To combat system start time and stop very large. No problem.
> To test the interval between the start and stop up to 10 minutes.
> The strangest thing that 2.15.1 error occurs frequently.
> For a couple of hours of tests in 2.15.0 fix one mistake.
> 2.15.1 At the same time, for the problem persists for more than 10 times.
>  
>  
> And here's remarks.
>  
>  
>  
>  
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/camel-ftp-2-15-1-return-ftp-error-code-421-tp5765272p5765367.html
>   
> Sent from the Camel - Users mailing list archive at Nabble.com.
>  



Re: Spring Boot component is missing CamelSpringBootApplicationController

2015-04-06 Thread ccampo
Just a follow up - it appears that CamelSpringBootApplicationController won't
be available until 2.16.0, per
https://issues.apache.org/jira/browse/CAMEL-8532. Unfortunately, this
renders the Camel Spring Boot component effectively broken until then.

A work-around for anybody encountering this issue is just to write the code
yourself. Create a the class CamelSpringBootApplicationController.java
somewhere in your codebase using the code
https://github.com/apache/camel/blob/master/components/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/CamelSpringBootApplicationController.java
(and of course, follow the license and give credit where it's due). Then in
your main method, just use the code:

final ApplicationContext applicationContext = new
SpringApplication(MainClass.class).run(args);
final CamelSpringBootApplicationController applicationController =
   
applicationContext.getBean(CamelSpringBootApplicationController.class);
applicationController.blockMainThread();

... similar to what's shown in
https://github.com/apache/camel/blob/master/components/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/FatJarRouter.java
(again, follow the license).

Finally declare a bean of type CamelSpringBootApplicationController, like
so:

@Bean
public CamelSpringBootApplicationController applicationController(final
ApplicationContext applicationContext,
final CamelContext camelContext) {
return new CamelSpringBootApplicationController(applicationContext,
camelContext);
}

Everything should be OK then.



--
View this message in context: 
http://camel.465427.n5.nabble.com/Spring-Boot-component-is-missing-CamelSpringBootApplicationController-tp5765405p5765406.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Issue with 'javax.annotation' when installing 'camel' followed by 'cxf' feature

2015-04-06 Thread James Carman
You need to update jre.properties to make sure you have the right version
coming from the jre.  What jdk?

On Monday, April 6, 2015, Martin Lichtin  wrote:

> In a Karaf 3.0.3 container one cannot install feature 'camel' followed by
> installing 'cxf'.
>
> karaf@root()> feature:repo-add mvn:org.apache.camel.karaf/
> apache-camel/2.15.1/xml/features
> Adding feature url mvn:org.apache.camel.karaf/apache-camel/2.15.1/xml/
> features
>
> karaf@root()> feature:install camel
> karaf@root()> feature:install cxf
> Refreshing bundles org.apache.servicemix.bundles.spring-context (79),
> org.apache.servicemix.bundles.spring-beans (77),
> org.apache.servicemix.bundles.spring-context-support (80),
> org.apache.servicemix.bundles.spring-core (75)
> Error executing command: Can't install feature cxf/0.0.0:
> Could not start bundle mvn:org.apache.cxf/cxf-rt-rs-extension-providers/3.0.4
> in feature(s) cxf-jaxrs-3.0.4: Uses constraint violation. Unable to resolve
> bundle revision org.apache.cxf.cxf-rt-frontend-jaxrs [138.0] because it
> is exposed to package 'javax.annotation' from bundle revisions
> javax.annotation-api [93.0] and org.apache.felix.framework [0] via two
> dependency chains.
>
> Chain 1:
>   org.apache.cxf.cxf-rt-frontend-jaxrs [138.0]
> import: (&(osgi.wiring.package=javax.annotation)(version>=1.2.0)(!(
> version>=2.0.0)))
>  |
> export: osgi.wiring.package=javax.annotation
>   javax.annotation-api [93.0]
>
> Chain 2:
>   org.apache.cxf.cxf-rt-frontend-jaxrs [138.0]
> import: (&(osgi.wiring.package=org.springframework.context.
> annotation)(version>=3.1.0)(!(version>=5.0.0)))
>  |
> export: osgi.wiring.package=org.springframework.context.annotation;
> uses:=javax.annotation
>   org.apache.servicemix.bundles.spring-context [79.0]
> import: (osgi.wiring.package=javax.annotation)
>  |
> export: osgi.wiring.package=javax.annotation
>   org.apache.felix.framework [0]
> karaf@root()>
>
> Anyone else experiencing this issue?
>
> I see that switching the install (i.e. first installing 'cxf') will make
> it work, however, it seems a klduge to prescribe an installation ordering.
>
>


Re: Karaf with Camel 2.15.1, CXF 3.0.4 - which Spring versions can be used?

2015-04-06 Thread lichtin
Hi Willem, just would like to show that what you say is not true.

I can happily first load a Spring 4 version:

   feature:install -v spring/4.1.2.RELEASE_1

and then load Camel:

   feature:repo-add
mvn:org.apache.camel.karaf/apache-camel/2.15.1/xml/features
   feature:install camel

At this point, however, Camel feature will install the latest Spring 3
version.
And you can verify yourself with

   bundle:requirements camel-spring

to see that it resolved the 'spring' packages with 3.2.11.RELEASE and not
version 4.

For example:

osgi.wiring.package;
(&(osgi.wiring.package=org.springframework.beans)(version>=3.2.0)(!(version>=5.0.0)))
resolved by:
   osgi.wiring.package; org.springframework.beans 3.2.11.RELEASE from
org.apache.servicemix.bundles.spring-beans [83]

I do believe the Camel features file needs to be modified to support Spring
4.

- Martin


Willem.Jiang wrote
> As we doesn’t specify the spring version inside of camel feature, you need
> to choice the spring version yourself inside of Karaf. If you load the
> spring feature 4.0, it should work out of box.
> 
> --  
> 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 April 3, 2015 at 11:26:55 PM, Martin Lichtin (

> lichtin@.com

> ) wrote:
>> Using Camel 2.15.1 and CXF 3.0.4 in a Karaf container, I'm wondering how
>> one can control the Spring version.
>> Camel feature "camel-spring" loads Spring with
>>  
>> spring
>>  
>> which will result in loading 3.2.11.RELEASE.
>>  
>> Is there a way to use Spring 4?
>>  
>> - Martin
>>  
>>  
>>





--
View this message in context: 
http://camel.465427.n5.nabble.com/Karaf-with-Camel-2-15-1-CXF-3-0-4-which-Spring-versions-can-be-used-tp5765283p5765377.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Issue with 'javax.annotation' when installing 'camel' followed by 'cxf' feature

2015-04-06 Thread Martin Lichtin
In a Karaf 3.0.3 container one cannot install feature 'camel' followed 
by installing 'cxf'.


karaf@root()> feature:repo-add 
mvn:org.apache.camel.karaf/apache-camel/2.15.1/xml/features
Adding feature url 
mvn:org.apache.camel.karaf/apache-camel/2.15.1/xml/features


karaf@root()> feature:install camel
karaf@root()> feature:install cxf
Refreshing bundles org.apache.servicemix.bundles.spring-context (79), 
org.apache.servicemix.bundles.spring-beans (77), 
org.apache.servicemix.bundles.spring-context-support (80), 
org.apache.servicemix.bundles.spring-core (75)

Error executing command: Can't install feature cxf/0.0.0:
Could not start bundle 
mvn:org.apache.cxf/cxf-rt-rs-extension-providers/3.0.4 in feature(s) 
cxf-jaxrs-3.0.4: Uses constraint violation. Unable to resolve bundle 
revision org.apache.cxf.cxf-rt-frontend-jaxrs [138.0] because it is 
exposed to package 'javax.annotation' from bundle revisions 
javax.annotation-api [93.0] and org.apache.felix.framework [0] via two 
dependency chains.


Chain 1:
  org.apache.cxf.cxf-rt-frontend-jaxrs [138.0]
import: 
(&(osgi.wiring.package=javax.annotation)(version>=1.2.0)(!(version>=2.0.0)))

 |
export: osgi.wiring.package=javax.annotation
  javax.annotation-api [93.0]

Chain 2:
  org.apache.cxf.cxf-rt-frontend-jaxrs [138.0]
import: 
(&(osgi.wiring.package=org.springframework.context.annotation)(version>=3.1.0)(!(version>=5.0.0)))

 |
export: osgi.wiring.package=org.springframework.context.annotation; 
uses:=javax.annotation

  org.apache.servicemix.bundles.spring-context [79.0]
import: (osgi.wiring.package=javax.annotation)
 |
export: osgi.wiring.package=javax.annotation
  org.apache.felix.framework [0]
karaf@root()>

Anyone else experiencing this issue?

I see that switching the install (i.e. first installing 'cxf') will make 
it work, however, it seems a klduge to prescribe an installation ordering.




Re: Karaf with Camel 2.15.1, CXF 3.0.4 - which Spring versions can be used?

2015-04-06 Thread alexey-s
File etc/org.apache.karaf.features.cfg


Note line





--
View this message in context: 
http://camel.465427.n5.nabble.com/Karaf-with-Camel-2-15-1-CXF-3-0-4-which-Spring-versions-can-be-used-tp5765283p5765369.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: camel-ftp 2.15.1 return ftp error code 421

2015-04-06 Thread alexey-s
A short excerpt from karaf.log.xxx file






--
View this message in context: 
http://camel.465427.n5.nabble.com/camel-ftp-2-15-1-return-ftp-error-code-421-tp5765272p5765368.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: camel-ftp 2.15.1 return ftp error code 421

2015-04-06 Thread alexey-s
Honestly. 2.15.0 On this effect is much less than 2.15.1.
I used to
  CronScheduledRoutePolicy ftpDocReadRoutePolicy = new
CronScheduledRoutePolicy();
  ftpDocReadRoutePolicy.setRouteStartTime(routePolicyStartTime);
  ftpDocReadRoutePolicy.setRouteStopTime(routePolicyStopTime);
  ftpDocReadRoutePolicy.setRouteStopGracePeriod(routePolicyStopGracePeriod);

I used to have broke the connection when receiving the contents of files
from ftp server.
Now the volume of data to be processed has increased by 50 times.
To combat system start time and stop very large. No problem.
To test the interval between the start and stop up to 10 minutes.
The strangest thing that 2.15.1 error occurs frequently.
For a couple of hours of tests in 2.15.0 fix one mistake.
2.15.1 At the same time, for the problem persists for more than 10 times.


And here's remarks.




--
View this message in context: 
http://camel.465427.n5.nabble.com/camel-ftp-2-15-1-return-ftp-error-code-421-tp5765272p5765367.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Multiple outputs from a custom component

2015-04-06 Thread Christopher Piggott
I have been reading mailing lists and forums trying to figure this out but
haven't really come up with a clean solution.

I have a zigbee ZCL component I wrote for Camel that parses out a few
ZCL/ZDO messages.  One of them is an attributes report, which contains a
list of attributes, each with:

- A numeric ID indicating which parameter
- A one-byte type ID which tells you if the value is a float, int, string,
whatever
- A value, which could be of various types

To use these components I do something like this:

from("seda:xbeeInput")
.to("xbee://localhost")
.to("zcl://localhost")
.to("zclSplitter://localhost")
.to(xmppUri);


The first four steps work great - the xbeeInput comes from the serial
port, sends the message to xbee decoding, and if that is successful it
parses it into a ZCL message containing some number of attributes.
The splitter is where I'm really having the problems.  I'd really like
it to be just another Endpoint/Component/something in the library so
that the user doesn't have to screw around configuring custom
splitters or beans.


I have tried a number of things to solve this, but I'm getting so far
deep in the weeds that I feel like I'm on the wrong track.


Does anybody have an example they can show me of a custom Producer (or
something more appropriate?) that can act like a cusom splitter,
replacing whatever Exchange comes in with a series of smaller
Exchanges?  I'm looking for something like:

public class ZclSplitter exends DefaultProducer {

public List process( Exchange originalExchange ) {



}

}


How is one supposed to accomplish this with a component?


--Chris


Re: Karaf with Camel 2.15.1, CXF 3.0.4 - which Spring versions can be used?

2015-04-06 Thread lichtin
But don't you restrict the Spring version and exclude version 4 with the
version range?

I'm looking at
https://repository.apache.org/content/repositories/releases/org/apache/camel/karaf/apache-camel/2.15.1/apache-camel-2.15.1-features.xml
and see

spring 

The way I read this, version 4 is not accepted.


Willem.Jiang wrote
> As we doesn’t specify the spring version inside of camel feature, you need
> to choice the spring version yourself inside of Karaf. If you load the
> spring feature 4.0, it should work out of box.
> 
> --  
> 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 April 3, 2015 at 11:26:55 PM, Martin Lichtin (

> lichtin@.com

> ) wrote:
>> Using Camel 2.15.1 and CXF 3.0.4 in a Karaf container, I'm wondering how
>> one can control the Spring version.
>> Camel feature "camel-spring" loads Spring with
>>  
>> spring
>>  
>> which will result in loading 3.2.11.RELEASE.
>>  
>> Is there a way to use Spring 4?
>>  
>> - Martin
>>  
>>  
>>





--
View this message in context: 
http://camel.465427.n5.nabble.com/Karaf-with-Camel-2-15-1-CXF-3-0-4-which-Spring-versions-can-be-used-tp5765283p5765357.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Request reply route is returning the request

2015-04-06 Thread begorrah
Works like a charm - you sir are a rock star!  :-)

Many thanks,
/BG



--
View this message in context: 
http://camel.465427.n5.nabble.com/Request-reply-route-is-returning-the-request-tp5765345p5765354.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: Conditional skipping when intercepting message

2015-04-06 Thread Andrei Stoica
Claus Ibsen-2 wrote
> interceptSendToEndpoint("mock:skippable").skipSendToOriginalEndpoint()
> .when(body().isEqualTo("skip")).to("mock:detour");

When does the to() occur? Is it like: all routes are skipped and the ones
that have the body equals to "skip" are sent on the to queue? 

The idea is that I want to set a property on the exchange *before* deciding
if I want to skip it or not.

I found a replacement solution like this:

interceptSendToEndpoint("jms:variableQueue")
.process(new Processor() {

@Override
public void process(Exchange exchange) throws Exception 
{

// set the skip property to true or
false based on the current exchange
exchange.setProperty("skip", 
false/true);

}
})
.choice()
.when(exchangeProperty("skip").isEqualTo(true)).stop();

But I'm not using the skipSendToOriginalEndpoint, which is best practice for
what I saw. 



--
View this message in context: 
http://camel.465427.n5.nabble.com/Conditional-skipping-when-intercepting-message-tp5765255p5765352.html
Sent from the Camel - Users mailing list archive at Nabble.com.


Re: camel-ftp 2.15.1 return ftp error code 421

2015-04-06 Thread Willem Jiang
There are only few changes between Camel 2.15.1 and Camel 2.15.0.
I’m not sure if CAMEL-7565[1] is related to issue that you faced.

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

--  
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 April 3, 2015 at 9:21:02 PM, alexey-s (alex...@mail.ru) wrote:
> Imagine that your FTP directory shows the "C:\Program Files" on Windows or
> "/usr/lib" on Linux. There is a very large number of files. Files can not be
> deleted.
> Process periodically scans all files in all folders, filters, and sorts.
> Uses a database table to store the names of files previously treated
> (IdempotentReposiotry).
>  
> It is understood that when preprocessing is large.
> Here then is manifested error with ftp server. He believes that his
> overloaded work and an error 421.
>  
>  
>  
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/camel-ftp-2-15-1-return-ftp-error-code-421-tp5765272p5765276.html
>   
> Sent from the Camel - Users mailing list archive at Nabble.com.
>