what can best way aggregate messages many different sources (actually queues/topics) single queue/topic , consume it. trying design application receive messages different topics in jms using weblogic.
you write own "aggregator" stand-alone java application:
- for each queue/topic have reader in own thread.
each reader sends received message again on "aggregate queue".
have thread listen on "aggregate queue".
as variation, use jvm queue (like java.util.concurrent.arrayblockingqueue) "aggregate queue". faster, not require mq queue, not need network bandwidth, it's not persistent.
another idea use "message driven bean (mdb)" each incoming queue/topic:
- again, each of these mdbs reads message , resends "aggregate queue".
- have mdb listening on "aggregate queue".
Comments
Post a Comment