qpid-dev mailing list archives

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

    [ https://issues.apache.org/jira/browse/QPID-3649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13159943#comment-13159943
] 

Keith Wall commented on QPID-3649:
----------------------------------

I've noticed other places where this problem manifests:

1) On disconnection of a non-durable subscriber, you'd expect the underlying queue to be removed
from the list checked by SCD.  This does not happen.
2) On unsubscription of a durable subscriber, you'd expect the underlying queue to be removed
from the list checked by SCD.  This does not happen.


                
> 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.10, 0.12, 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