Hello Ladies and Gentlemen, Having a problem using the failover protocol to connect to another broker when the connection to the current broker dies. The client is taking a long time about 1min and 15 seconds to failover to another known broker. Is there are configuration options i can use to improve this such that clients failover faster?
I've tried using the backup=true on client connection but that makes no difference! Using activeMq 5.8 three brokers using static network protocol all three brokers create duplex connection to each other. Were using update configuration properties: updateClusterClients="true" rebalanceClusterClients="true" updateClusterClientsOnRemove="true" So we can scale and rebalance the cluster at will depending on demand. Clients are connecting with configuration uri: failover:(tcp://" + brokerIp + ":61616)?useExponentialBackOff=false&updateURIsSupported=true Sample config from one brokers: <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"; useJmx="true" brokerName="amq-node-1" dataDirectory="${activemq.data}" networkConnectorStartAsync="true"> <destinationPolicy> <policyMap> <policyEntries> <policyEntry topic=">" producerFlowControl="true"> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="100000"/> </pendingMessageLimitStrategy> </policyEntry> <policyEntry queue=">" producerFlowControl="true" queuePrefetch="1"> <pendingMessageLimitStrategy> <constantPendingMessageLimitStrategy limit="100000"/> </pendingMessageLimitStrategy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy> <managementContext> <managementContext createConnector="true"/> </managementContext> <persistenceAdapter> <kahaDB directory="${activemq.data}/kahadb" indexCacheSize="131072"/> </persistenceAdapter> <systemUsage> <systemUsage> <memoryUsage> <memoryUsage limit="2 gb"/> </memoryUsage> <storeUsage> <storeUsage limit="50 gb"/> </storeUsage> <tempUsage> <tempUsage limit="20 gb"/> </tempUsage> </systemUsage> </systemUsage> <networkConnectors> <networkConnector name="amq-node-1-amq-node-3-queuesOnly" uri="static:(tcp://172.27.1.137:61616?connectionTimeout=5000)?maxReconnectDelay=5000" networkTTL="1" conduitSubscriptions="false" duplex="true"> <dynamicallyIncludedDestinations> <queue physicalName=">"/> </dynamicallyIncludedDestinations> </networkConnector> <networkConnector name="amq-node-1-amq-node-3-topicsOnly" uri="static:(tcp://172.27.1.137:61616?connectionTimeout=5000)?maxReconnectDelay=5000" networkTTL="1" suppressDuplicateQueueSubscriptions="true" duplex="true"> <dynamicallyIncludedDestinations> <topic physicalName=">"/> </dynamicallyIncludedDestinations> </networkConnector> <networkConnector name="amq-node-1-amq-node-2-queuesOnly" uri="static:(tcp://172.27.1.113:61616?connectionTimeout=5000)?maxReconnectDelay=5000" networkTTL="1" conduitSubscriptions="false" duplex="true"> <dynamicallyIncludedDestinations> <queue physicalName=">"/> </dynamicallyIncludedDestinations> </networkConnector> <networkConnector name="amq-node-1-amq-node-2-topicsOnly" uri="static:(tcp://172.27.1.113:61616?connectionTimeout=5000)?maxReconnectDelay=5000" networkTTL="1" suppressDuplicateQueueSubscriptions="true" duplex="true"> <dynamicallyIncludedDestinations> <topic physicalName=">"/> </dynamicallyIncludedDestinations> </networkConnector> </networkConnectors> <transportConnectors> <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireformat.maxFrameSize=104857600" updateClusterClients="true" rebalanceClusterClients="true" updateClusterClientsOnRemove="true" /> <transportConnector name="stomp" uri="stomp://0.0.0.0:61613"/> </transportConnectors> <shutdownHooks> <bean xmlns="http://www.springframework.org/schema/beans"; class="org.apache.activemq.hooks.SpringContextHook" /> </shutdownHooks> <plugins> <statisticsBrokerPlugin/> </plugins> </broker> <import resource="jetty.xml"/> </beans> Any help would be greatly appreciated. Thank you Tom Parkinson -- View this message in context: http://activemq.2283324.n4.nabble.com/Slow-Failover-tp4666393.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
