Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of rajdavies@gmail.com designates
 209.85.211.185 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=message-id:from:to:in-reply-to:content-type
         :content-transfer-encoding:mime-version:subject:date:references
         :x-mailer;
        b=kvACGD1MZhT2Q/iuzjzoR+81v/uRFUJaNxOa1VjUwMFawQZ3RNh6CFoqT+upDSjyWu
         rWWgri9dseWO0JvhPBRzW7jZ3uNuMEwgRadkL3eI10BZ/8Zv7kCAk0XVdDnxDfh9WK+2
         96eidyHwG1yIs5xQsc3LvxqvINTcdISdB3b1o=
Message-Id: <4D508E2F-6884-4EF5-86F0-F1B081238499@gmail.com>
From: Rob Davies <rajdavies@gmail.com>
To: users@activemq.apache.org
In-Reply-To: <25369349.post@talk.nabble.com>
Content-Type: text/plain; charset=US-ASCII; format=flowed; delsp=yes
Content-Transfer-Encoding: 7bit
Mime-Version: 1.0 (Apple Message framework v936)
Subject: Re: Getting negative number of pending messages
Date: Wed, 9 Sep 2009 18:45:51 +0100
References: <22106707.post@talk.nabble.com> <25295148.post@talk.nabble.com>
 <E187AC5E-D9DA-4B29-B10C-C5D5AD99A248@gmail.com>
 <25299721.post@talk.nabble.com>
 <8D4FBEB6-66A9-497C-87FB-229E81BB4613@gmail.com>
 <25369349.post@talk.nabble.com>

just as a sanity check - can you try a 5.3 client to connect to the  
5.3 broker?
On 9 Sep 2009, at 18:10, magellings wrote:

>
> Okay I have 5.3 configured with the following config.  I can't  
> connect from
> another machine through the host name of the server however.  This  
> config is
> taken directly from an ActiveMQ 5.2 broker and running that broker I  
> can
> connect just fine.  Anyone know what's up?
>
> <!--
>    Licensed to the Apache Software Foundation (ASF) under one or more
>    contributor license agreements.  See the NOTICE file distributed  
> with
>    this work for additional information regarding copyright ownership.
>    The ASF licenses this file to You under the Apache License,  
> Version 2.0
>    (the "License"); you may not use this file except in compliance  
> with
>    the License.  You may obtain a copy of the License at
>
>    http://www.apache.org/licenses/LICENSE-2.0
>
>    Unless required by applicable law or agreed to in writing, software
>    distributed under the License is distributed on an "AS IS" BASIS,
>    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or  
> implied.
>    See the License for the specific language governing permissions and
>    limitations under the License.
> -->
>
> <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">
>
>  <!-- Allows us to use system properties as variables in this  
> configuration
> file -->
>  <bean
> class 
> = 
> "org 
> .springframework.beans.factory.config.PropertyPlaceholderConfigurer">
>    <property name="locations">
>      <value>file:///${activemq.base}/conf/credentials.properties</ 
> value>
>    </property>
>  </bean>
>
>  <broker xmlns="http://activemq.apache.org/schema/core"
> brokerName="WAMQDEV1PRODUCTREQUEST" dataDirectory="${activemq.base}/ 
> data">
>
>    <plugins>
>      <simpleAuthenticationPlugin>
>        <users>
>          <authenticationUser username="GL$ACTIVEMQ_PRODUCTREQUEST"
> password="replenish" groups="producers,consumers,admins" />
>        </users>
>      </simpleAuthenticationPlugin>
>      <authorizationPlugin>
>        <map>
>          <authorizationMap>
>            <authorizationEntries>
>              <authorizationEntry queue=">" write="producers"
> read="consumers" admin="admins,producers" />
>              <authorizationEntry topic=">" read="admins"
> write="admins,producers" admin="admins,producers,consumers" />
>            </authorizationEntries>
>          </authorizationMap>
>        </map>
>      </authorizationPlugin>
>    </plugins>
>
>
>    <!-- Destination specific policies using destination names or  
> wildcards
> -->
>    <destinationPolicy>
>      <policyMap>
>        <policyEntries>
>          <policyEntry queue=">" useCache="true" memoryLimit="5mb"/>
>          <policyEntry topic=">" advisoryForSlowConsumers="true"
> advisdoryForFastProducers="true" advisoryWhenFull="true"  
> memoryLimit="5mb"/>
>        </policyEntries>
>      </policyMap>
>    </destinationPolicy>
>
>    <!-- Use the following to configure how ActiveMQ is exposed in  
> JMX -->
>    <managementContext>
>      <managementContext createConnector="false"/>
>    </managementContext>
>
>    <persistenceAdapter>
>      <amqPersistenceAdapter syncOnWrite="false"
> directory="${activemq.base}/data" maxFileLength="20 mb"/>
>    </persistenceAdapter>
>
>    <persistenceAdapter>
>      <jdbcPersistenceAdapter dataSource="#mssql-ds"
> createTablesOnStartup="false"  />
>    </persistenceAdapter>
>
>    <sslContext>
>      <sslContext keyStore="file:${activemq.base}/conf/broker.ks"
> keyStorePassword="password"
> trustStore="file:${activemq.base}/conf/broker.ts"
> trustStorePassword="password"/>
>    </sslContext>
>
>    <!--  The maximum about of space the broker will use before  
> slowing down
> producers -->
>    <systemUsage>
>      <systemUsage>
>        <memoryUsage>
>          <memoryUsage limit="20 mb"/>
>        </memoryUsage>
>        <storeUsage>
>          <storeUsage limit="1 gb" name="foo"/>
>        </storeUsage>
>        <tempUsage>
>          <tempUsage limit="100 mb"/>
>        </tempUsage>
>      </systemUsage>
>    </systemUsage>
>
>    <!-- The transport connectors ActiveMQ will listen to -->
>    <transportConnectors>
>      <transportConnector name="openwire" uri="tcp://localhost:10198"
> discoveryUri="multicast://default"/>
>    </transportConnectors>
>
>  </broker>
>
>  <bean id="mssql-ds" class="com.mchange.v2.c3p0.ComboPooledDataSource"
> destroy-method="close">
>    <property name="driverClass"
> value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/>
>    <property name="jdbcUrl"
> value="jdbc:sqlserver://CHALLENGER.qg.com: 
> 1433;databaseName=ActiveMQProductRequest;user=GL 
> $ACTIVEMQ_PRODUCTREQUEST;password=replenish"/>
>    <property name="user" value="GL$ACTIVEMQ_PRODUCTREQUEST"/>
>    <property name="password" value="replenish"/>
>    <property name="acquireRetryAttempts" value="100"/>
>    <property name="testConnectionOnCheckout" value="true"/>
>    <property name="testConnectionOnCheckin" value="true"/>
>    <property name="automaticTestTable" value="ACTIVEMQ_CONN_TEST"/>
>    <property name="acquireRetryDelay" value="5000"/>
>    <property name="preferredTestQuery" value="SELECT 1"/>
>  </bean>
>
>  <jetty xmlns="http://mortbay.com/schemas/jetty/1.0">
>    <connectors>
>      <nioConnector port="10199"/>
>    </connectors>
>
>    <handlers>
>      <webAppContext contextPath="/admin"
> resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true"/>
>      <webAppContext contextPath="/camel"
> resourceBase="${activemq.base}/webapps/camel" logUrlOnStart="true"/>
>      <webAppContext contextPath="/demo"
> resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true"/>
>      <webAppContext contextPath="/fileserver"
> resourceBase="${activemq.base}/webapps/fileserver"  
> logUrlOnStart="true"/>
>    </handlers>
>  </jetty>
>
> </beans>
>
>
>
>
>
>
>
>
>
>
>
> rajdavies wrote:
>>
>> We are aiming to get a 5.3 release candidate to vote on next week -  
>> so
>> no long
>> On 4 Sep 2009, at 19:46, magellings wrote:
>>
>>>
>>> Right now we're focusing pretty hard on stress testing version 5.2
>>> but we can
>>> try and fit in a test.  When is the estimated release date of
>>> version 5.3?
>>> In other words, how much time do we have?  :)
>>>
>>>
>>> rajdavies wrote:
>>>>
>>>>
>>>> On 4 Sep 2009, at 15:14, magellings wrote:
>>>>
>>>>>
>>>>> We too were having problems were number of pending of messages  
>>>>> was a
>>>>> negative
>>>>> number and messages received was greater than number sent.  We
>>>>> determined
>>>>> there were indeed duplicate messages being sent.
>>>>>
>>>>> We ended up setting useCache to false on the queue policy entry  
>>>>> and
>>>>> the
>>>>> problem appears to be resolved.
>>>>>
>>>>> We too were sending a high volume of messages to our queues
>>>>> relatively
>>>>> quickly.
>>>>> -- 
>>>>> View this message in context:
>>>>> http://www.nabble.com/Getting-negative-number-of-pending-messages-tp22106707p25295148.html
>>>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>>>>
>>>>
>>>>
>>>> It would be great to know if you still had the problem on the  
>>>> latest
>>>> 5.3 snapshot too
>>>>
>>>> cheers,
>>>>
>>>> Rob
>>>>
>>>> Rob Davies
>>>> I work here: http://fusesource.com
>>>> My Blog: http://rajdavies.blogspot.com/
>>>> I'm writing this: http://www.manning.com/snyder/
>>>>
>>>>
>>>>
>>>>
>>>>
>>>>
>>>
>>> -- 
>>> View this message in context:
>>> http://www.nabble.com/Getting-negative-number-of-pending-messages-tp22106707p25299721.html
>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>>
>>
>> Rob Davies
>> I work here: http://fusesource.com
>> My Blog: http://rajdavies.blogspot.com/
>> I'm writing this: http://www.manning.com/snyder/
>>
>>
>>
>>
>>
>>
>
> -- 
> View this message in context: http://www.nabble.com/Getting-negative-number-of-pending-messages-tp22106707p25369349.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Rob Davies
I work here: http://fusesource.com
My Blog: http://rajdavies.blogspot.com/
I'm writing this: http://www.manning.com/snyder/