Re: Stopped waiting for space in pendingMessage cursor messages

[kureckam]

Below is the config file. I don't have persistence set to true and the
ActiveMQ heap size is 1024mb.

<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";>
   <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="pBroker"
           dataDirectory="${activemq.base}/data">

      <destinationPolicy>
         <policyMap>
            <policyEntries>
               <policyEntry queue=">"
                            producerFlowControl="true"
                            optimizedDispatch="true" />

               <policyEntry topic=">"
                            topicPrefetch="1000"
                            producerFlowControl="true"
                            advisoryForSlowConsumers="true"
                            advisoryForDiscardingMessages="true"
                            advisoryForConsumed="true"
                            advisoryWhenFull="true" />
            </policyEntries>
         </policyMap>
      </destinationPolicy>

      <managementContext>
         <managementContext connectorPort="1099"
                            jmxDomainName="pDomain"/>
      </managementContext>
        
      <persistenceAdapter>
         <kahaDB directory="${activemq.base}/data/pData"
                 journalMaxFileLength="3 mb" />
      </persistenceAdapter>
        
      <systemUsage>
         <systemUsage sendFailIfNoSpace="true">
            <memoryUsage>
               <memoryUsage limit="600 mb"/>
            </memoryUsage>
            <storeUsage>
               <storeUsage limit="500 mb" />
            </storeUsage>
            <tempUsage>
               <tempUsage limit="500 mb"/>
            </tempUsage>
         </systemUsage>
      </systemUsage>

      <transportConnectors>
         <transportConnector name="openwire_p"
                             uri="nio://0.0.0.0:61616" />
      </transportConnectors>
   </broker>

   <broker xmlns="http://activemq.apache.org/schema/core";
           brokerName="fBroker"  dataDirectory="${activemq.base}/data">
        
      <destinationPolicy>
            <policyMap>
               <policyEntries>
                  <policyEntry queue=">"
                               producerFlowControl="true"
                               optimizedDispatch="true" />

                  <policyEntry topic=">"
                               producerFlowControl="true" />
               </policyEntries>
            </policyMap>
      </destinationPolicy> 

      <managementContext>
         <managementContext connectorPort="1099"
                            jmxDomainName="fDomain"/>
      </managementContext>

      <networkConnectors>
         <networkConnector
uri="static:(tcp://xxx.xxx.xxx.xxx:61616?wireFormat.maxInactivityDuration=3600000)"
                           name="fBridge"
                           conduitSubscriptions="false"
                           decreaseNetworkConsumerPriority="false"
                           duplex="true" />
      </networkConnectors>
        
      <persistenceAdapter>
         <kahaDB directory="${activemq.base}/data/fData"
                 journalMaxFileLength="10 mb" />
      </persistenceAdapter>
        
      <systemUsage>
         <systemUsage sendFailIfNoSpace="true">
            <memoryUsage>
               <memoryUsage limit="168 mb"/>
            </memoryUsage>
            <storeUsage>
               <storeUsage limit="2 gb" />
            </storeUsage>
            <tempUsage>
               <tempUsage limit="50 mb"/>
            </tempUsage>
         </systemUsage>
      </systemUsage>
                
      <transportConnectors>
         <transportConnector name="openwire_f"
                             uri="nio://0.0.0.0:61617" />
      </transportConnectors>
   </broker>

   <import resource="jetty.xml" />
</beans>



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Stopped-waiting-for-space-in-pendingMessage-cursor-messages-tp4658396p4658445.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.