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.
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
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.
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-
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.
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
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
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.
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
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
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
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
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.
13 matches
Mail list logo