Issue Details (XML | Word | Printable)

Key: AMQ-1672
Type: Bug Bug
Status: Resolved Resolved
Resolution: Fixed
Priority: Major Major
Assignee: Rob Davies
Reporter: vik dhawan
Votes: 0
Watchers: 0
Operations

If you were logged in you would be able to see more operations.
ActiveMQ

Mirror Queues on Temp Queues is causing Memory leak

Created: 17/Apr/08 03:18 PM   Updated: 21/Apr/08 06:40 AM
Return to search
Component/s: Broker
Affects Version/s: 4.1.2, 5.0.0
Fix Version/s: 5.1.0

Time Tracking:
Not Specified

Environment: AMQ 4.x/5.x on Solaris 10


 Description  « Hide
Having Mirror queues turned on AMQ, creates the mirror queue for all the TEMP queues gets created. TEMP queues gets destroyed when the transaction is over but Mirror queues never goes away. after a long test (creating around 100K transactions) MIRROR queues caused memory problem in AMQ. TEMP queues were all removed appropriately. When looked at the JConsole there are all those MIRROR queue treads for the TEMP queues in the wait state.

 All   Comments   Work Log   Change History   Subversion Commits   FishEye   Crucible      Sort Order: Ascending order - Click to sort in descending order
Rob Davies made changes - 21/Apr/08 06:36 AM
Field Original Value New Value
Assignee Rob Davies [ rajdavies ]
[ Permlink | « Hide ]
Rob Davies added a comment - 21/Apr/08 06:40 AM
Fixed by svn revision 650143

Rob Davies made changes - 21/Apr/08 06:40 AM
Resolution Fixed [ 1 ]
Fix Version/s 5.1.0 [ 11802 ]
Status Open [ 1 ] Resolved [ 5 ]
650143 by  Rob Davies (23 files)
21/Apr/08 06:41 AM (18 months, 25 days ago)
Fix for https://issues.apache.org/activemq/browse/AMQ-1672
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java 650143 history download (+3 -10) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationInterceptor.java 650143 history download (+2 -0) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/CompositeDestinationInterceptor.java 650143 history download (+7 -0) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualDestinationInterceptor.java 650143 history download (+5 -1) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java 650143 history download (+4 -0) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueBrowserSubscription.java 650143 history download (+2 -4) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java 650143 history download (+11 -6) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java 650143 history download (+13 -12) diffs
trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempQueueMemoryTest.java 650143 history download (+1 -1) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeQueue.java 650143 history download (+1 -0) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestination.java 650143 history download (+4 -0) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java 650143 history download (+2 -10) diffs
trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempDestLoadTest.java 650143 history download (+7 -6) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualTopic.java 650143 history download (+4 -0) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempTopicRegion.java 650143 history download (+1 -3) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java 650143 history download (+17 -0) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java 650143 history download (+2 -5) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java 650143 history download (+2 -5) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java 650143 history download (+4 -0) diffs
trunk/activemq-core/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueTest.java 650143 history download (+17 -1) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java 650143 history download (+1 -6) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java 650143 history download (+0 -2) diffs
trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java 650143 history download (+3 -10) diffs

Repository Revision Date User Message
AMQ #650143 Mon Apr 21 06:41:19 PDT 2008 rajdavies Fix for https://issues.apache.org/activemq/browse/AMQ-1672
Files Changed
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationInterceptor.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/CompositeDestinationInterceptor.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/VirtualDestinationInterceptor.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractRegion.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueBrowserSubscription.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DurableTopicSubscription.java
MODIFY /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempQueueMemoryTest.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeQueue.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/CompositeDestination.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TempQueueRegion.java
MODIFY /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempDestLoadTest.java
MODIFY /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/TempTopicRegion.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/virtual/MirroredQueue.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
MODIFY /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/virtual/MirroredQueueTest.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/AbstractSubscription.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/QueueRegion.java

Create crucible review for this changeset in

Powered by a free Atlassian JIRA open source license for Apache Software Foundation - ActiveMQ. Try JIRA - bug tracking software for your team.
Atlassian JIRA the Professional Issue Tracker. (Enterprise Edition, Version: 3.13.2-#335) - Bug/feature request - Atlassian news - Contact Administrators