Thanks. Mine is working now. It looks like the one major difference is the zk session timeout. I was using the default, and you had it set to 5 seconds. However, I am still seeing exceptions such as this one: "java.lang.RuntimeException: An IOException was thrown (should never happen in this method).”
Is your broker running pretty clean when you send messages through the fabric of network of replicated master/slaves? Kevin From: "James A. Robinson-2 [via ActiveMQ]" <ml-node+s2283324n4694097...@n4.nabble.com<mailto:ml-node+s2283324n4694097...@n4.nabble.com>> Date: Monday, March 30, 2015 at 5:29 PM To: SNEI <kevin...@am.sony.com<mailto:kevin...@am.sony.com>> Subject: Re: Creating a Network of Replicated LevelDB broker clusters On Mon, Mar 30, 2015 at 4:57 PM, wonderkind <[hidden email]</user/SendEmail.jtp?type=node&node=4694097&i=0>> wrote: > Do you have a sample activemq.xml configuration file you could share for your 3 x 3 cluster? I am trying to do the same, with everything running on my Mac initially. On the amq-prod-1 cluster my network connector url is masterslave:(tcp://amq-prod-2a:61616,tcp://amq-prod-2b:61616,tcp://amq-prod-2c:61616) On the amq-prod-2 cluster my network connector url is: masterslave:(tcp://amq-prod-1a:61616,tcp://amq-prod-1b:61616,tcp://amq-prod-1c:61616) The following are the messages I get in my log: 2015-03-30 17:38:00,236 [ActiveMQ Task-1] INFO DiscoveryNetworkConnector - Establishing network connection from vm://amq-prod-1?async=false&network=true to failover:(tcp://amq-prod-2a:61616,tcp://amq-prod-2b:61616,tcp://amq-prod-2c:61616)?randomize=false&maxReconnectAttempts=0 2015-03-30 17:38:00,450 [ActiveMQ Task-1] INFO FailoverTransport - Successfully connected to tcp://amq-prod-2b:61616 2015-03-30 17:38:00,767 [//amq-prod-1#42] INFO DemandForwardingBridgeSupport - Network connection between vm://amq-prod-1#42 and tcp://amq-prod-2b:61616 (amq-prod-2) has been established. Here's a full example of the config: <?xml version="1.0"?> <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";> <!-- Allow the use of system properties as variables in this configuration file --> <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-prod-1"> <managementContext> <!-- http://activemq.apache.org/jmx.html --> <!-- Do not use the legacy JMX Connector. --> <managementContext createConnector="false" /> </managementContext> <persistenceAdapter> <!-- http://activemq.apache.org/replicated-leveldb-store.html --> <replicatedLevelDB replicas="3" zkSessionTimeout="5s" zkPath="/activemq/amq-prod-1" zkAddress="zk1.example.org:2181,zk2.example.org:2182,zk3.example.org:2181, zk4.example.org:2181,zk5.example.org:2181,zk6.example.org:2181" /> </persistenceAdapter> <plugins> <!-- http://activemq.apache.org/statisticsplugin.html --> <statisticsBrokerPlugin/> </plugins> <!-- http://activemq.apache.org/producer-flow-control.html --> <systemUsage> <systemUsage> <memoryUsage> <memoryUsage percentOfJvmHeap="70"/> </memoryUsage> <storeUsage> <storeUsage limit="6 gb"/> </storeUsage> <tempUsage> <tempUsage limit="2 gb"/> </tempUsage> </systemUsage> </systemUsage> <!-- http://activemq.apache.org/producer-flow-control.html --> <!-- http://activemq.apache.org/message-cursors.html --> <destinationPolicy> <policyMap> <policyEntries> <policyEntry topic=">" memoryLimit="1mb"> </policyEntry> <policyEntry queue=">" memoryLimit="1mb" optimizedDispatch="true"> </policyEntry> </policyEntries> </policyMap> </destinationPolicy> <!-- http://activemq.apache.org/configuring-transports.html --> <transportConnectors> <transportConnector name="openwire" uri="nio://0.0.0.0:61616"/> <transportConnector name="stomp+nio" uri="stomp+nio://0.0.0.0:61613"/> <transportConnector name="amqp" uri="amqp+nio://0.0.0.0:5672"/> </transportConnectors> <!-- http://activemq.apache.org/networks-of-brokers.html --> <!-- networkTTL is based on the number of clusters networked together --> <networkConnectors> <networkConnector uri="masterslave:(tcp://amq-prod-2a:61616,tcp://amq-prod-2b:61616,tcp://amq-prod-2c:61616)" consumerTTL="1" messageTTL="-1" decreaseNetworkConsumerPriority="true" /> </networkConnectors> <shutdownHooks> <!-- Shut down the jetty based web console application. --> <bean xmlns="http://www.springframework.org/schema/beans"; class="org.apache.activemq.hooks.SpringContextHook"/> </shutdownHooks> </broker> <import resource="jetty.xml"/> </beans> ________________________________ If you reply to this email, your message will be added to the discussion below: http://activemq.2283324.n4.nabble.com/Creating-a-Network-of-Replicated-LevelDB-broker-clusters-tp4693979p4694097.html To unsubscribe from Creating a Network of Replicated LevelDB broker clusters, click here<http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=4693979&code=a2V2aW4uc3VAYW0uc29ueS5jb218NDY5Mzk3OXw5MzA0MDE1ODU=>. NAML<http://activemq.2283324.n4.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> -- View this message in context: http://activemq.2283324.n4.nabble.com/Creating-a-Network-of-Replicated-LevelDB-broker-clusters-tp4693979p4694154.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
