Re: How to wiretap without consuming the original queue

2015-05-20 Thread Jonasty
The only helpful are questions that I posted by myself... -- View this message in context: http://camel.465427.n5.nabble.com/How-to-wiretap-without-consuming-the-original-queue-tp5767253p5767324.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to wiretap without consuming the original queue

2015-05-20 Thread Jonasty
Thanks, but Camel isn't allowed to consume in my program. I just need to monitor the queue. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-wiretap-without-consuming-the-original-queue-tp5767253p5767318.html Sent from the Camel - Users mailing list archive at Nabble.co

Re: How to wiretap without consuming the original queue

2015-05-20 Thread Jonasty
If I do that, I wel get an unclosable loop of messages being pumped at the same queue. -- View this message in context: http://camel.465427.n5.nabble.com/How-to-wiretap-without-consuming-the-original-queue-tp5767253p5767315.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to wiretap without consuming the original queue

2015-05-20 Thread Jonasty
I don't want to process anything, this is not the function of my program So I get from("activemq:queue:aap").wireTap("direct:log") // this is the tapped route from("direct:log").process(myProcessor) -- View this message in context: http://camel.465427.n5.nabble.com/How-to-wiretap-without-

Re: How to wiretap without consuming the original queue

2015-05-20 Thread Jonasty
But how can I log in that case a new incoming message on the queue? -- View this message in context: http://camel.465427.n5.nabble.com/How-to-wiretap-without-consuming-the-original-queue-tp5767253p5767305.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: How to wiretap without consuming the original queue

2015-05-20 Thread Jonasty
That's the whole point, I am wiretapping it, but it still get polled from my queue, My routes look like: from("activemq:queue:" + propertiesManager.getProperty("queueName")).wireTap("activemq:queue:" + propertiesManager.getProperty("queueName") + "Tap"); from("activemq:queue:" + properties

Re: How to wiretap without consuming the original queue

2015-05-20 Thread Jonasty
I am trying to monitor a queue on a public activeMQ server For every incoming message, I need this wiretap to process it (pumping a record into a database). Because a Queue has 1 producer and 1 consumer, but I want to let the message stay on his queue and not poll it. That's why I just want to wire

Re: How to wiretap without consuming the original queue

2015-05-19 Thread Jonasty
How can I send it to nowhere or do nothing? -- View this message in context: http://camel.465427.n5.nabble.com/How-to-wiretap-without-consuming-the-original-queue-tp5767253p5767255.html Sent from the Camel - Users mailing list archive at Nabble.com.

How to wiretap without consuming the original queue

2015-05-19 Thread Jonasty
Hello I am monitoring activemq, I use following routebuilder for this: @Override public void configure() throws Exception { from("activemq:queue:aap").wireTap("activemq:queue:aapTap"); from("activemq:queue:aapTap").process(myProcessor).id("QueueIncoming"); } But when I sen

Apache Camel make a route to a public Active MQ server

2015-05-19 Thread Jonasty
I have following routes @Override public void configure() throws Exception { from("activemq:queue:aap").wireTap("activemq:queue:"aapTap"); from("activemq:queue:aapTap").process(processor).id("QueueIncoming"); } But when I run this, active MQ looks for my local host, I not

Disable camellock files

2015-03-30 Thread Jonasty
Hello I want to check if there are enough files in my folder. But when I make an exchange approach, the camel filelock makes an unused file Can I disable the system to create these files? Thanks! -- View this message in context: http://camel.465427.n5.nabble.com/Disable-camellock-files-tp57650

Failed to create route on activemq

2015-03-25 Thread Jonasty
I have following code: context.addRoutes(new RouteBuilder() { public void configure() throws JMSException { from("activemq:queue:KBC?noop=true").process(new QueueProcessor()); } }); The queueprocessor writes a log to the databa

Apache camel monitor activemq

2015-03-24 Thread Jonasty
How do I do that? -- View this message in context: http://camel.465427.n5.nabble.com/Apache-camel-monitor-activemq-tp5764703.html Sent from the Camel - Users mailing list archive at Nabble.com.