2016-06-24 32 views
6

我是新来的活动MQ。安装了activemq 5.13.2。在activeMQ服务器重新启动后,我正在丢失所有消息(包括持久主题)。请在激活的MQ服务器重新启动之前和之后找到以下控制台屏幕截图。重新启动后ActiveMQ 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> 
+1

消息是否标记为永久? (请参阅http://activemq.apache.org/why-do-i-not-receive-messages-on-my-durable-topic-subscription.html) – mjn

+0

正如@mjn所述 - 消息在默认情况下是非持久性的,如果从Web控制台发送。对于从应用程序发送的消息,请仔细检查您的代码 –

+0

您确定在重新启动后不会因为任何原因清除了“$ {activemq.data}/kahadb”目录吗? – yegodm

回答

1

真正的问题似乎是重新启动后的ActiveMQ的控制台。消息并没有消失,控制台似乎只是显示了一些错误。

activemq console screenshot

0

如果你需要的信息持续跨越重启生产者必须将它们设置为持续性或经纪人不会坚持他们。如果您使用骆驼进行路由,则必须将路由标记为事务处理,否则它们也会消失。因此,可以告诉经纪人耐用消费者,但消息不会持续,除非生产者(客户)在发送之前将其标记为持久。

0
  1. 即使在重新启动后,队列仍然存在消息。
  2. 持久的主题持续的消息,但问题是控制台将不会显示这些。一旦你重新启动了activemq,你的耐用用户就会收到它。