Return-Path: 
 <dev-return-19711-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-dev-archive@www.apache.org
Received: (qmail 75079 invoked from network); 7 Apr 2010 10:49:30 -0000
Received: from unknown (HELO mail.apache.org) (140.211.11.3)
  by 140.211.11.9 with SMTP; 7 Apr 2010 10:49:30 -0000
Received: (qmail 85413 invoked by uid 500); 7 Apr 2010 10:49:30 -0000
Delivered-To: apmail-activemq-dev-archive@activemq.apache.org
Received: (qmail 85253 invoked by uid 500); 7 Apr 2010 10:49:30 -0000
Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@activemq.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@activemq.apache.org>
List-Post: <mailto:dev@activemq.apache.org>
List-Id: <dev.activemq.apache.org>
Reply-To: dev@activemq.apache.org
Delivered-To: mailing list dev@activemq.apache.org
Received: (qmail 85245 invoked by uid 99); 7 Apr 2010 10:49:30 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 07 Apr 2010 10:49:30 +0000
X-ASF-Spam-Status: No, hits=-1238.3 required=10.0
	tests=ALL_TRUSTED,AWL
X-Spam-Check-By: apache.org
Received: from [140.211.11.140] (HELO brutus.apache.org) (140.211.11.140)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 07 Apr 2010 10:49:28 +0000
Received: from brutus.apache.org (localhost [127.0.0.1])
	by brutus.apache.org (Postfix) with ESMTP id 9ED14234C4AB
	for <dev@activemq.apache.org>; Wed,  7 Apr 2010 10:49:08 +0000 (UTC)
Message-ID: <274118014.13891270637348642.JavaMail.jira@brutus.apache.org>
Date: Wed, 7 Apr 2010 10:49:08 +0000 (UTC)
From: =?UTF-8?Q?Marc_Sch=C3=B6chlin_=28JIRA=29?= <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Updated: (AMQ-2680) Producer Flow Control seems to be broken
In-Reply-To: <2167497.6911269938948676.JavaMail.jira@brutus.apache.org>
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable
X-JIRA-FingerPrint: ae95407df07c98740808b2ef9da0087c


     [ https://issues.apache.org/activemq/browse/AMQ-2680?page=3Dcom.atlass=
ian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Marc Sch=C3=B6chlin updated AMQ-2680:
--------------------------------

    Attachment: activemq-broken-flow-control.xml

> Producer Flow Control seems to be broken
> ----------------------------------------
>
>                 Key: AMQ-2680
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2680
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker, Documentation
>    Affects Versions: 5.3.1
>         Environment: SLES 11, IBM JDK 1.6
>            Reporter: Marc Sch=C3=B6chlin
>            Assignee: Gary Tully
>            Priority: Critical
>             Fix For: 5.3.1
>
>         Attachments: activemq-broken-flow-control.xml, activemq.xml
>
>
> How to reproduce:
> - Download ActiveMQ 5.3.1
> - Start broker with the attached configuration
>    ---
>    <systemUsage>
>        <systemUsage>
>            <memoryUsage>
>                <memoryUsage limit=3D"10 mb"/>
>            </memoryUsage>
>            <storeUsage>
>                <storeUsage limit=3D"10 mb" name=3D"queue/RemoteQ"/>
>            </storeUsage>
>            <tempUsage>
>                <tempUsage limit=3D"3 gb"/>
>            </tempUsage>
>        </systemUsage>
>    </systemUsage>
>    ---
> - Start example producer/consumer
>    cd examples
>    ant producer -Durl=3Dtcp://127.0.0.1:61616 -Dmax=3D100000 -Dsubject=3D=
queue/RemoteQ -Ddurable=3Dtrue -DsleepTime=3D2
>    sleep 600
>    ant consumer -Durl=3Dtcp://127.0.0.1:61616  -Dsubject=3Dqueue/RemoteQ =
-Dmax=3D100000 -DsleepTime=3D2
> The problem:=20
> When the 10mb limit is reached, the producer is blocked forever.
> The expected behavior is, that if a consumer cleans the queue, producers =
are able to post more messages.
> Neither cleaning up the queue, restarting producers and restarting the br=
oker helps :-(
> It would be also a good idea to enhance the documentation about producer-=
flow-control:
> (http://activemq.apache.org/producer-flow-control.html)
> - expected behavior
> - what is limited in detail by using system|store|tempUsage=20
> The entire configuration :
> ---
> <beans
>   xmlns=3D"http://www.springframework.org/schema/beans"
>   xmlns:amq=3D"http://activemq.apache.org/schema/core"
>   xmlns:xsi=3D"http://www.w3.org/2001/XMLSchema-instance"
>   xsi:schemaLocation=3D"http://www.springframework.org/schema/beans http:=
//www.springframework.org/schema/beans/spring-beans-2.0.xsd
>   http://activemq.apache.org/schema/core http://activemq.apache.org/schem=
a/core/activemq-core.xsd">
>     <bean class=3D"org.springframework.beans.factory.config.PropertyPlace=
holderConfigurer">
>         <property name=3D"locations">
>             <value>file:${activemq.base}/conf/credentials.properties</val=
ue>
>         </property>     =20
>     </bean>
>     <broker xmlns=3D"http://activemq.apache.org/schema/core" brokerName=
=3D"localhost" dataDirectory=3D"${activemq.data}/data" >
>         <destinationPolicy>
>             <policyMap>
>               <policyEntries>
>                 <policyEntry topic=3D">" producerFlowControl=3D"true" mem=
oryLimit=3D"10mb">
>                   <deadLetterStrategy>
>                     <!--
>                       Use the prefix 'DLQ.' for the destination name, and=
 make
>                       the DLQ a queue rather than a topic
>                     -->
>                     <individualDeadLetterStrategy
>                       queuePrefix=3D"DLQ." useQueueForQueueMessages=3D"tr=
ue" />
>                   </deadLetterStrategy>
>                   <pendingSubscriberPolicy>
>                     <vmCursor />
>                   </pendingSubscriberPolicy>
>                 </policyEntry>
>                 <policyEntry queue=3D">" producerFlowControl=3D"true" mem=
oryLimit=3D"10mb">
>                   <!-- Use VM cursor for better latency
>                        For more information, see:
>                       =20
>                        http://activemq.apache.org/message-cursors.html
>                       =20
>                   <pendingQueuePolicy>
>                     <vmQueueCursor/>
>                   </pendingQueuePolicy>
>                   -->
>                   <deadLetterStrategy>
>                     <!--
>                       Use the prefix 'DLQ.' for the destination name, and=
 make
>                       the DLQ a queue rather than a topic
>                     -->
>                     <individualDeadLetterStrategy
>                       queuePrefix=3D"DLQ." useQueueForQueueMessages=3D"tr=
ue" />
>                   </deadLetterStrategy>
>                 </policyEntry>
>               </policyEntries>
>             </policyMap>
>         </destinationPolicy>=20
> =20
>         <systemUsage>
>             <systemUsage>
>                 <memoryUsage>
>                     <memoryUsage limit=3D"10 mb"/>
>                 </memoryUsage>
>                 <storeUsage>
>                     <storeUsage limit=3D"10 mb" name=3D"queue/RemoteQ"/>
>                 </storeUsage>
>                 <tempUsage>
>                     <tempUsage limit=3D"3 gb"/>
>                 </tempUsage>
>             </systemUsage>
>         </systemUsage>
>                  =20
>         <transportConnectors>
>             <transportConnector name=3D"openwire" uri=3D"tcp://0.0.0.0:61=
616"/>
>         </transportConnectors>
>     </broker>
>     <import resource=3D"jetty.xml"/>
>    =20
> </beans>
> ---

--=20
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.