Routing messages to ActiveMQ queue

Hi all! I'm trying to route some messages to an ActiveMQ server. Basically I'd need to rewrite the tomcat-active-example to use Camel Java API and run in on another application server. So I have started ActiveMQ on my machine and defined a queue named "activemq/queue/TestQueue". Next I have coded a

Re: Routing messages to ActiveMQ queue

HI Frank, Try with this : from("timer:foo?period=1s").setBody(body().append("Message at ${date:now:-MM-dd HH:mm:ss}")).to("|activemq:|activemq/queue/TestQueue "); activemq: http://camel.apache.org/activemq.html On 3/02/2015 9:30, frank1970 wrote: Hi all! I'm trying to route some message

Re: Routing messages to ActiveMQ queue

Thanks for your reply. Actually I've just found out the issue: I was missing some libs in the classpath and without including SLF4J (both libraries) these exceptions were hidden. Now it's working :-) -- View this message in context: http://camel.465427.n5.nabble.com/Routing-messages-to-ActiveMQ

Camel repeat route

Hello guys, I would like to kindly ask you if anyone knows how to solve this issue: I have a web app which is synchronized with ldap and is checking ldap every minute if there are new groups. If so, then the app will take the groups from ldap and inserts them into its internal database. Then I

camel-imap

I m planning to write a route which will have to move messages from inbox to four different folders folder1, folder2, folder3, folder4 every 5 minutes. How can i do this? I need to dynamically change folder2 to folder1, folder4 every 5 miutes. -Thanks Sasi

REST InOut with JMS InOnly

I have two routes: 1. A rest dsl accepting data from HTTP clients and sending it to the route below before replying to the client 2. A "backend" route that receives an Exchange and sends it to a JMS queue By default, although the JMS queue gets the message, a stack trace occurs because the queue

Camel Content Based Router

I made a camel route which contains an xml in an activemq queue.I want to route this xml according to a content property.How can i reach and make choice according to a property.I use spring dsl.My xml format like below: http://service.cxf.ws.sep.bedas.com/";>0 6439705 I want to route this xm

Re: Camel Content Based Router

Seems like you need some content based routing using xpath. http://camel.apache.org/content-based-router.html On 3/02/2015 13:00, akotako wrote: I made a camel route which contains an xml in an activemq queue.I want to route this xml according to a content property.How can i reach and make choi

Re: WildflyCamel-2.1.0 released

Congrats! > On 02 Feb 2015, at 17:38, Thomas Diesler wrote: > > Folks, > > I’m happy to announce the release of wildfly-camel-2.1.0 > > > We added twelve new camel components >

Re: REST InOut with JMS InOnly

Hi You can send the message to the JMS as InOnly or use WireTap On Tue, Feb 3, 2015 at 12:27 PM, James Green wrote: > I have two routes: > > 1. A rest dsl accepting data from HTTP clients and sending it to the route > below before replying to the client > 2. A "backend" route that receives an Ex

Re: REST InOut with JMS InOnly

Claus, Is their any way a queue (using activemq) could respond , like a request-reply mechanism? http://camel.apache.org/request-reply.html On 3/02/2015 13:14, Claus Ibsen wrote: Hi You can send the message to the JMS as InOnly or use WireTap On Tue, Feb 3, 2015 at 12:27 PM, James Green w

Using AggregationStrategies.bean, setting in bean header value

Hi, i'm setting up on a route a split like this : split(body(), AggregationStrategies.bean(BusAggregator.class)). In BusAggregator i put a value on booth headers, but i can't find this header on the next step e.g a log : public String process(String prevBody, Map prevHeaders,

Re: Using AggregationStrategies.bean, setting in bean header value

Hi Yes you can change the headers, but the rule of thumb is that if the oldExchange is != null then its the old headers you must change to take affect. (old = is what you can prev). On Tue, Feb 3, 2015 at 1:30 PM, kalber wrote: > Hi, > > i'm setting up on a route a split like this : split(body()

Re: REST InOut with JMS InOnly

Surely its the job of the queue consumer to reply, not ActiveMQ? On 3 February 2015 at 12:27, Morgan Hautman wrote: > Claus, > > Is their any way a queue (using activemq) could respond , like a > request-reply mechanism? > > http://camel.apache.org/request-reply.html > > > On 3/02/2015 13:14, Cl

Re: REST InOut with JMS InOnly

On Tue, Feb 3, 2015 at 1:27 PM, Morgan Hautman wrote: > Claus, > > Is their any way a queue (using activemq) could respond , like a > request-reply mechanism? > > http://camel.apache.org/request-reply.html > Not sure I follow. Camel can do InOnly and InOut over JMS. So yeah both is possible. Jus

Re: REST InOut with JMS InOnly

Yes I understand we can encounter a timeout when we don't respond to http/rest because it's synchronous. But I think what James means is : 1st route: from(cxf:...).to(activemq:bar) 2nd route from(activemq: bar).to(processing) The first route sends a message to the second route through activem

Re: REST InOut with JMS InOnly

Nope :) rest("/from-smtp/") .post() .type(EmailedSmsRequest.class) .to("direct:fromSmtp"); direct:fromSmtp routes onward to direct:router. direct:router sends it onwards to jms:queue:foo asynchronously. The route that reads from("direct:router") is intended for be fully re

Re: camel-imap

Hi, you could use a recipient list to dynamically identify the endpoint. http://camel.apache.org/recipient-list.html Bart Horré Anova r&d bvba On Tue, Feb 3, 2015 at 10:39 AM, Mezai 279 wrote: > I m planning to write a route which will have to move messages from inbox > to four different fold

Re: camel-imap

Thanks Bart Horre! Here i want to change a particular attribute in the copyTo should be changed dynamically each time it is polling the mail server. I believe recipient list will not be helpful here. -Thanks Sasi On Tue, Feb 3, 2015 at 7:10 PM, Bart Horré wrote: > Hi, > > you could use a

Re: camel-imap

If I read the docs of copyTo correctly you should be able to change to add a header with the copyTo value at runtime. *Camel 2.10:* Consumer only. After processing a mail message, it can be copied to a mail folder with the given name. You can override this configuration value, with a header with t

Re: CamelDestinationOverrideUrl documentation

Hi Willem, Sorry to revive this old thread but it looks like this is supported in Camel CXF in addition to camel-cxfrs component. Would it be worthwhile to update the Camel CXF wiki page with this info? Thanks, Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/CamelDes

Re: camel-imap

Thanks a ton!! this worked for me... I have done some thing like below: My processor in the route *folderNameProcesor,*has a static variable and every time processor is cal

ActiveMQ - java.io.IOException: Transport scheme NOT recognized: [tcp]

Hello, I am facing a strange error when I use ActiveMQ in my routes where ActiveNQ is configured as a RA. I am having a real hard time having ActiveMQ connection factory working as part of the XA Transaction. I have configured ActiveMQ as a Wildfly xa resource and I can see that it is configured o

Unable to send message in camel-quickfix component, cannot find session

BeginString=FIX.4.4 SenderCompID=EXCHANGE [SESSION] TargetCompID=CLIENT All other connection parameters are default. The return message is like so: 8=FIX.4.4|9=252|35=W|34=32|49=EXCHANGE|52=20150203-20:49:19.443|56=CLIENT|57=trader|262=MDRQ0003|55=EURO OPTION (LN) J15 4.75

Re: Endpoint uri: Questionmark as part of password

Hey, only 2.5 years later! Check out RAW. See: http://cosmo-opticon.net/blog/2014/12/23/escaping-endpoint-uris-in-camel ~cg -- View this message in context: http://camel.465427.n5.nabble.com/Endpoint-uri-Questionmark-as-part-of-password-tp5718378p5762369.html Sent from the Camel - Users mail

Re: REST InOut with JMS InOnly

On Tue, Feb 3, 2015 at 2:30 PM, James Green wrote: > Nope :) > > rest("/from-smtp/") > .post() > .type(EmailedSmsRequest.class) > .to("direct:fromSmtp"); > > direct:fromSmtp routes onward to direct:router. direct:router sends it > onwards to jms:queue:foo asynchronously. Th

Re: camel-imap

Mezai, Why don't you persist the last number you processed and put in a PropertyPlaceholder when polling again? http://camel.apache.org/using-propertyplaceholder.html Little example I made: http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-insta