qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Keith Wall (Created) (JIRA)" <j...@apache.org>
Subject [jira] [Created] (QPID-3649) SlowConsumerDetection continues to check (and holds references to) deleted queues
Date Tue, 29 Nov 2011 14:56:48 GMT
SlowConsumerDetection continues to check (and holds references to) deleted queues
---------------------------------------------------------------------------------

                 Key: QPID-3649
                 URL: https://issues.apache.org/jira/browse/QPID-3649
             Project: Qpid
          Issue Type: Bug
          Components: Java Broker
    Affects Versions: 0.12, 0.10, 0.14, 0.15
            Reporter: Keith Wall



SlowConsumerDetection maintains a list of queues to periodically test for the presence of
slow consumers.  If a queue is deleted however, the queue is not removed from the list.  
This could cause performance problems for users of the SlowConsumerDetection plugin, and may
pose the risk of a memory leak since the data structure caches references to AMQQueue.

To reproduce, configure SCD in the virtualhost xml, and use JMX to create/delete queues:

1) Create three queues:

{code}

2011-11-29 14:42:28,604 INFO  [RMI TCP Connection(4)-169.24.25.106] (Log4jMessageLogger.java:72)
- [mng:N/A(169.24.25.106)] [vh(/localhost)/qu(queue1)] QUE-1001 : Create : Owner: String Durable
2011-11-29 14:42:28,611 INFO  [RMI TCP Connection(4)-169.24.25.106] (Log4jMessageLogger.java:72)
- [mng:N/A(169.24.25.106)] [vh(/localhost)/ex(direct/<<default>>)/qu(queue1)/rk(queue1)]
BND-1001 : Create
2011-11-29 14:42:34,260 INFO  [RMI TCP Connection(3)-169.24.25.106] (Log4jMessageLogger.java:72)
- [mng:N/A(169.24.25.106)] [vh(/localhost)/qu(queue2)] QUE-1001 : Create : Owner: String Durable
2011-11-29 14:42:34,267 INFO  [RMI TCP Connection(3)-169.24.25.106] (Log4jMessageLogger.java:72)
- [mng:N/A(169.24.25.106)] [vh(/localhost)/ex(direct/<<default>>)/qu(queue2)/rk(queue2)]
BND-1001 : Create
2011-11-29 14:42:37,661 INFO  [RMI TCP Connection(4)-169.24.25.106] (Log4jMessageLogger.java:72)
- [mng:N/A(169.24.25.106)] [vh(/localhost)/qu(queue3)] QUE-1001 : Create : Owner: String Durable
2011-11-29 14:42:37,667 INFO  [RMI TCP Connection(4)-169.24.25.106] (Log4jMessageLogger.java:72)
- [mng:N/A(169.24.25.106)] [vh(/localhost)/ex(direct/<<default>>)/qu(queue3)/rk(queue3)]
BND-1001 : Create

{code}


2) Observe SCD checking the 3 queues:

{code}
2011-11-29 14:43:01,357 INFO  [localhost:SlowConsumerDetection] (Log4jMessageLogger.java:72)
- localhost:SlowConsumerDetectionSCD-1001 : Running
2011-11-29 14:43:01,358 INFO  [localhost:SlowConsumerDetection] (Log4jMessageLogger.java:72)
- localhost:SlowConsumerDetectionSCD-1003 : Checking Status of Queue queue2
2011-11-29 14:43:01,360 INFO  [localhost:SlowConsumerDetection] (Log4jMessageLogger.java:72)
- localhost:SlowConsumerDetectionSCD-1003 : Checking Status of Queue queue3
2011-11-29 14:43:01,361 INFO  [localhost:SlowConsumerDetection] (Log4jMessageLogger.java:72)
- localhost:SlowConsumerDetectionSCD-1003 : Checking Status of Queue queue1
2011-11-29 14:43:01,362 INFO  [localhost:SlowConsumerDetection] (Log4jMessageLogger.java:72)
- localhost:SlowConsumerDetectionSCD-1002 : Complete
{code}


3) Delete a queue

{code}

2011-11-29 14:43:14,178 INFO  [RMI TCP Connection(3)-169.24.25.106] (Log4jMessageLogger.java:72)
- [mng:N/A(169.24.25.106)] [vh(/localhost)/ex(direct/<<default>>)/qu(queue2)/rk(queue2)]
BND-1002 : Deleted
2011-11-29 14:43:14,179 INFO  [RMI TCP Connection(3)-169.24.25.106] (Log4jMessageLogger.java:72)
- [mng:N/A(169.24.25.106)] [vh(/localhost)/qu(queue2)] QUE-1002 : Deleted
{code}


4) Observe the SCD continues to check all queues

{code}
2011-11-29 14:44:01,358 INFO  [localhost:SlowConsumerDetection] (Log4jMessageLogger.java:72)
- localhost:SlowConsumerDetectionSCD-1001 : Running
2011-11-29 14:44:01,359 INFO  [localhost:SlowConsumerDetection] (Log4jMessageLogger.java:72)
- localhost:SlowConsumerDetectionSCD-1003 : Checking Status of Queue queue2
2011-11-29 14:44:01,361 INFO  [localhost:SlowConsumerDetection] (Log4jMessageLogger.java:72)
- localhost:SlowConsumerDetectionSCD-1003 : Checking Status of Queue queue3
2011-11-29 14:44:01,362 INFO  [localhost:SlowConsumerDetection] (Log4jMessageLogger.java:72)
- localhost:SlowConsumerDetectionSCD-1003 : Checking Status of Queue queue1
2011-11-29 14:44:01,363 INFO  [localhost:SlowConsumerDetection] (Log4jMessageLogger.java:72)
- localhost:SlowConsumerDetectionSCD-1002 : Complete
{code}



--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org


Mime
View raw message