activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timothy Bish <tabish...@gmail.com>
Subject Re: Getting negative number of pending messages
Date Fri, 11 Sep 2009 13:12:00 GMT


What version of the NMS client are you using?  Do you have a sample app that
can causes this to happen I'd like to try and reproduce the NMS errors if
possible.

Regards
Tim.


magellings wrote:
> 
> Note test went from 2009-09-09 14:01:29,918 to about 14:06.
> 
> I also needed to kill the broker.
> 
> 
> magellings wrote:
>> 
>> Using the wild-card address allowed the producers to connect.
>> 
>> I'm getting a lot of exceptions in the activemq.log however with 5.3 so I
>> can't test this.  It is very slow too.  I guess this isn't surprising if
>> exceptions are occurring.
>> 
>> I uploaded the activemq.log and a detailed NMS producer/consumer log. 
>> Possibly this is something with the NMS provider?
>> 
>>  http://www.nabble.com/file/p25371640/log.txt consumerLog.txt 
>>  http://www.nabble.com/file/p25371640/Log.txt producerLog.txt  
>>  http://www.nabble.com/file/p25371640/activemq.log activemq.log 
>> 
>> 
>> Gary Tully wrote:
>>> 
>>> with 5.3 "localhost" is local, not the wildcard address. you may need to
>>> use
>>> the wildcard address "0.0.0.0" if you localhost is tied to a different
>>> interface.
>>> 
>>> 2009/9/9 magellings <mark.gellings@qg.com>
>>> 
>>>>
>>>> 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.
>>>>
>>>>
>>> 
>>> 
>>> -- 
>>> http://blog.garytully.com
>>> 
>>> Open Source Integration
>>> http://fusesource.com
>>> 
>>> 
>> 
>> 
> 
> 

-- 
View this message in context: http://www.nabble.com/Getting-negative-number-of-pending-messages-tp22106707p25400736.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message