सक्रिय एमक्यू 5.13.2 संदेश

Question

पुनरारंभ करने के बाद गायब हैं मैं सक्रिय एमक्यू में नया हूं। स्थापित सक्रिय एमक 5.13.2। सक्रिय एमक्यू सर्वर पुनरारंभ करने के बाद मैं अपने सभी संदेशों (टिकाऊ विषय सहित) खो रहा हूं। सक्रिय एमक्यू सर्वर पुनरारंभ करने से पहले और बाद में कृपया नीचे कंसोल स्क्रीन शॉट्स पाएं।

before activeMQ restart

After ActiveMQ restart

यह मेरा activemq.xml विन्यास है:

<beans 
    xmlns="http://www.springframework.org/schema/beans" 
    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> 


    <bean id="logQuery" class="io.fabric8.insight.log.log4j.Log4jLogQuery" 
      lazy-init="false" scope="singleton" 
      init-method="start" destroy-method="stop"> 
    </bean> 

    <broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" persistent="true" useShutdownHook="false"> 

     <destinationPolicy> 
      <policyMap> 
       <policyEntries> 
       <policyEntry topic=">" > 

        <pendingMessageLimitStrategy> 
        <constantPendingMessageLimitStrategy limit="1000"/> 
        </pendingMessageLimitStrategy> 
       </policyEntry> 
       </policyEntries> 
      </policyMap> 
     </destinationPolicy> 



     <managementContext> 
      <managementContext createConnector="false"/> 
     </managementContext> 


     <persistenceAdapter> 
      <kahaDB directory="${activemq.data}/kahadb" journalMaxFileLength="32mb"/> 
     </persistenceAdapter> 




      <systemUsage> 
      <systemUsage> 
       <memoryUsage> 
        <memoryUsage percentOfJvmHeap="70" /> 
       </memoryUsage> 
       <storeUsage> 
        <storeUsage limit="100 gb"/> 
       </storeUsage> 
       <tempUsage> 
        <tempUsage limit="50 gb"/> 
       </tempUsage> 
      </systemUsage> 
     </systemUsage> 


     <transportConnectors> 

      <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/> 
      <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/> 
      <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/> 
      <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/> 
      <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/> 
     </transportConnectors> 

     <destinations> 
       <queue physicalName="testQueue"> 
       </queue> 
       <topic physicalName="testTopic" /> 
     </destinations> 

     <shutdownHooks> 
      <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /> 
     </shutdownHooks> 


    </broker> 


    <import resource="jetty.xml"/> 

</beans> 

Answer 1

वास्तविक समस्या एक बार पुनः प्रारंभ करने ActiveMQ सांत्वना हो रहा है। संदेश गायब नहीं हुए, कंसोल बस कुछ गलत दिखा रहा है।

Answer 2

आप संदेशों भर कायम पुन: प्रारंभ होता निर्माता उन्हें लगातार सेट करने के लिए है या दलाल उन्हें दृढ़ रहना नहीं होगा की जरूरत है। यदि आप ऊंट का उपयोग कर रूटिंग कर रहे हैं, तो मार्गों को ट्रांसएक्ट के रूप में चिह्नित किया जाना चाहिए या वे गायब हो जाएंगे। इसलिए ब्रोकर को टिकाऊ उपभोक्ताओं के बारे में बताया जा सकता है लेकिन संदेश तब तक जारी नहीं रहेंगे जब तक कि निर्माता (क्लाइंट) उन्हें भेजने से पहले उन्हें लगातार न रखें।

Answer 3

1. पंक्तियां पुनरारंभ करने के बाद भी संदेश जारी रहती हैं।
2. टिकाऊ विषय संदेश जारी रखते हैं लेकिन समस्या यह है कि कंसोल उनको नहीं दिखाएगा। एक बार जब आप सक्रिय एमक्यू को पुनरारंभ करेंगे तो आपके टिकाऊ ग्राहक इसे प्राप्त करेंगे।