Also attaching the Java class.
Andreas
-------------------------------------------------------
Progress Software GmbH
Sitz der Gesellschaft: Agrippinawerft 26, 50678 Koeln;
Niederlassung: Fuerstenrieder Str. 279, 81377 Muenchen
Amtsgericht Koeln, HRB 15620;
Geschaeftsfuehrung: David Ireland
-------------------------------------------------------
On Mar 23, 2009, at 7:32 PM, Andreas Gies wrote:
Hi again ,
Well, I am not a Camel expert and don't know all the components from
the top of my head.
What I can say is that what you are trying to achieve would be
possible with a very simple
camel processor.
Perhaps it is even simpler to extract the color from the message
body in an even simpler
Processor, populate a message property and then use an out of the
box camel content
based router.
The architectural difference is that you keep the messaging layer
clean from routing definitions.
I have attached one my examples. You can see from there that it is
possible to write a processor
that looks into the message body. My code is slightly more complex
as I am adding Endpoints
on the fly in case my environment is dynamically growing. In your
case the code would be
simpler as you have a limited number of destinations.
I am also attaching the corresponding spring definitions.
Best regards
Andreas
-------------------------------------------------------
Progress Software GmbH
Sitz der Gesellschaft: Agrippinawerft 26, 50678 Koeln;
Niederlassung: Fuerstenrieder Str. 279, 81377 Muenchen
Amtsgericht Koeln, HRB 15620;Geschaeftsfuehrung: David Ireland
-------------------------------------------------------<bundle-
context.xml>
On Mar 23, 2009, at 7:17 PM, DanielR wrote:
Hi.
I need to use interceptors because I need to inspect the body of the
message. My filters are based on some characters of the body. With
camel,
you can only check if some string is contained in the body (may be
i'm
wrong?)
Andreas Gies-3 wrote:
Hi there,
Apart from the question why you want to do such a thin in an
interceptor instead of
using virtual destinations or a camel route....
Could you share your activemq.xml to let us see how you hooked in
the
plugin in the broker ?
Perhaps you could include some logging statements in your code and
understand what is executed.
You could also attach a remote debugger to Activemq and debug
through
your code.
Best regards
Andreas
On Mar 23, 2009, at 5:35 PM, DanielR wrote:
any ideas?
DanielR wrote:
I have a main queue named QUEUE.COLOR.
1 Producer send a lot of messages to QUEUE.COLOR
Messages only have "red ..." or "blue..." in their body
In trying to route the messages with "red ..." to QUEUE.RED and
the
messages with "blue..." to QUEUE.BLUE ONLY USING AN INTERCEPTOR
My problem: messages are randomly dispatched to QUEUE.RED or
QUEUE.BLUE
I have inspected some messages in QUEUE.RED and have their
Destination
property set to "queue://QUEUE.BLUE" that's weird...
Any clues? corrections? hints? codes?
Best Regards, DR.
This is my code:
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.ActiveMQSession;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.broker.Broker;
import org.apache.activemq.broker.BrokerFilter;
import org.apache.activemq.broker.BrokerPlugin;
import org.apache.activemq.broker.ProducerBrokerExchange;
import org.apache.activemq.command.Message;
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.broker.ConnectionContext;
import org.apache.activemq.broker.region.MessageReference;
import org.apache.activemq.command.TransactionId;
import org.apache.activemq.command.ActiveMQDestination;
import javax.jms.TextMessage;
import javax.jms.Session;
import javax.jms.Connection;
import javax.jms.Queue;
public class MsgInterceptorPluginRouter2 extends BrokerFilter
implements
BrokerPlugin {
public MsgInterceptorPluginRouter2() {
super(null);
}
public MsgInterceptorPluginRouter2(Broker next) {
super(next);
}
public Broker installPlugin(Broker broker) throws Exception {
return new MsgInterceptorPluginRouter2(broker);
}
public void send(ProducerBrokerExchange producerExchange, Message
messageSend) throws Exception{
String content = ((TextMessage)
messageSend).getText().substring(0, 30)
+ "...";
String substr = content.substring(0,4);
if (substr.matches("red\\s*")) {
messageSend.setDestination(this.getDestinations()[2]);
}
else if (substr.matches("blue\\s*")) {
messageSend.setDestination(this.getDestinations()[7]);
}
super.send(producerExchange, messageSend);
}
}
--
View this message in context:
http://www.nabble.com/Problem-trying-to-route-with-Interceptors-tp22606463p22663866.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
---
Mit freundlichen Grüssen - Kind Regards
Andreas Gies
Principal Consultant
Open Source Center of Competence
Progress Software GmbH
Agrippinawerft 26
50678 Köln
E-Mail ag...@progress.com
Direct Line +49 (0)9953 980349
Mobile +49 (0)170 5759611
Skype +44 (0)20 3239 2922
Skype +353 (0)1 443 4971
Skype +1 (0)781 262 0168
http://www.progress.com
http://fusesource.com
http://open-source-adventures.blogspot.com
-------------------------------------------------------
Progress Software GmbH
Sitz der Gesellschaft: Agrippinawerft 26, 50678 Koeln;
Niederlassung: Fuerstenrieder Str. 279, 81377 Muenchen
Amtsgericht Koeln, HRB 15620;
Geschaeftsfuehrung: David Ireland
-------------------------------------------------------
--
View this message in context:
http://www.nabble.com/Problem-trying-to-route-with-Interceptors-tp22606463p22665980.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
---
Mit freundlichen Grüssen - Kind Regards
Andreas Gies
Principal Consultant
Open Source Center of Competence
Progress Software GmbH
Agrippinawerft 26
50678 Köln
E-Mail ag...@progress.com
Direct Line +49 (0)9953 980349
Mobile +49 (0)170 5759611
Skype +44 (0)20 3239 2922
Skype +353 (0)1 443 4971
Skype +1 (0)781 262 0168
http://www.progress.com
http://fusesource.com
http://open-source-adventures.blogspot.com
---
Mit freundlichen Grüssen - Kind Regards
Andreas Gies
Principal Consultant
Open Source Center of Competence
Progress Software GmbH
Agrippinawerft 26
50678 Köln
E-Mail ag...@progress.com
Direct Line +49 (0)9953 980349
Mobile +49 (0)170 5759611
Skype +44 (0)20 3239 2922
Skype +353 (0)1 443 4971
Skype +1 (0)781 262 0168
http://www.progress.com
http://fusesource.com
http://open-source-adventures.blogspot.com
