Re: Clustering with camel-quartz
Hi Ingo
On Thu, Jun 3, 2010 at 10:30 PM, Ingo Düppe wrote:
> Hi Claus,
>
> well I'm not sure if it is right. But I guess if the trigger is marked
> as volatile it will be automatically removed within in the database.
> Normally volatile jobs won't be stored in a db but in a cluster
> environment they will be.
>
> The problem with camel is, that I cannot define an volatile trigger like
> "quartz://trigger?job.volatility=true&cron..." and also define a cluster
> environment within the quartz.properties. This is because CamelJob isn't
> serializable.
>
> As I mentioned I haven't dig into it very deep. I just wanted to be
> sure, that I didn't miss something obviously before I invest time into it.
>
Ah thanks for point this out. I have created a ticket
https://issues.apache.org/activemq/browse/CAMEL-2788
To improve camel-quartz so you can set that volatile option and also
see what we can about the quartz.properties etc.
And to see how we can serialize CamelJob
> Regards
>
> Ingo
>
>
> Am 03.06.10 15:08, schrieb Claus Ibsen:
>> Hi
>>
>> If you have the app crash using kill -3 / -9 and then start it again
>> and expect quartz to recover and it does not.
>> Then I think you should ask at the Quartz user forum about this.
>>
>> And maybe you can create a plain example with pure Quartz to not
>> pollute the example with Camel as the Quartz guys would just say its a
>> Camel problem.
>> Just as I say its most likely a Quartz problem :)
>>
>> And if there is something that must be configured / tweaked in Quartz
>> to have this working then let us know. Maybe there is something we can
>> do easier in camel-quartz for that.
>>
>>
>>
>> On Thu, Jun 3, 2010 at 12:08 PM, Ingo Düppe wrote:
>>
>>> Am 01.06.10 08:37, schrieb Claus Ibsen:
>>>
On Mon, May 31, 2010 at 6:48 PM, Ingo Düppe
wrote:
> I forgot to mention that I currently use version 2.2.0.
>
>
>
Can you create a small sample application that demonstrates this? Then
its much easier to look into it to see what / if we can do in Camel.
> - Ingo
>
>
>
>
>>> Sure, i created a small example that you can find at
>>> http://dl.dropbox.com/u/4043036/quartz-cluster.tar.gz.
>>>
>>> It contains just a small JUnit Test Case (see below). The test runs fine
>>> as long you execute the whole test. As I find out yesterday, quartz
>>> deletes some information within the database on a clean shutdown.
>>> So the next test run will also run fine.
>>> But if you kill the running test - to simulate a server crash - the next
>>> test run will end up with an exception.
>>>
>>> So how do I handle such inconsist data on startup of camel?
>>>
>>> Regards
>>> Ingo
>>>
>>> @RunWith(SpringJUnit4ClassRunner.class)
>>> @ContextConfiguration(
>>> locations = {
>>> "classpath*:context-test.xml"
>>> }
>>> )
>>> public class QuartzClusterTest extends TestCase {
>>>
>>> �...@autowired
>>> private CamelContext camelContext;
>>>
>>> �...@endpointinject(uri = "mock:result")
>>> protected MockEndpoint resultEndpoint;
>>>
>>> �...@test
>>> �...@dirtiescontext
>>> �...@repeat(value=2)
>>> public void testTriggering() throws Exception {
>>> camelContext.addRoutes(new QuartzRouteBuilder());
>>> resultEndpoint.setMinimumExpectedMessageCount(5);
>>> resultEndpoint.setResultWaitTime(5000L);
>>> resultEndpoint.assertIsSatisfied();
>>> }
>>>
>>> public static class QuartzRouteBuilder extends RouteBuilder {
>>>
>>> �...@override
>>> public void configure() throws Exception {
>>>
>>> from("quartz://trigger?stateful=true&cron=0/1+*+*+*+*+?").to("mock:result");
>>> }
>>> }
>>> }
>>>
>>>
>>>
>>>
>>>
>>>
>>
>>
>>
>
>
--
Claus Ibsen
Apache Camel Committer
Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
FTP Component That Consumes On Demand
Hi,
Is there an ftp component that consumes a file on edemand? and not a
polling.
for example i have the file name already and want to fetch this file coming
from an ftp server,
how would i route it?
from("direct:getfile").to("ftp://someurl?file-name=sd?";)
would this fetch a file or would this create a file on that server?
thanks
carlo
Re: Clustering with camel-quartz
Hi Claus,
well I'm not sure if it is right. But I guess if the trigger is marked
as volatile it will be automatically removed within in the database.
Normally volatile jobs won't be stored in a db but in a cluster
environment they will be.
The problem with camel is, that I cannot define an volatile trigger like
"quartz://trigger?job.volatility=true&cron..." and also define a cluster
environment within the quartz.properties. This is because CamelJob isn't
serializable.
As I mentioned I haven't dig into it very deep. I just wanted to be
sure, that I didn't miss something obviously before I invest time into it.
Regards
Ingo
Am 03.06.10 15:08, schrieb Claus Ibsen:
> Hi
>
> If you have the app crash using kill -3 / -9 and then start it again
> and expect quartz to recover and it does not.
> Then I think you should ask at the Quartz user forum about this.
>
> And maybe you can create a plain example with pure Quartz to not
> pollute the example with Camel as the Quartz guys would just say its a
> Camel problem.
> Just as I say its most likely a Quartz problem :)
>
> And if there is something that must be configured / tweaked in Quartz
> to have this working then let us know. Maybe there is something we can
> do easier in camel-quartz for that.
>
>
>
> On Thu, Jun 3, 2010 at 12:08 PM, Ingo Düppe wrote:
>
>> Am 01.06.10 08:37, schrieb Claus Ibsen:
>>
>>> On Mon, May 31, 2010 at 6:48 PM, Ingo Düppe
>>> wrote:
>>>
>>>
I forgot to mention that I currently use version 2.2.0.
>>> Can you create a small sample application that demonstrates this? Then
>>> its much easier to look into it to see what / if we can do in Camel.
>>>
>>>
- Ingo
>> Sure, i created a small example that you can find at
>> http://dl.dropbox.com/u/4043036/quartz-cluster.tar.gz.
>>
>> It contains just a small JUnit Test Case (see below). The test runs fine
>> as long you execute the whole test. As I find out yesterday, quartz
>> deletes some information within the database on a clean shutdown.
>> So the next test run will also run fine.
>> But if you kill the running test - to simulate a server crash - the next
>> test run will end up with an exception.
>>
>> So how do I handle such inconsist data on startup of camel?
>>
>> Regards
>> Ingo
>>
>> @RunWith(SpringJUnit4ClassRunner.class)
>> @ContextConfiguration(
>>locations = {
>>"classpath*:context-test.xml"
>>}
>> )
>> public class QuartzClusterTest extends TestCase {
>>
>>@Autowired
>>private CamelContext camelContext;
>>
>>@EndpointInject(uri = "mock:result")
>>protected MockEndpoint resultEndpoint;
>>
>>@Test
>>@DirtiesContext
>>@Repeat(value=2)
>>public void testTriggering() throws Exception {
>>camelContext.addRoutes(new QuartzRouteBuilder());
>>resultEndpoint.setMinimumExpectedMessageCount(5);
>>resultEndpoint.setResultWaitTime(5000L);
>>resultEndpoint.assertIsSatisfied();
>>}
>>
>>public static class QuartzRouteBuilder extends RouteBuilder {
>>
>>@Override
>>public void configure() throws Exception {
>>
>> from("quartz://trigger?stateful=true&cron=0/1+*+*+*+*+?").to("mock:result");
>>}
>>}
>> }
>>
>>
>>
>>
>>
>>
>
>
>
Re: Direct-route not shared across contexts?
Hi I have created unit tests in both pure Java and with Spring XML and cannot reproduce any such behavior http://svn.apache.org/viewvc?rev=951088&view=rev Direct endpoints with same endpoint uri is not shared between multiple CamelContext. So double check on your end what you may do wrong or what you do differently. On Thu, Jun 3, 2010 at 4:20 PM, ankelee wrote: > > Hi > > > Running on Windows in JVM 1.6. > > I'm just loading it into a Spring container in Java main: > > private static String fileRessource = "isuite-client-context.xml"; > > ClassPathXmlApplicationContext x = new > ClassPathXmlApplicationContext(fileRessource); > > > > > > Claus Ibsen-2 wrote: >> >> Hi >> >> Whats your runtime environment? >> And how do you start your app? >> Do you use OSGi or WAR etc? >> >> >> >> >> On Thu, Jun 3, 2010 at 2:28 PM, ankelee wrote: >>> >>> Perhaps I'm doing it wrong. >>> >>> I load a Spring context xml file that has two imports as such. >>> >>> >>> >>> >>> >>> The two camelcontext.xml files obviously holds a tag each. >>> >>> Each of contexts loads a identical route that they create their own >>> instance >>> of. These are configured differently with properties. Then I get a >>> "direct >>> endpoint cannot have more than 1 active consumer" when I run them at the >>> same time. Maybe I don't really have two camelcontexts or? >>> >>> >>> -- >>> View this message in context: >>> http://old.nabble.com/Direct-route-not-shared-across-contexts--tp28766143p28766770.html >>> Sent from the Camel - Users mailing list archive at Nabble.com. >>> >>> >> >> >> >> -- >> Claus Ibsen >> Apache Camel Committer >> >> Author of Camel in Action: http://www.manning.com/ibsen/ >> Open Source Integration: http://fusesource.com >> Blog: http://davsclaus.blogspot.com/ >> Twitter: http://twitter.com/davsclaus >> >> > > -- > View this message in context: > http://old.nabble.com/Direct-route-not-shared-across-contexts--tp28766143p28768147.html > Sent from the Camel - Users mailing list archive at Nabble.com. > > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
Re: Getting exception when using retryUntil with concurrentConsumers
On Thu, Jun 3, 2010 at 12:24 PM, Srini97 wrote:
>
> If I use it below by removing threads() it is taking the messsages one by
> one even though there are concurrent consumers.
>
What JMS Broker are you using?
Normally using concurrentConsumer=5 on the JMS endpoint will have 5
threads process new messages on the JMS queue at the same time.
So something is odd/wrong on your system.
> from("jms-cif:queue:" +
> _notificationQueue+"?concurrentConsumers="+concurrentConsumersSize).
> process(processor)
> .onException(Exception.class).retryUntil(bean("myRetryBean")).end()
> .recipientList(header("recipientListHeader").tokenize(","))
> .parallelProcessing().executorService(customThreadPoolExecutor)
> .aggregationStrategy(new
> RecipientAggregationStrategy(deliveryEndpoints, _endpointDeliveredBaseUri))
> .to("direct:chunk.completed");
>
>
>
>
>
>
>
> --
> View this message in context:
> http://old.nabble.com/Getting-exception-when-using-retryUntil-with-concurrentConsumers-tp28756173p28765667.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
--
Claus Ibsen
Apache Camel Committer
Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
Re: Using CamelHttpComponent to download file
Thanks William, I tried the GET method but it still gave the same results. regards, willem.jiang wrote: > > Hi, > > Maybe you should try to use GET method instead of the POST method to get > the file. > > Willem > > Nav1771 wrote: >> Hi, >> I am a beginner with Camel. I am trying to download a file for which I >> have >> http path and trying to store the file in the local file system. I am >> using >> Camel 2.3.0. Please see the code below. I am expecting that on running >> this >> route the file should be downloaded and moved to data2/s124 folder on the >> local filesystem. But this is not happening. Please let me know if I am >> doing anything wrong or if there is a better way of achieving this. Btw I >> am >> using camel-jetty component for the http action. >> >> >> >> >> >> POST >> >> http://fileServer/11/trial1.txt"/> >> >> > > > -- View this message in context: http://old.nabble.com/Using-CamelHttpComponent-to-download-file-tp28765063p28770292.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Using CamelHttpComponent to download file
Thanks Claus for the reply. I will set the tracer and see. Yes the http path returns valid data. Claus Ibsen-2 wrote: > > Hi > > Use the tracer to see what is going on > http://camel.apache.org/tracer > > And does that remote HTTP server return valid data. > > > On Thu, Jun 3, 2010 at 11:14 AM, Nav1771 wrote: >> >> Hi, >> I am a beginner with Camel. I am trying to download a file for which I >> have >> http path and trying to store the file in the local file system. I am >> using >> Camel 2.3.0. Please see the code below. I am expecting that on running >> this >> route the file should be downloaded and moved to data2/s124 folder on the >> local filesystem. But this is not happening. Please let me know if I am >> doing anything wrong or if there is a better way of achieving this. Btw I >> am >> using camel-jetty component for the http action. >> >> >> >> >> >>POST >> >>http://fileServer/11/trial1.txt"/> >> >> >> -- >> View this message in context: >> http://old.nabble.com/Using-CamelHttpComponent-to-download-file-tp28765063p28765063.html >> Sent from the Camel - Users mailing list archive at Nabble.com. >> >> > > > > -- > Claus Ibsen > Apache Camel Committer > > Author of Camel in Action: http://www.manning.com/ibsen/ > Open Source Integration: http://fusesource.com > Blog: http://davsclaus.blogspot.com/ > Twitter: http://twitter.com/davsclaus > > -- View this message in context: http://old.nabble.com/Using-CamelHttpComponent-to-download-file-tp28765063p28770164.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Direct-route not shared across contexts?
Hi Running on Windows in JVM 1.6. I'm just loading it into a Spring container in Java main: private static String fileRessource = "isuite-client-context.xml"; ClassPathXmlApplicationContext x = new ClassPathXmlApplicationContext(fileRessource); Claus Ibsen-2 wrote: > > Hi > > Whats your runtime environment? > And how do you start your app? > Do you use OSGi or WAR etc? > > > > > On Thu, Jun 3, 2010 at 2:28 PM, ankelee wrote: >> >> Perhaps I'm doing it wrong. >> >> I load a Spring context xml file that has two imports as such. >> >> >> >> >> >> The two camelcontext.xml files obviously holds a tag each. >> >> Each of contexts loads a identical route that they create their own >> instance >> of. These are configured differently with properties. Then I get a >> "direct >> endpoint cannot have more than 1 active consumer" when I run them at the >> same time. Maybe I don't really have two camelcontexts or? >> >> >> -- >> View this message in context: >> http://old.nabble.com/Direct-route-not-shared-across-contexts--tp28766143p28766770.html >> Sent from the Camel - Users mailing list archive at Nabble.com. >> >> > > > > -- > Claus Ibsen > Apache Camel Committer > > Author of Camel in Action: http://www.manning.com/ibsen/ > Open Source Integration: http://fusesource.com > Blog: http://davsclaus.blogspot.com/ > Twitter: http://twitter.com/davsclaus > > -- View this message in context: http://old.nabble.com/Direct-route-not-shared-across-contexts--tp28766143p28768147.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to use offline Camel Spring schema? (Camel 2.3)
Sorry, the right url should be http://camel.apache.org/schema/spring/camel-spring-2.3.0.xsd Willem ankelee wrote: It was hard for me :-) Thanks. Claus Ibsen-2 wrote: On Thu, Jun 3, 2010 at 3:27 PM, ankelee wrote: Hi Willem That is not working. Can't even access that url in a browser. Well you can view all the XSD here http://camel.apache.org/schema/spring/ So it was not that hard to figure out there was a tiny typo in the url from willem willem.jiang wrote: The camel-spring-2.3.0.xsd is published into the apache camel web sit. But the camel-spring.xsd is not updated with the latest camel-spring-2.3.0.xsd. You can work around this issue by doing the below change . ankelee wrote: http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns:camel="http://camel.apache.org/schema/spring"; xmlns:jee="http://www.springframework.org/schema/jee"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd *** change the upper line to *** http://camel.apache.org/schema/spring/camel-spring.2.3.0.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.0.xsd "> My XML files look like this at the moment. What to do to use the local 2.3 schemas in the jar? Willem -- View this message in context: http://old.nabble.com/How-to-use-offline-Camel-Spring-schema--%28Camel-2.3%29-tp28767115p28767432.html Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
Re: How to use offline Camel Spring schema? (Camel 2.3)
It was hard for me :-) Thanks. Claus Ibsen-2 wrote: > > On Thu, Jun 3, 2010 at 3:27 PM, ankelee wrote: >> >> Hi Willem >> >> That is not working. Can't even access that url in a browser. >> > > Well you can view all the XSD here > http://camel.apache.org/schema/spring/ > > So it was not that hard to figure out there was a tiny typo in the url > from willem > > >> >> >> willem.jiang wrote: >>> >>> The camel-spring-2.3.0.xsd is published into the apache camel web sit. >>> But the camel-spring.xsd is not updated with the latest >>> camel-spring-2.3.0.xsd. You can work around this issue by doing the >>> below change . >>> >>> ankelee wrote: http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns:camel="http://camel.apache.org/schema/spring"; xmlns:jee="http://www.springframework.org/schema/jee"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd >>> *** change the upper line to *** >>> http://camel.apache.org/schema/spring/camel-spring.2.3.0.xsd >>> http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.0.xsd "> My XML files look like this at the moment. What to do to use the local 2.3 schemas in the jar? >>> >>> Willem >>> >>> >> >> -- >> View this message in context: >> http://old.nabble.com/How-to-use-offline-Camel-Spring-schema--%28Camel-2.3%29-tp28767115p28767432.html >> Sent from the Camel - Users mailing list archive at Nabble.com. >> >> > > > > -- > Claus Ibsen > Apache Camel Committer > > Author of Camel in Action: http://www.manning.com/ibsen/ > Open Source Integration: http://fusesource.com > Blog: http://davsclaus.blogspot.com/ > Twitter: http://twitter.com/davsclaus > > -- View this message in context: http://old.nabble.com/How-to-use-offline-Camel-Spring-schema--%28Camel-2.3%29-tp28767115p28767567.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: How to use offline Camel Spring schema? (Camel 2.3)
On Thu, Jun 3, 2010 at 3:27 PM, ankelee wrote: > > Hi Willem > > That is not working. Can't even access that url in a browser. > Well you can view all the XSD here http://camel.apache.org/schema/spring/ So it was not that hard to figure out there was a tiny typo in the url from willem > > > willem.jiang wrote: >> >> The camel-spring-2.3.0.xsd is published into the apache camel web sit. >> But the camel-spring.xsd is not updated with the latest >> camel-spring-2.3.0.xsd. You can work around this issue by doing the >> below change . >> >> ankelee wrote: >>> http://www.springframework.org/schema/beans"; >>> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; >>> xmlns:camel="http://camel.apache.org/schema/spring"; >>> xmlns:jee="http://www.springframework.org/schema/jee"; >>> xsi:schemaLocation=" http://www.springframework.org/schema/beans >>> >>> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd >>> >>> http://camel.apache.org/schema/spring >>> >>> http://camel.apache.org/schema/spring/camel-spring.xsd >> *** change the upper line to *** >> http://camel.apache.org/schema/spring/camel-spring.2.3.0.xsd >> >>> >>> http://www.springframework.org/schema/jee >>> >>> http://www.springframework.org/schema/jee/spring-jee-2.0.xsd >>> "> >>> >>> >>> My XML files look like this at the moment. What to do to use the local >>> 2.3 >>> schemas in the jar? >> >> Willem >> >> > > -- > View this message in context: > http://old.nabble.com/How-to-use-offline-Camel-Spring-schema--%28Camel-2.3%29-tp28767115p28767432.html > Sent from the Camel - Users mailing list archive at Nabble.com. > > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
Re: How to use offline Camel Spring schema? (Camel 2.3)
Hi Willem That is not working. Can't even access that url in a browser. willem.jiang wrote: > > The camel-spring-2.3.0.xsd is published into the apache camel web sit. > But the camel-spring.xsd is not updated with the latest > camel-spring-2.3.0.xsd. You can work around this issue by doing the > below change . > > ankelee wrote: >> http://www.springframework.org/schema/beans"; >> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; >> xmlns:camel="http://camel.apache.org/schema/spring"; >> xmlns:jee="http://www.springframework.org/schema/jee"; >> xsi:schemaLocation=" http://www.springframework.org/schema/beans >> >> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd >> >> http://camel.apache.org/schema/spring >> >> http://camel.apache.org/schema/spring/camel-spring.xsd > *** change the upper line to *** > http://camel.apache.org/schema/spring/camel-spring.2.3.0.xsd > >> >> http://www.springframework.org/schema/jee >> >> http://www.springframework.org/schema/jee/spring-jee-2.0.xsd >> "> >> >> >> My XML files look like this at the moment. What to do to use the local >> 2.3 >> schemas in the jar? > > Willem > > -- View this message in context: http://old.nabble.com/How-to-use-offline-Camel-Spring-schema--%28Camel-2.3%29-tp28767115p28767432.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Direct-route not shared across contexts?
Hi Whats your runtime environment? And how do you start your app? Do you use OSGi or WAR etc? On Thu, Jun 3, 2010 at 2:28 PM, ankelee wrote: > > Perhaps I'm doing it wrong. > > I load a Spring context xml file that has two imports as such. > > > > > > The two camelcontext.xml files obviously holds a tag each. > > Each of contexts loads a identical route that they create their own instance > of. These are configured differently with properties. Then I get a "direct > endpoint cannot have more than 1 active consumer" when I run them at the > same time. Maybe I don't really have two camelcontexts or? > > > -- > View this message in context: > http://old.nabble.com/Direct-route-not-shared-across-contexts--tp28766143p28766770.html > Sent from the Camel - Users mailing list archive at Nabble.com. > > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
Re: How to use offline Camel Spring schema? (Camel 2.3)
On Thu, Jun 3, 2010 at 3:16 PM, Willem Jiang wrote: > The camel-spring-2.3.0.xsd is published into the apache camel web sit. > But the camel-spring.xsd is not updated with the latest > camel-spring-2.3.0.xsd. You can work around this issue by doing the below > change . > Ah we need Hadrian to upload the XSD so its up to date. > ankelee wrote: >> >> http://www.springframework.org/schema/beans"; >> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; >> xmlns:camel="http://camel.apache.org/schema/spring"; >> xmlns:jee="http://www.springframework.org/schema/jee"; >> xsi:schemaLocation=" http://www.springframework.org/schema/beans >> >> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd >> http://camel.apache.org/schema/spring >> >> http://camel.apache.org/schema/spring/camel-spring.xsd > > *** change the upper line to *** > http://camel.apache.org/schema/spring/camel-spring.2.3.0.xsd > >> >> http://www.springframework.org/schema/jee >> >> http://www.springframework.org/schema/jee/spring-jee-2.0.xsd >> "> >> >> >> My XML files look like this at the moment. What to do to use the local 2.3 >> schemas in the jar? > > Willem > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
Re: How to use offline Camel Spring schema? (Camel 2.3)
The camel-spring-2.3.0.xsd is published into the apache camel web sit. But the camel-spring.xsd is not updated with the latest camel-spring-2.3.0.xsd. You can work around this issue by doing the below change . ankelee wrote: http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns:camel="http://camel.apache.org/schema/spring"; xmlns:jee="http://www.springframework.org/schema/jee"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd *** change the upper line to *** http://camel.apache.org/schema/spring/camel-spring.2.3.0.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.0.xsd "> My XML files look like this at the moment. What to do to use the local 2.3 schemas in the jar? Willem
Re: Clustering with camel-quartz
Hi
If you have the app crash using kill -3 / -9 and then start it again
and expect quartz to recover and it does not.
Then I think you should ask at the Quartz user forum about this.
And maybe you can create a plain example with pure Quartz to not
pollute the example with Camel as the Quartz guys would just say its a
Camel problem.
Just as I say its most likely a Quartz problem :)
And if there is something that must be configured / tweaked in Quartz
to have this working then let us know. Maybe there is something we can
do easier in camel-quartz for that.
On Thu, Jun 3, 2010 at 12:08 PM, Ingo Düppe wrote:
> Am 01.06.10 08:37, schrieb Claus Ibsen:
>> On Mon, May 31, 2010 at 6:48 PM, Ingo Düppe wrote:
>>
>>> I forgot to mention that I currently use version 2.2.0.
>>>
>>>
>> Can you create a small sample application that demonstrates this? Then
>> its much easier to look into it to see what / if we can do in Camel.
>>
>>> - Ingo
>>>
>>>
>>>
> Sure, i created a small example that you can find at
> http://dl.dropbox.com/u/4043036/quartz-cluster.tar.gz.
>
> It contains just a small JUnit Test Case (see below). The test runs fine
> as long you execute the whole test. As I find out yesterday, quartz
> deletes some information within the database on a clean shutdown.
> So the next test run will also run fine.
> But if you kill the running test - to simulate a server crash - the next
> test run will end up with an exception.
>
> So how do I handle such inconsist data on startup of camel?
>
> Regards
> Ingo
>
> @RunWith(SpringJUnit4ClassRunner.class)
> @ContextConfiguration(
> locations = {
> "classpath*:context-test.xml"
> }
> )
> public class QuartzClusterTest extends TestCase {
>
> �...@autowired
> private CamelContext camelContext;
>
> �...@endpointinject(uri = "mock:result")
> protected MockEndpoint resultEndpoint;
>
> �...@test
> �...@dirtiescontext
> �...@repeat(value=2)
> public void testTriggering() throws Exception {
> camelContext.addRoutes(new QuartzRouteBuilder());
> resultEndpoint.setMinimumExpectedMessageCount(5);
> resultEndpoint.setResultWaitTime(5000L);
> resultEndpoint.assertIsSatisfied();
> }
>
> public static class QuartzRouteBuilder extends RouteBuilder {
>
> �...@override
> public void configure() throws Exception {
>
> from("quartz://trigger?stateful=true&cron=0/1+*+*+*+*+?").to("mock:result");
> }
> }
> }
>
>
>
>
>
--
Claus Ibsen
Apache Camel Committer
Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
How does glogin deal with the ClientLogin CAPTCHA request?
The Google ClientLogin manual http://code.google.com/apis/accounts/docs/AuthForInstalledApps.html http://code.google.com/apis/accounts/docs/AuthForInstalledApps.html indicates that a CAPTCHA is sometimes used as a challenge. How does Camel's glogin deal with this? Best wishes, Dan -- View this message in context: http://old.nabble.com/How-does-glogin-deal-with-the-ClientLogin-CAPTCHA-request--tp28767170p28767170.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Using CamelHttpComponent to download file
Hi, Maybe you should try to use GET method instead of the POST method to get the file. Willem Nav1771 wrote: Hi, I am a beginner with Camel. I am trying to download a file for which I have http path and trying to store the file in the local file system. I am using Camel 2.3.0. Please see the code below. I am expecting that on running this route the file should be downloaded and moved to data2/s124 folder on the local filesystem. But this is not happening. Please let me know if I am doing anything wrong or if there is a better way of achieving this. Btw I am using camel-jetty component for the http action. POST http://fileServer/11/trial1.txt"/>
Re: How to use offline Camel Spring schema? (Camel 2.3)
http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns:camel="http://camel.apache.org/schema/spring"; xmlns:jee="http://www.springframework.org/schema/jee"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.0.xsd "> My XML files look like this at the moment. What to do to use the local 2.3 schemas in the jar? -- View this message in context: http://old.nabble.com/How-to-use-offline-Camel-Spring-schema--%28Camel-2.3%29-tp28767115p28767130.html Sent from the Camel - Users mailing list archive at Nabble.com.
How to use offline Camel Spring schema? (Camel 2.3)
Claus answers this question partly in this thread: http://old.nabble.com/Using-local-camel-schema-on-server-with-no-internet-access-td28340101s22882.html#a28340101 But I can't get this to work. I'm trying to use some of the new options in the tag but both the ide and the compiler complains that these options does not exist so I assume it's validating against an old online schema. Could someone help me on this? -- View this message in context: http://old.nabble.com/How-to-use-offline-Camel-Spring-schema--%28Camel-2.3%29-tp28767115p28767115.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Using CamelHttpComponent to download file
Hi Use the tracer to see what is going on http://camel.apache.org/tracer And does that remote HTTP server return valid data. On Thu, Jun 3, 2010 at 11:14 AM, Nav1771 wrote: > > Hi, > I am a beginner with Camel. I am trying to download a file for which I have > http path and trying to store the file in the local file system. I am using > Camel 2.3.0. Please see the code below. I am expecting that on running this > route the file should be downloaded and moved to data2/s124 folder on the > local filesystem. But this is not happening. Please let me know if I am > doing anything wrong or if there is a better way of achieving this. Btw I am > using camel-jetty component for the http action. > > > > > > POST > > http://fileServer/11/trial1.txt"/> > > > -- > View this message in context: > http://old.nabble.com/Using-CamelHttpComponent-to-download-file-tp28765063p28765063.html > Sent from the Camel - Users mailing list archive at Nabble.com. > > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
Re: Using CamelHttpComponent to download file
Hi, Any inputs on this. This maiy be fairly obvious question but I am new to Camel so any input would help . regards. Nav1771 wrote: > > Hi, > I am a beginner with Camel. I am trying to download a file for which I > have http path and trying to store the file in the local file system. I > am using Camel 2.3.0. Please see the code below. I am expecting that on > running this route the file should be downloaded and moved to data2/s124 > folder on the local filesystem. But this is not happening. Please let me > know if I am doing anything wrong or if there is a better way of achieving > this. Btw I am using camel-jetty component for the http action. > > > > > > POST > > http://fileServer/11/trial1.txt"/> > > > -- View this message in context: http://old.nabble.com/Using-CamelHttpComponent-to-download-file-tp28765063p28766873.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Direct-route not shared across contexts?
Perhaps I'm doing it wrong. I load a Spring context xml file that has two imports as such. The two camelcontext.xml files obviously holds a tag each. Each of contexts loads a identical route that they create their own instance of. These are configured differently with properties. Then I get a "direct endpoint cannot have more than 1 active consumer" when I run them at the same time. Maybe I don't really have two camelcontexts or? -- View this message in context: http://old.nabble.com/Direct-route-not-shared-across-contexts--tp28766143p28766770.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: ExchangeTimedOutException: The OUT message was not received within: 20000 millis.
I eventually figured this put.
I had to wiretap the response.
THanks.
Claus Ibsen-2 wrote:
>
> Are you sending request/reply or fire and forget messaging over JMS?
>
> When you get that 20 sec timeout then its because Camel uses InOut and
> expects a reply being send back to JMSReplyTo.
>
> See
> http://camel.apache.org/event-message.html
> http://camel.apache.org/request-reply.html
>
> On Thu, Jun 3, 2010 at 10:28 AM, lekkie wrote:
>>
>> Hi Guys,
>>
>> I have this requirement where the source queue and destination queue are
>> on
>> separate brokers. See the config below:
>>
>> > class="org.apache.activemq.ActiveMQConnectionFactory">
>>
>>
>> > name="brokerURL">${request-queue-url}
>>
>>
>>
>> > value="false"/>
>>
>> > value="false"/>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> > class="org.apache.activemq.ActiveMQConnectionFactory">
>>
>>
>> > name="brokerURL">${response-queue-url}
>>
>>
>>
>> > value="false"/>
>>
>> > value="false"/>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> > class="org.springframework.jms.connection.JmsTransactionManager">
>> > ref="requestJMSConnectionFactory" />
>>
>>
>> > class="org.springframework.jms.connection.JmsTransactionManager">
>> > ref="responseJMSConnectionFactory"
>> />
>>
>>
>>
>> > class="org.apache.camel.component.jms.JmsConfiguration">
>> > ref="requestJMSConnectionFactory"/>
>> > ref="requestJMSTransactionManager"/>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> > class="org.apache.camel.component.jms.JmsConfiguration">
>> > ref="responseJMSConnectionFactory"/>
>> > ref="responseJMSTransactionManager"/>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> > class="org.apache.camel.spring.spi.SpringTransactionPolicy">
>> > ref="requestJMSTransactionManager"/>
>> > value="PROPAGATION_REQUIRED"/>
>>
>>
>> > class="org.apache.camel.spring.spi.SpringTransactionPolicy">
>> > ref="responseJMSTransactionManager"/>
>> > value="PROPAGATION_REQUIRED"/>
>>
>>
>> > class="org.springframework.transaction.support.TransactionTemplate">
>> > ref="requestJMSTransactionManager"/>
>>
>>
>> > class="org.apache.camel.component.jms.JmsComponent">
>>
>>
>>
>> > class="org.apache.camel.component.jms.JmsComponent">
>>
>>
>>
>> http://camel.apache.org/schema/spring";
>> trace="true">
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> Each time the response is dropped into the responseQueue I get this
>> message
>> and it tries to requeue the message into the response queue which makes
>> it
>> enqueue multiple responses.
>>
>> Here is the exception thrown:
>> org.apache.camel.ExchangeTimedOutException: The OUT message was not
>> received
>> within: 2 millis. Exchange[JmsMessage:
>> at
>> org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:265)
>> at
>> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:147)
>> at
>> org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97)
>> at
>> org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95)
>> at
>> org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146)
>> at
>> org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94)
>> at
>> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82)
>> at
>> org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53)
>> at
>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82)
>> at
>> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:161)
>> at
>> org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177)
>> at
>> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143)
Re: Direct-route not shared across contexts?
Yikes - Guillaume, you're right - I misfired on this one. By default, each direct: endpoint should be 'isolated' within it's own camel context. So, if Andreas is experiencing something different, where direct: endpoints from different contexts are being shared 'cross-context' then this would be a bug. /Ade On 03/06/2010 12:32, Guillaume Nodet wrote: I think Andreas is looking for exactly the opposite. I don't think the goal of the direct: component was that endpoints would be shared across camel context (as that's what vm: has been written for). So i'm kinda tempted to consider that a bug. On Thu, Jun 3, 2010 at 13:27, Adrian Trenaman wrote: Fraid not! If you want to cross camel contexts in the same JVM, you could use the Camel VM (http://camel.apache.org/vm.html) component to do this. Or, you can take a look at using the NMR in SMX4 to achieve something similar. Hope that helps, Ade. On 03/06/2010 12:19, ankelee wrote: Hi Is it possible to have direct endpoints that will not be shared across different camelcontexts in the same JVM? So that each camel context has its own instance of a direct route?
Re: Direct-route not shared across contexts?
I think Andreas is looking for exactly the opposite. I don't think the goal of the direct: component was that endpoints would be shared across camel context (as that's what vm: has been written for). So i'm kinda tempted to consider that a bug. On Thu, Jun 3, 2010 at 13:27, Adrian Trenaman wrote: > Fraid not! > > If you want to cross camel contexts in the same JVM, you could use the Camel > VM (http://camel.apache.org/vm.html) component to do this. Or, you can take > a look at using the NMR in SMX4 to achieve something similar. > > Hope that helps, > Ade. > > On 03/06/2010 12:19, ankelee wrote: >> >> Hi >> >> Is it possible to have direct endpoints that will not be shared across >> different camelcontexts in the same JVM? So that each camel context has >> its >> own instance of a direct route? >> > -- Cheers, Guillaume Nodet Blog: http://gnodet.blogspot.com/ Open Source SOA http://fusesource.com
Re: Direct-route not shared across contexts?
Fraid not! If you want to cross camel contexts in the same JVM, you could use the Camel VM (http://camel.apache.org/vm.html) component to do this. Or, you can take a look at using the NMR in SMX4 to achieve something similar. Hope that helps, Ade. On 03/06/2010 12:19, ankelee wrote: Hi Is it possible to have direct endpoints that will not be shared across different camelcontexts in the same JVM? So that each camel context has its own instance of a direct route?
Direct-route not shared across contexts?
Hi Is it possible to have direct endpoints that will not be shared across different camelcontexts in the same JVM? So that each camel context has its own instance of a direct route? -- View this message in context: http://old.nabble.com/Direct-route-not-shared-across-contexts--tp28766143p28766143.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Getting exception when using retryUntil with concurrentConsumers
If I use it below by removing threads() it is taking the messsages one by
one even though there are concurrent consumers.
from("jms-cif:queue:" +
_notificationQueue+"?concurrentConsumers="+concurrentConsumersSize).
process(processor)
.onException(Exception.class).retryUntil(bean("myRetryBean")).end()
.recipientList(header("recipientListHeader").tokenize(","))
.parallelProcessing().executorService(customThreadPoolExecutor)
.aggregationStrategy(new
RecipientAggregationStrategy(deliveryEndpoints, _endpointDeliveredBaseUri))
.to("direct:chunk.completed");
--
View this message in context:
http://old.nabble.com/Getting-exception-when-using-retryUntil-with-concurrentConsumers-tp28756173p28765667.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Clustering with camel-quartz
Am 01.06.10 08:37, schrieb Claus Ibsen:
> On Mon, May 31, 2010 at 6:48 PM, Ingo Düppe wrote:
>
>> I forgot to mention that I currently use version 2.2.0.
>>
>>
> Can you create a small sample application that demonstrates this? Then
> its much easier to look into it to see what / if we can do in Camel.
>
>> - Ingo
>>
>>
>>
Sure, i created a small example that you can find at
http://dl.dropbox.com/u/4043036/quartz-cluster.tar.gz.
It contains just a small JUnit Test Case (see below). The test runs fine
as long you execute the whole test. As I find out yesterday, quartz
deletes some information within the database on a clean shutdown.
So the next test run will also run fine.
But if you kill the running test - to simulate a server crash - the next
test run will end up with an exception.
So how do I handle such inconsist data on startup of camel?
Regards
Ingo
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(
locations = {
"classpath*:context-test.xml"
}
)
public class QuartzClusterTest extends TestCase {
@Autowired
private CamelContext camelContext;
@EndpointInject(uri = "mock:result")
protected MockEndpoint resultEndpoint;
@Test
@DirtiesContext
@Repeat(value=2)
public void testTriggering() throws Exception {
camelContext.addRoutes(new QuartzRouteBuilder());
resultEndpoint.setMinimumExpectedMessageCount(5);
resultEndpoint.setResultWaitTime(5000L);
resultEndpoint.assertIsSatisfied();
}
public static class QuartzRouteBuilder extends RouteBuilder {
@Override
public void configure() throws Exception {
from("quartz://trigger?stateful=true&cron=0/1+*+*+*+*+?").to("mock:result");
}
}
}
Re: java.lang.VerifyError:(class: org/apache/camel/model/ProcessorType, method: loop signature:
Thanks alot.
I have posted a request for the plugin up gradation on Grails forum.
Claus Ibsen-2 wrote:
>
> On Thu, Jun 3, 2010 at 10:44 AM, mevikasg wrote:
>>
>> Hi Claus,
>>
>>
>> As you suggested to check the Camel version (because of ProcessorType
>> error).
>>
>> I did update the Camel plugin in my grails application with ver 0.2
>> (after
>> updating)
>>
>> I found camel plugin's lib contains apache-camel-1.6.0.jar.
>>
>
> Ask at Grails to have them upgrade their plugin to use Camel 2.3
> instead of the old 1.6.0 release.
>
>
>
>> But, could't find apache-camel-2.x.x to resolve the issue.
>>
>>
>> And, my lib directory contains following jars:
>>
>> activemq-all-5.3.1
>> activemq-pool-5.3.1
>> activemq-ra-3.2
>> mysql-connector-java-5.0.7-bin
>> spring-jms-2.5.6
>> camel-route-2.3.0
>>
>>
>> Please guide.
>>
>> Thanks
>>
>>
>> Claus Ibsen-2 wrote:
>>>
>>> Hi
>>>
>>> It smells like having mixed .jars with different Camel versions. Make
>>> 100% sure that all Camel jars are v2.1.0.
>>>
>>>
>>> On Fri, Dec 18, 2009 at 10:20 PM, Gedaliya wrote:
I am trying to upgrade from Camel 2.0-M2 to 2.1.0
In 2.0-M2 the following code works just fine. In 2.1.0 it does not:
[...]
CamelContext c = (CamelContext)applicationContext.getBean("camel");
// Get the endpoints for this camel context
String endPoints[] =
applicationContext.getBeanNamesForType(Endpoint.class);
// Find the time endpoints
for (int i=0; i< endPoints.length; i++)
{
// If the endpoint is a timerendpoint, create a file object for it
// and put it in the array
endPoint = (Endpoint)applicationContext.getBean(endPoints[i]);
[...]
In Camel 2.1.0 it throws an exception:
Caused by: java.lang.VerifyError: Cannot inherit from final class
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClass(ClassLoader.java:621)
at
java.security.SecureClassLoader.defineClass(SecureClassLoader.java:124)
at java.net.URLClassLoader.defineClass(URLClassLoader.java:260)
at java.net.URLClassLoader.access$000(URLClassLoader.java:56)
at java.net.URLClassLoader$1.run(URLClassLoader.java:195)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:188)
at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:252)
at
org.apache.camel.impl.DefaultPackageScanClassResolver.addIfMatching(DefaultPackageScanClassResolver.java:405)
at
org.apache.camel.impl.DefaultPackageScanClassResolver.loadImplementationsInDirectory(DefaultPackageScanClassResolver.java:347)
at
org.apache.camel.impl.DefaultPackageScanClassResolver.find(DefaultPackageScanClassResolver.java:256)
at
org.apache.camel.impl.DefaultPackageScanClassResolver.find(DefaultPackageScanClassResolver.java:180)
at
org.apache.camel.impl.DefaultPackageScanClassResolver.findAnnotated(DefaultPackageScanClassResolver.java:100)
at
org.apache.camel.impl.converter.AnnotationTypeConverterLoader.load(AnnotationTypeConverterLoader.java:63)
at
org.apache.camel.impl.converter.DefaultTypeConverter.checkLoaded(DefaultTypeConverter.java:379)
at
org.apache.camel.impl.converter.DefaultTypeConverter.doConvertTo(DefaultTypeConverter.java:160)
at
org.apache.camel.impl.converter.DefaultTypeConverter.mandatoryConvertTo(DefaultTypeConverter.java:120)
at
org.apache.camel.impl.converter.DefaultTypeConverter.mandatoryConvertTo(DefaultTypeConverter.java:113)
at
org.apache.camel.util.IntrospectionSupport.convert(IntrospectionSupport.java:277)
at
org.apache.camel.util.IntrospectionSupport.setProperty(IntrospectionSupport.java:233)
at
org.apache.camel.util.IntrospectionSupport.setProperties(IntrospectionSupport.java:200)
at
org.apache.camel.util.EndpointHelper.setProperties(EndpointHelper.java:152)
at
org.apache.camel.impl.DefaultComponent.setProperties(DefaultComponent.java:229)
at
org.apache.camel.component.jetty.JettyHttpComponent.createEndpoint(JettyHttpComponent.java:125)
at
org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:78)
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:416)
at
org.apache.camel.spring.CamelEndpointFactoryBean.createEndpoint(CamelEndpointFactoryBean.java:96)
at
org.apache.camel.spring.CamelEndpointFactoryBean.isSingleton(CamelEndpointFactoryBean.java:62)
at
org.
Re: ExchangeTimedOutException: The OUT message was not received within: 20000 millis.
Are you sending request/reply or fire and forget messaging over JMS?
When you get that 20 sec timeout then its because Camel uses InOut and
expects a reply being send back to JMSReplyTo.
See
http://camel.apache.org/event-message.html
http://camel.apache.org/request-reply.html
On Thu, Jun 3, 2010 at 10:28 AM, lekkie wrote:
>
> Hi Guys,
>
> I have this requirement where the source queue and destination queue are on
> separate brokers. See the config below:
>
> class="org.apache.activemq.ActiveMQConnectionFactory">
>
>
> name="brokerURL">${request-queue-url}
>
>
>
>
>
> value="false"/>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> class="org.apache.activemq.ActiveMQConnectionFactory">
>
>
> name="brokerURL">${response-queue-url}
>
>
>
>
>
> value="false"/>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> class="org.springframework.jms.connection.JmsTransactionManager">
> ref="requestJMSConnectionFactory" />
>
>
> class="org.springframework.jms.connection.JmsTransactionManager">
> ref="responseJMSConnectionFactory"
> />
>
>
>
> class="org.apache.camel.component.jms.JmsConfiguration">
> ref="requestJMSConnectionFactory"/>
> ref="requestJMSTransactionManager"/>
>
>
>
>
>
>
>
>
>
> class="org.apache.camel.component.jms.JmsConfiguration">
> ref="responseJMSConnectionFactory"/>
> ref="responseJMSTransactionManager"/>
>
>
>
>
>
>
>
>
>
> class="org.apache.camel.spring.spi.SpringTransactionPolicy">
> ref="requestJMSTransactionManager"/>
> value="PROPAGATION_REQUIRED"/>
>
>
> class="org.apache.camel.spring.spi.SpringTransactionPolicy">
> ref="responseJMSTransactionManager"/>
> value="PROPAGATION_REQUIRED"/>
>
>
> class="org.springframework.transaction.support.TransactionTemplate">
> ref="requestJMSTransactionManager"/>
>
>
>
>
>
>
> class="org.apache.camel.component.jms.JmsComponent">
>
>
>
> http://camel.apache.org/schema/spring";
> trace="true">
>
>
>
>
>
>
>
>
>
>
> Each time the response is dropped into the responseQueue I get this message
> and it tries to requeue the message into the response queue which makes it
> enqueue multiple responses.
>
> Here is the exception thrown:
> org.apache.camel.ExchangeTimedOutException: The OUT message was not received
> within: 2 millis. Exchange[JmsMessage:
> at
> org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:265)
> at
> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:147)
> at
> org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97)
> at
> org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95)
> at
> org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146)
> at
> org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94)
> at
> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82)
> at
> org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53)
> at
> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82)
> at
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:161)
> at
> org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177)
> at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143)
> at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88)
> at
> org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
> at
> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228)
> at org.apache.camel.processor.Pipeline.process(Pipeline.java:74)
> at
> org.apache.came
Using CamelHttpComponent to download file
Hi, I am a beginner with Camel. I am trying to download a file for which I have http path and trying to store the file in the local file system. I am using Camel 2.3.0. Please see the code below. I am expecting that on running this route the file should be downloaded and moved to data2/s124 folder on the local filesystem. But this is not happening. Please let me know if I am doing anything wrong or if there is a better way of achieving this. Btw I am using camel-jetty component for the http action. POST http://fileServer/11/trial1.txt"/> -- View this message in context: http://old.nabble.com/Using-CamelHttpComponent-to-download-file-tp28765063p28765063.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: java.lang.VerifyError:(class: org/apache/camel/model/ProcessorType, method: loop signature:
On Thu, Jun 3, 2010 at 10:44 AM, mevikasg wrote:
>
> Hi Claus,
>
>
> As you suggested to check the Camel version (because of ProcessorType
> error).
>
> I did update the Camel plugin in my grails application with ver 0.2 (after
> updating)
>
> I found camel plugin's lib contains apache-camel-1.6.0.jar.
>
Ask at Grails to have them upgrade their plugin to use Camel 2.3
instead of the old 1.6.0 release.
> But, could't find apache-camel-2.x.x to resolve the issue.
>
>
> And, my lib directory contains following jars:
>
> activemq-all-5.3.1
> activemq-pool-5.3.1
> activemq-ra-3.2
> mysql-connector-java-5.0.7-bin
> spring-jms-2.5.6
> camel-route-2.3.0
>
>
> Please guide.
>
> Thanks
>
>
> Claus Ibsen-2 wrote:
>>
>> Hi
>>
>> It smells like having mixed .jars with different Camel versions. Make
>> 100% sure that all Camel jars are v2.1.0.
>>
>>
>> On Fri, Dec 18, 2009 at 10:20 PM, Gedaliya wrote:
>>>
>>> I am trying to upgrade from Camel 2.0-M2 to 2.1.0
>>>
>>> In 2.0-M2 the following code works just fine. In 2.1.0 it does not:
>>>
>>> [...]
>>>
>>> CamelContext c = (CamelContext)applicationContext.getBean("camel");
>>> // Get the endpoints for this camel context
>>> String endPoints[] =
>>> applicationContext.getBeanNamesForType(Endpoint.class);
>>> // Find the time endpoints
>>> for (int i=0; i< endPoints.length; i++)
>>> {
>>> // If the endpoint is a timerendpoint, create a file object for it
>>> // and put it in the array
>>> endPoint = (Endpoint)applicationContext.getBean(endPoints[i]);
>>>
>>> [...]
>>>
>>> In Camel 2.1.0 it throws an exception:
>>>
>>> Caused by: java.lang.VerifyError: Cannot inherit from final class
>>> at java.lang.ClassLoader.defineClass1(Native Method)
>>> at java.lang.ClassLoader.defineClass(ClassLoader.java:621)
>>> at
>>> java.security.SecureClassLoader.defineClass(SecureClassLoader.java:124)
>>> at java.net.URLClassLoader.defineClass(URLClassLoader.java:260)
>>> at java.net.URLClassLoader.access$000(URLClassLoader.java:56)
>>> at java.net.URLClassLoader$1.run(URLClassLoader.java:195)
>>> at java.security.AccessController.doPrivileged(Native Method)
>>> at java.net.URLClassLoader.findClass(URLClassLoader.java:188)
>>> at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
>>> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
>>> at java.lang.ClassLoader.loadClass(ClassLoader.java:252)
>>> at
>>> org.apache.camel.impl.DefaultPackageScanClassResolver.addIfMatching(DefaultPackageScanClassResolver.java:405)
>>> at
>>> org.apache.camel.impl.DefaultPackageScanClassResolver.loadImplementationsInDirectory(DefaultPackageScanClassResolver.java:347)
>>> at
>>> org.apache.camel.impl.DefaultPackageScanClassResolver.find(DefaultPackageScanClassResolver.java:256)
>>> at
>>> org.apache.camel.impl.DefaultPackageScanClassResolver.find(DefaultPackageScanClassResolver.java:180)
>>> at
>>> org.apache.camel.impl.DefaultPackageScanClassResolver.findAnnotated(DefaultPackageScanClassResolver.java:100)
>>> at
>>> org.apache.camel.impl.converter.AnnotationTypeConverterLoader.load(AnnotationTypeConverterLoader.java:63)
>>> at
>>> org.apache.camel.impl.converter.DefaultTypeConverter.checkLoaded(DefaultTypeConverter.java:379)
>>> at
>>> org.apache.camel.impl.converter.DefaultTypeConverter.doConvertTo(DefaultTypeConverter.java:160)
>>> at
>>> org.apache.camel.impl.converter.DefaultTypeConverter.mandatoryConvertTo(DefaultTypeConverter.java:120)
>>> at
>>> org.apache.camel.impl.converter.DefaultTypeConverter.mandatoryConvertTo(DefaultTypeConverter.java:113)
>>> at
>>> org.apache.camel.util.IntrospectionSupport.convert(IntrospectionSupport.java:277)
>>> at
>>> org.apache.camel.util.IntrospectionSupport.setProperty(IntrospectionSupport.java:233)
>>> at
>>> org.apache.camel.util.IntrospectionSupport.setProperties(IntrospectionSupport.java:200)
>>> at
>>> org.apache.camel.util.EndpointHelper.setProperties(EndpointHelper.java:152)
>>> at
>>> org.apache.camel.impl.DefaultComponent.setProperties(DefaultComponent.java:229)
>>> at
>>> org.apache.camel.component.jetty.JettyHttpComponent.createEndpoint(JettyHttpComponent.java:125)
>>> at
>>> org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:78)
>>> at
>>> org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:416)
>>> at
>>> org.apache.camel.spring.CamelEndpointFactoryBean.createEndpoint(CamelEndpointFactoryBean.java:96)
>>> at
>>> org.apache.camel.spring.CamelEndpointFactoryBean.isSingleton(CamelEndpointFactoryBean.java:62)
>>> at
>>> org.springframework.beans.factory.support.FactoryBeanRegistrySupport.getObjectFromFactoryBean(FactoryBeanRegistrySupport.java:87)
>>> at
>>> org.springframework.beans.factory.support.AbstractBeanFactory.getObjectForBeanInstance(AbstractBeanFa
Re: Using properties file values with Camel Simple expression
Hi
You need Camel 2.3 for that !!!
On Thu, Jun 3, 2010 at 11:06 AM, lekkie wrote:
>
> I am trying to insert a value from a properties file into a simple expression
> but it keeps throwing an exception
>
>
>
>
> ${properties:my-host}
>
>
>
>
> See exception below:
>
> org.apache.camel.RuntimeCamelException:
> org.apache.camel.FailedToCreateRouteException: Failed to create route
> route56 at: >>> Transform[simple{${properties:my-host}}] <<< in route:
> Route[[From[direct://signOut]] -> [Transform[simple{%3CAK_BS... because of
> Illegal syntax: properties:aero-host
> at
> org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1055)
> at
> org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:103)
> at
> org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:593)
> at
> org.springframework.context.event.SimpleApplicationEventMulticaster$1.run(SimpleApplicationEventMulticaster.java:78)
> at
> org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:49)
> at
> org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:76)
> at
> org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:274)
> at
> org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:736)
>
> ... 12 more
> Caused by: org.apache.camel.ExpressionIllegalSyntaxException: Illegal
> syntax: properties:my-host
> at
> org.apache.camel.language.simple.SimpleLanguage.createSimpleExpression(SimpleLanguage.java:155)
> at
> org.apache.camel.language.simple.SimpleLanguageSupport.createComplexConcatExpression(SimpleLanguageSupport.java:267)
> at
> org.apache.camel.language.simple.SimpleLanguageSupport.createExpression(SimpleLanguageSupport.java:69)
> at
> org.apache.camel.model.language.ExpressionDefinition.createExpression(ExpressionDefinition.java:171)
> at
> org.apache.camel.model.language.ExpressionDefinition.createExpression(ExpressionDefinition.java:161)
> at
> org.apache.camel.model.TransformDefinition.createProcessor(TransformDefinition.java:55)
> at
> org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:325)
> at
> org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:137)
> at
> org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:690)
> ... 22 more
>
>
> I went through the doc on http://camel.apache.org/simple.html and I saw
> this:
>
> properties:locations:key String Camel 2.3: Lookup a property
> with the
> given key. The locations option is optional. See more at Using
> PropertyPlaceholder.
>
> I wonder what the proble is.
>
> regards.
> --
> View this message in context:
> http://old.nabble.com/Using-properties-file-values-with-Camel-Simple-expression-tp28764989p28764989.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
--
Claus Ibsen
Apache Camel Committer
Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
Using properties file values with Camel Simple expression
I am trying to insert a value from a properties file into a simple expression
but it keeps throwing an exception
${properties:my-host}
See exception below:
org.apache.camel.RuntimeCamelException:
org.apache.camel.FailedToCreateRouteException: Failed to create route
route56 at: >>> Transform[simple{${properties:my-host}}] <<< in route:
Route[[From[direct://signOut]] -> [Transform[simple{%3CAK_BS... because of
Illegal syntax: properties:aero-host
at
org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1055)
at
org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:103)
at
org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:593)
at
org.springframework.context.event.SimpleApplicationEventMulticaster$1.run(SimpleApplicationEventMulticaster.java:78)
at
org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:49)
at
org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:76)
at
org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:274)
at
org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:736)
... 12 more
Caused by: org.apache.camel.ExpressionIllegalSyntaxException: Illegal
syntax: properties:my-host
at
org.apache.camel.language.simple.SimpleLanguage.createSimpleExpression(SimpleLanguage.java:155)
at
org.apache.camel.language.simple.SimpleLanguageSupport.createComplexConcatExpression(SimpleLanguageSupport.java:267)
at
org.apache.camel.language.simple.SimpleLanguageSupport.createExpression(SimpleLanguageSupport.java:69)
at
org.apache.camel.model.language.ExpressionDefinition.createExpression(ExpressionDefinition.java:171)
at
org.apache.camel.model.language.ExpressionDefinition.createExpression(ExpressionDefinition.java:161)
at
org.apache.camel.model.TransformDefinition.createProcessor(TransformDefinition.java:55)
at
org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:325)
at
org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:137)
at
org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:690)
... 22 more
I went through the doc on http://camel.apache.org/simple.html and I saw
this:
properties:locations:key String Camel 2.3: Lookup a property
with the
given key. The locations option is optional. See more at Using
PropertyPlaceholder.
regards.
--
View this message in context:
http://old.nabble.com/Using-properties-file-values-with-Camel-Simple-expression-tp28764992p28764992.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Using properties file values with Camel Simple expression
I am trying to insert a value from a properties file into a simple expression
but it keeps throwing an exception
${properties:my-host}
See exception below:
org.apache.camel.RuntimeCamelException:
org.apache.camel.FailedToCreateRouteException: Failed to create route
route56 at: >>> Transform[simple{${properties:my-host}}] <<< in route:
Route[[From[direct://signOut]] -> [Transform[simple{%3CAK_BS... because of
Illegal syntax: properties:aero-host
at
org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:1055)
at
org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:103)
at
org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:593)
at
org.springframework.context.event.SimpleApplicationEventMulticaster$1.run(SimpleApplicationEventMulticaster.java:78)
at
org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:49)
at
org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:76)
at
org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:274)
at
org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:736)
... 12 more
Caused by: org.apache.camel.ExpressionIllegalSyntaxException: Illegal
syntax: properties:my-host
at
org.apache.camel.language.simple.SimpleLanguage.createSimpleExpression(SimpleLanguage.java:155)
at
org.apache.camel.language.simple.SimpleLanguageSupport.createComplexConcatExpression(SimpleLanguageSupport.java:267)
at
org.apache.camel.language.simple.SimpleLanguageSupport.createExpression(SimpleLanguageSupport.java:69)
at
org.apache.camel.model.language.ExpressionDefinition.createExpression(ExpressionDefinition.java:171)
at
org.apache.camel.model.language.ExpressionDefinition.createExpression(ExpressionDefinition.java:161)
at
org.apache.camel.model.TransformDefinition.createProcessor(TransformDefinition.java:55)
at
org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:325)
at
org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:137)
at
org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:690)
... 22 more
I went through the doc on http://camel.apache.org/simple.html and I saw
this:
properties:locations:key String Camel 2.3: Lookup a property
with the
given key. The locations option is optional. See more at Using
PropertyPlaceholder.
I wonder what the proble is.
regards.
--
View this message in context:
http://old.nabble.com/Using-properties-file-values-with-Camel-Simple-expression-tp28764989p28764989.html
Sent from the Camel - Users mailing list archive at Nabble.com.
Re: java.lang.VerifyError:(class: org/apache/camel/model/ProcessorType, method: loop signature:
Hi Claus,
As you suggested to check the Camel version (because of ProcessorType
error).
I did update the Camel plugin in my grails application with ver 0.2 (after
updating)
I found camel plugin's lib contains apache-camel-1.6.0.jar.
But, could't find apache-camel-2.x.x to resolve the issue.
And, my lib directory contains following jars:
activemq-all-5.3.1
activemq-pool-5.3.1
activemq-ra-3.2
mysql-connector-java-5.0.7-bin
spring-jms-2.5.6
camel-route-2.3.0
Please guide.
Thanks
Claus Ibsen-2 wrote:
>
> Hi
>
> It smells like having mixed .jars with different Camel versions. Make
> 100% sure that all Camel jars are v2.1.0.
>
>
> On Fri, Dec 18, 2009 at 10:20 PM, Gedaliya wrote:
>>
>> I am trying to upgrade from Camel 2.0-M2 to 2.1.0
>>
>> In 2.0-M2 the following code works just fine. In 2.1.0 it does not:
>>
>> [...]
>>
>> CamelContext c = (CamelContext)applicationContext.getBean("camel");
>> // Get the endpoints for this camel context
>> String endPoints[] =
>> applicationContext.getBeanNamesForType(Endpoint.class);
>> // Find the time endpoints
>> for (int i=0; i< endPoints.length; i++)
>> {
>> // If the endpoint is a timerendpoint, create a file object for it
>> // and put it in the array
>> endPoint = (Endpoint)applicationContext.getBean(endPoints[i]);
>>
>> [...]
>>
>> In Camel 2.1.0 it throws an exception:
>>
>> Caused by: java.lang.VerifyError: Cannot inherit from final class
>> at java.lang.ClassLoader.defineClass1(Native Method)
>> at java.lang.ClassLoader.defineClass(ClassLoader.java:621)
>> at
>> java.security.SecureClassLoader.defineClass(SecureClassLoader.java:124)
>> at java.net.URLClassLoader.defineClass(URLClassLoader.java:260)
>> at java.net.URLClassLoader.access$000(URLClassLoader.java:56)
>> at java.net.URLClassLoader$1.run(URLClassLoader.java:195)
>> at java.security.AccessController.doPrivileged(Native Method)
>> at java.net.URLClassLoader.findClass(URLClassLoader.java:188)
>> at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
>> at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
>> at java.lang.ClassLoader.loadClass(ClassLoader.java:252)
>> at
>> org.apache.camel.impl.DefaultPackageScanClassResolver.addIfMatching(DefaultPackageScanClassResolver.java:405)
>> at
>> org.apache.camel.impl.DefaultPackageScanClassResolver.loadImplementationsInDirectory(DefaultPackageScanClassResolver.java:347)
>> at
>> org.apache.camel.impl.DefaultPackageScanClassResolver.find(DefaultPackageScanClassResolver.java:256)
>> at
>> org.apache.camel.impl.DefaultPackageScanClassResolver.find(DefaultPackageScanClassResolver.java:180)
>> at
>> org.apache.camel.impl.DefaultPackageScanClassResolver.findAnnotated(DefaultPackageScanClassResolver.java:100)
>> at
>> org.apache.camel.impl.converter.AnnotationTypeConverterLoader.load(AnnotationTypeConverterLoader.java:63)
>> at
>> org.apache.camel.impl.converter.DefaultTypeConverter.checkLoaded(DefaultTypeConverter.java:379)
>> at
>> org.apache.camel.impl.converter.DefaultTypeConverter.doConvertTo(DefaultTypeConverter.java:160)
>> at
>> org.apache.camel.impl.converter.DefaultTypeConverter.mandatoryConvertTo(DefaultTypeConverter.java:120)
>> at
>> org.apache.camel.impl.converter.DefaultTypeConverter.mandatoryConvertTo(DefaultTypeConverter.java:113)
>> at
>> org.apache.camel.util.IntrospectionSupport.convert(IntrospectionSupport.java:277)
>> at
>> org.apache.camel.util.IntrospectionSupport.setProperty(IntrospectionSupport.java:233)
>> at
>> org.apache.camel.util.IntrospectionSupport.setProperties(IntrospectionSupport.java:200)
>> at
>> org.apache.camel.util.EndpointHelper.setProperties(EndpointHelper.java:152)
>> at
>> org.apache.camel.impl.DefaultComponent.setProperties(DefaultComponent.java:229)
>> at
>> org.apache.camel.component.jetty.JettyHttpComponent.createEndpoint(JettyHttpComponent.java:125)
>> at
>> org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:78)
>> at
>> org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:416)
>> at
>> org.apache.camel.spring.CamelEndpointFactoryBean.createEndpoint(CamelEndpointFactoryBean.java:96)
>> at
>> org.apache.camel.spring.CamelEndpointFactoryBean.isSingleton(CamelEndpointFactoryBean.java:62)
>> at
>> org.springframework.beans.factory.support.FactoryBeanRegistrySupport.getObjectFromFactoryBean(FactoryBeanRegistrySupport.java:87)
>> at
>> org.springframework.beans.factory.support.AbstractBeanFactory.getObjectForBeanInstance(AbstractBeanFactory.java:1288)
>> at
>> org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:217)
>> at
>> org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:185)
>> at
>> org.springframe
ExchangeTimedOutException: The OUT message was not received within: 20000 millis.
Hi Guys,
I have this requirement where the source queue and destination queue are on
separate brokers. See the config below:
${request-queue-url}
${response-queue-url}
http://camel.apache.org/schema/spring";
trace="true">
Each time the response is dropped into the responseQueue I get this message
and it tries to requeue the message into the response queue which makes it
enqueue multiple responses.
Here is the exception thrown:
org.apache.camel.ExchangeTimedOutException: The OUT message was not received
within: 2 millis. Exchange[JmsMessage:
at
org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:265)
at
org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:147)
at
org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97)
at
org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95)
at
org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146)
at
org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94)
at
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82)
at
org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53)
at
org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82)
at
org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:161)
at
org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177)
at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143)
at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88)
at
org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
at
org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:74)
at
org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177)
at
org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143)
at
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88)
at
org.apache.camel.spring.spi.TransactionErrorHandler.access$001(TransactionErrorHandler.java:39)
Kind help out.
--
View this message in context:
http://old.nabble.com/ExchangeTimedOutException%3A-The-OUT-message-was-not-received-within%3A-2-millis.-tp28764712p28764712.html
Sent from the Camel - Users mailing list archive at Nabble.com.
