[#AMQ-1435] support mirrored queues to make it easier to monitor message flows via a topic (or queue via virtual topics) for things like BAM or monitoring etc - Apache ActiveMQ, Apache ServiceMix, Apache Camel

ActiveMQ

support mirrored queues to make it easier to monitor message flows via a topic (or queue via virtual topics) for things like BAM or monitoring etc

Created: 27/Sep/07 01:06 AM Updated: 09/Oct/07 07:33 AM

Return to search

Component/s:

Broker

Affects Version/s:

None

Fix Version/s:

5.0.0

Time Tracking:

Not Specified

Description

« Hide

Mirrored queues would be very handy; so that if enabled folks can monitor a virtual topic to see messages being delivered to a topic; while being out of band of the queue message flow. i.e. so that any existing queue based application works as before, but meanwhile other services can consume those same messages via a topic or virtual topic

All

Comments

Work Log

Change History

Subversion Commits

FishEye

Crucible

Sort Order:

579941 by James Strachan (9 files)

27/Sep/07 01:26 AM (25 months, 21 days ago)

added patch for https://issues.apache.org/activemq/browse/AMQ-1435 to handle Mirrored Queues (so that folks can consume on a topic what messages are sent to a queue)

trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestination.java 579941

(+1 -1) diffs

trunk/activemq-core/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueUsingVirtualTopicQueueTest.java 579941

(+34) new

trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopic.java 579941

(+0 -7) diffs

trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java 579941

(+127) new

trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopicInterceptor.java 579941

(+1 -0) diffs

trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java 579941

(+83) new

trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationInterceptor.java 579941

deleted

trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java 579941

(+55 -24) diffs

trunk/activemq-core/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueTest.java 579941

(+100) new

Repository	Revision	Date	User	Message
AMQ	#579941	Thu Sep 27 01:26:57 PDT 2007	jstrachan	added patch for https://issues.apache.org/activemq/browse/AMQ-1435 to handle Mirrored Queues (so that folks can consume on a topic what messages are sent to a queue)
				Files Changed
				MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestination.java ADD /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueUsingVirtualTopicQueueTest.java MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopic.java ADD /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java (from /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopic.java) MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopicInterceptor.java ADD /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationFilter.java (from /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationInterceptor.java) DEL /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestinationInterceptor.java MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java ADD /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueTest.java (from /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/virtual/VirtualTopicPubSubTest.java)

[ Permlink | « Hide ]

James Strachan added a comment - 27/Sep/07 01:38 AM

Code committed to trunk - just awaiting documention

[ Permlink | « Hide ]

James Strachan added a comment - 09/Oct/07 07:33 AM

See the documentation

http://cwiki.apache.org/ACTIVEMQ/mirrored-queues.html

James Strachan made changes - 09/Oct/07 07:33 AM

Field	Original Value	New Value
Status	Open [ 1 ]	Resolved [ 5 ]
Resolution		Fixed [ 1 ]