Re: offline Durable Topic Subscribers issue in activemq 5.15.8

[Ashish Vaishno]

Hello Tim,

Please find below the config 

Config with kahadb

<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.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.conf}/credentials.properties</value>
    </property>
  </bean>

  <broker xmlns="http://activemq.apache.org/schema/core";
brokerName="MQ-MY-BROKER-NAME" dataDirectory="${activemq.data}"
schedulerSupport="false" persistent="true">
    <destinations>

    <topic physicalName="Hello.V3"/>

    <topic physicalName="Hello.V2"/>

    <topic physicalName="Hello.V1"/>

  </destinations>
    <destinationPolicy>
      <policyMap>
        <policyEntries>
          <policyEntry topic=">" producerFlowControl="true">
            <pendingMessageLimitStrategy>
              <constantPendingMessageLimitStrategy limit="1000"/>
            </pendingMessageLimitStrategy>
          </policyEntry>
          <policyEntry queue=">" producerFlowControl="true"
memoryLimit="20mb">
            <deadLetterStrategy>
              <individualDeadLetterStrategy queueSuffix=".DLQ"
useQueueForQueueMessages="true"/>
            </deadLetterStrategy>
          </policyEntry>
        </policyEntries>
      </policyMap>
    </destinationPolicy>

    <managementContext>
      <managementContext createConnector="true" connectorPort="1199"/>
    </managementContext>
    
    <persistenceAdapter>
      <kahaDB directory="${activemq.data}" journalMaxFileLength="32mb"/>
    </persistenceAdapter>

    
    <systemUsage>
      <systemUsage>
        <memoryUsage>
          <memoryUsage percentOfJvmHeap="70"/>
        </memoryUsage>
        <storeUsage>
          <storeUsage limit="10 gb"/>
        </storeUsage>
        <tempUsage>
          <tempUsage limit="1 gb"/>
        </tempUsage>
      </systemUsage>
    </systemUsage>


    
    <transportConnectors>
      <transportConnector name="openwire"
uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600"/>
      <transportConnector name="stomp"
uri="stomp://0.0.0.0:61612?maximumConnections=1000&amp;transport.closeAsync=false&amp;connectionTimeout=120000&amp;wireformat.maxFrameSize=104857600"/>
    </transportConnectors>

    
    <shutdownHooks>
      <bean xmlns="http://www.springframework.org/schema/beans";
class="org.apache.activemq.hooks.SpringContextHook" />
    </shutdownHooks>
  </broker>
  
  <import resource="jetty.xml"/>
</beans>




Config with mkahadb

<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.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.conf}/credentials.properties</value>
    </property>
  </bean>

  <broker xmlns="http://activemq.apache.org/schema/core";
brokerName="MQ-MY-BROKER-NAME" dataDirectory="${activemq.data}"
schedulerSupport="false" persistent="true">
    <destinations>

    <topic physicalName="Hello.V3"/>

    <topic physicalName="Hello.V2"/>

    <topic physicalName="Hello.V1"/>

  </destinations>
    <destinationPolicy>
      <policyMap>
        <policyEntries>
          <policyEntry topic=">" producerFlowControl="true">
            <pendingMessageLimitStrategy>
              <constantPendingMessageLimitStrategy limit="1000"/>
            </pendingMessageLimitStrategy>
          </policyEntry>
          <policyEntry queue=">" producerFlowControl="true"
memoryLimit="20mb">
            <deadLetterStrategy>
              <individualDeadLetterStrategy queueSuffix=".DLQ"
useQueueForQueueMessages="true"/>
            </deadLetterStrategy>
          </policyEntry>
        </policyEntries>
      </policyMap>
    </destinationPolicy>

    <managementContext>
      <managementContext createConnector="true" connectorPort="1199"/>
    </managementContext>
    
    <persistenceAdapter>
      <mKahaDB directory="${activemq.data}/mkahadb">
        <filteredPersistenceAdapters>
          <filteredKahaDB perDestination="true">
            <persistenceAdapter>
              <kahaDB ignoreMissingJournalfiles="false"
checkForCorruptJournalFiles="true" checksumJournalFiles="true"/>
            </persistenceAdapter>
          </filteredKahaDB>
        </filteredPersistenceAdapters>
      </mKahaDB>
    </persistenceAdapter>

    
    <systemUsage>
      <systemUsage>
        <memoryUsage>
          <memoryUsage percentOfJvmHeap="70"/>
        </memoryUsage>
        <storeUsage>
          <storeUsage limit="10 gb"/>
        </storeUsage>
        <tempUsage>
          <tempUsage limit="1 gb"/>
        </tempUsage>
      </systemUsage>
    </systemUsage>


    
    <transportConnectors>
      <transportConnector name="openwire"
uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireformat.maxFrameSize=104857600"/>
      <transportConnector name="stomp"
uri="stomp://0.0.0.0:61612?maximumConnections=1000&amp;transport.closeAsync=false&amp;connectionTimeout=120000&amp;wireformat.maxFrameSize=104857600"/>
    </transportConnectors>

    
    <shutdownHooks>
      <bean xmlns="http://www.springframework.org/schema/beans";
class="org.apache.activemq.hooks.SpringContextHook" />
    </shutdownHooks>
  </broker>
  
  <import resource="jetty.xml"/>
</beans>

Regards
Ashish



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html