Return-Path: 
 <users-return-14370-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 75279 invoked from network); 2 Jun 2008 14:29:58 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 2 Jun 2008 14:29:58 -0000
Received: (qmail 35881 invoked by uid 500); 2 Jun 2008 14:29:59 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 35869 invoked by uid 500); 2 Jun 2008 14:29:59 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 35858 invoked by uid 99); 2 Jun 2008 14:29:59 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Jun 2008 07:29:59 -0700
X-ASF-Spam-Status: No, hits=2.6 required=10.0
	tests=DNS_FROM_OPENWHOIS,SPF_HELO_PASS,SPF_PASS,WHOIS_MYPRIVREG
X-Spam-Check-By: apache.org
Received-SPF: pass (nike.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158)
    by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Jun 2008 14:29:02 +0000
Received: from isper.nabble.com ([192.168.236.156])
	by kuber.nabble.com with esmtp (Exim 4.63)
	(envelope-from <lists@nabble.com>)
	id 1K3B2K-0002ge-88
	for users@activemq.apache.org; Mon, 02 Jun 2008 07:29:24 -0700
Message-ID: <17602690.post@talk.nabble.com>
Date: Mon, 2 Jun 2008 07:29:24 -0700 (PDT)
From: kloh <kevin.lohmann@d-velop.de>
To: users@activemq.apache.org
Subject: Closing a consumer create more messages than sent
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Nabble-From: kevin.lohmann@d-velop.de
X-Virus-Checked: Checked by ClamAV on apache.org


Hi *,

we're concerning with interested happenings, about which we're not sure,
wether this is caused by bad configuration, bad code or a bug.

The scenario:
ActiveMQ 5.1, persistence with the amq-store, transactional.
We have two producer, each sends 10.000 messages to the broker, to a queue.
We have 3 consumers; one of this consumers is closed every 5 seconds and a
new consumer is created and started. Each consumer just counts the messages
it recieved and commits.

What happens?
After the consumers don't recieve any messages, we take a look at the
web-console or the jmx-monitor and see, that the pending messages are
negative (about 3 to 5) and the recieved messages are not 20.000 but 20.005
(for example).

We just tried differents variants of closing the consumer, but the calls
--
consumer.close()
session.close()
--
should work. Or did we not get the point at this?

The configuration:
<beans
  xmlns="http://www.springframework.org/schema/beans"
  xmlns:amq="http://activemq.apache.org/schema/core"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="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/schema/core/activemq-core.xsd   
  http://activemq.apache.org/camel/schema/spring
http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">

    <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>

    <broker xmlns="http://activemq.apache.org/schema/core"
brokerName="localhost" useJmx="true" persistent="true"
dataDirectory="${activemq.base}/data">

        <destinationPolicy>
            <policyMap>
                <policyEntries>
                    <policyEntry queue=">" producerFlowControl="true"
memoryLimit="50mb"/>
                    <policyEntry topic=">" memoryLimit="5mb">
                        <dispatchPolicy>
                            <strictOrderDispatchPolicy/>
                        </dispatchPolicy>
                        <subscriptionRecoveryPolicy>
                            <lastImageSubscriptionRecoveryPolicy/>
                        </subscriptionRecoveryPolicy>
                    </policyEntry>
                </policyEntries>
            </policyMap>
        </destinationPolicy>

        <managementContext>
            <managementContext connectorPort="1099"
jmxDomainName="org.apache.activemq"/>
        </managementContext>

        <networkConnectors>
            <networkConnector name="default-nc" uri="multicast://default"/>
        </networkConnectors>

	<persistenceAdapter>
            <amqPersistenceAdapter syncOnWrite="false"
directory="${activemq.base}/data" maxFileLength="20 mb"/>
        </persistenceAdapter>

        <systemUsage>
            <systemUsage>
                <memoryUsage>
                    <memoryUsage limit="100 mb"/> 
                </memoryUsage>
                <storeUsage>
                    <storeUsage limit="1 gb" name="messageStorage"/>
                </storeUsage>
                <tempUsage>
                    <tempUsage limit="100 mb"/>
                </tempUsage>
            </systemUsage>
        </systemUsage>

        <transportConnectors>
            <transportConnector name="openwire" uri="tcp://localhost:61616"
discoveryUri="multicast://default"/>
        </transportConnectors>

    </broker>
   
    <camelContext id="camel"
xmlns="http://activemq.apache.org/camel/schema/spring">
        <package>org.foo.bar</package>
    </camelContext>

    <jetty xmlns="http://mortbay.com/schemas/jetty/1.0">
        <connectors>
            <nioConnector port="8161"/>
        </connectors>

        <handlers>
            <webAppContext contextPath="/admin"
resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true"/>
            <webAppContext contextPath="/demo"
resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true"/>
            <webAppContext contextPath="/fileserver"
resourceBase="${activemq.base}/webapps/fileserver" logUrlOnStart="true"/>
        </handlers>
    </jetty>

    <bean id="derby-ds" class="org.apache.derby.jdbc.EmbeddedDataSource">
      <property name="databaseName" value="derbydb"/>
      <property name="createDatabase" value="create"/>
    </bean>
</beans>
<!-- END SNIPPET: example -->

We are interested, if someone else has occured this or there is just one
(simple) point, that we miss.
-- 
View this message in context: http://www.nabble.com/Closing-a-consumer-create-more-messages-than-sent-tp17602690s2354p17602690.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.