Ashish, are you setting the clientID setting on your clients, as documented at the bottom of https://activemq.apache.org/how-do-durable-queues-and-topics-work.html? If not, then on reconnection it may be that the new connection is getting a different client ID, resulting in a different subscriber name.
Tim On Wed, Nov 20, 2019, 8:27 AM Ashish Vaishno <vaishno....@gmail.com> wrote: > 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&wireformat.maxFrameSize=104857600 > "/> > <transportConnector name="stomp" > uri="stomp:// > 0.0.0.0:61612?maximumConnections=1000&transport.closeAsync=false&connectionTimeout=120000&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&wireformat.maxFrameSize=104857600 > "/> > <transportConnector name="stomp" > uri="stomp:// > 0.0.0.0:61612?maximumConnections=1000&transport.closeAsync=false&connectionTimeout=120000&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 >
