activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From magellings <mark.gelli...@qg.com>
Subject Re: Getting negative number of pending messages
Date Wed, 09 Sep 2009 19:22:33 GMT

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-tp22106707p25371678.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message