activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "yang.yang.zz" <yang.yang...@outlook.com>
Subject Re: Message stuck after failover [5.11.1, 5.13.0]
Date Sun, 10 Jan 2016 23:07:12 GMT
Configuration for node *A*



<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>

    
    
    
    
    <broker 
    	xmlns="http://activemq.apache.org/schema/core" 
    	brokerName="dc_broker_1d54f2fd-87f0-4b07-85bf-16475ce2cf5c" 
    	dataDirectory="${activemq.data}"
        useShutdownHook="false"
        useJmx="true">
        
        
        <destinationPolicy>
            <policyMap>

                <policyEntries>
					<policyEntry queue=">" producerFlowControl="true"
cursorMemoryHighWaterMark="30" memoryLimit="100M"/>
                    <policyEntry topic=">" producerFlowControl="false">
                        <subscriptionRecoveryPolicy>
                            <lastImageSubscriptionRecoveryPolicy/>
                        </subscriptionRecoveryPolicy>
                    </policyEntry>
                </policyEntries>
            </policyMap>

        </destinationPolicy>


        
        <managementContext>
            <managementContext createConnector="true"
connectorPort="11099"/>
        </managementContext>

		
        <networkConnectors>
            
            				  
		  <networkConnector name="da_manager"
uri="static:(failover:(tcp://yanya04-vertica1:61616,tcp://uspmscale1-da:61616)?randomize=false)"
duplex="true" suppressDuplicateTopicSubscriptions="false"/>
        </networkConnectors> 

        
        <persistenceAdapter>
            <kahaDB directory="${activemq.data}/kahadb"/>
        </persistenceAdapter>
        
        
        
        
        <systemUsage>
            <systemUsage sendFailIfNoSpace="true">
                <memoryUsage>
					
                 	<memoryUsage percentOfJvmHeap="70" />
                </memoryUsage>
                <tempUsage>
                	
                	
                    <tempUsage limit="200 gb"/>
                </tempUsage>                
            </systemUsage>
        </systemUsage>

        
        <transportConnectors>
            
            <transportConnector name="openwire"
uri="tcp://0.0.0.0:61616?maximumConnections=100&amp;wireFormat.maxFrameSize=104857600"/>
        </transportConnectors>

        <plugins>
        	<statisticsBrokerPlugin/>
        </plugins>

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

</beans>




--
View this message in context: http://activemq.2283324.n4.nabble.com/Message-stuck-after-failover-5-11-1-5-13-0-tp4705730p4705733.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message