You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Andrew Kennedy (JIRA)" <qp...@incubator.apache.org> on 2010/05/19 14:02:53 UTC
[jira] Updated: (QPID-1447) Broker does not handle with slow
consumers effectively
[ https://issues.apache.org/jira/browse/QPID-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Andrew Kennedy updated QPID-1447:
---------------------------------
Attachment: 0012-QPID-1447-Updated-to-use-newer-configuration-plugin.patch
qpid/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/configuration/plugin/SlowConsumerDetectionConfiguration.java
qpid/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/configuration/plugin/SlowConsumerDetectionPolicyConfiguration.java
qpid/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/configuration/plugin/SlowConsumerDetectionQueueConfiguration.java
qpid/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/SlowConsumerDetection.java
qpid/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/server/virtualhost/plugin/policies/TopicDeletePolicy.java
qpid/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/slowconsumerdetection/policies/SlowConsumerPolicyPlugin.java
qpid/java/broker-plugins/experimental/slowconsumerdetection/src/main/java/org/apache/qpid/slowconsumerdetection/policies/SlowConsumerPolicyPluginFactory.java
> Broker does not handle with slow consumers effectively
> ------------------------------------------------------
>
> Key: QPID-1447
> URL: https://issues.apache.org/jira/browse/QPID-1447
> Project: Qpid
> Issue Type: Improvement
> Components: Java Broker
> Affects Versions: M3
> Environment: Any
> Reporter: Robert Greig
> Assignee: Martin Ritchie
> Priority: Critical
> Attachments: 0012-QPID-1447-Updated-to-use-newer-configuration-plugin.patch
>
>
> Please see this qpid-user thread for further context: http://markmail.org/message/vgtssb2ivyttnbsf
> The qpid java broker does not deal effectively with slow consumers. This is a combination of two issues: a MINA issue and a lack of support in qpid itself.
> The MINA issue is similar to the "fast producer" issue. In this case, the data is stored in the MINA session queues, and does not appear in the queue counts which makes it very difficult for users to track down. Each MINA session event queue needs to be a bounded list.
> The broker also needs enhancement to offer at least two options when a queue builds up:
> 1) throttle the publisher. This is likely to be something that is desirable for "public" queues.
> 2) disconnect the slow consumer. This will be used when dealing with private queues - typically bound to a topic exchange.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org