activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From wonderkind <kevin...@am.sony.com>
Subject Re: Creating a Network of Replicated LevelDB broker clusters
Date Tue, 31 Mar 2015 19:08:15 GMT
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+s2283324n4694097h66@n4.nabble.com<mailto:ml-node+s2283324n4694097h66@n4.nabble.com>>
Date: Monday, March 30, 2015 at 5:29 PM
To: SNEI <kevin.su@am.sony.com<mailto:kevin.su@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.
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message