2 Replies Latest reply on Nov 21, 2012 1:59 AM by mandarbk

    Multiple Clusters on the same network

    mandarbk

      I have multiple clusters on the same network (LAN).

      Currently, I am facing an issue with HornetQ configuration,

       

       

      ERROR (Thread-11 (HornetQ-client-global-threads-1319079009)) 2012-11-20 15:08:40,953 [org.hornetq.core.server.cluster.impl.ClusterConnectionImpl] HornetQLoggerFactory$HornetQLogDelegate Failed to handle message: java.lang.IllegalStateException: Cannot find binding for 5ea6ba12-ab4b-4a0a-bf18-c2e52e852573e8370d59-3323-11e2-a6c0-005056a1003a on ClusterConnectionImpl@198385039[nodeUUID=e8370d59-3323-11e2-a6c0-005056a1003a, connector=org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5445&host=0-0-0-0, address=jms, server=HornetQServerImpl::serverUUID=e8370d59-3323-11e2-a6c0-005056a1003a]

                at org.hornetq.core.server.cluster.impl.ClusterConnectionImpl$MessageFlowRecordImpl.doConsumerCreated(ClusterConnectionImpl.java:1458) [hornetq-core-2.2.13.Final.jar:]

                at org.hornetq.core.server.cluster.impl.ClusterConnectionImpl$MessageFlowRecordImpl.onMessage(ClusterConnectionImpl.java:1225) [hornetq-core-2.2.13.Final.jar:]

                at org.hornetq.core.client.impl.ClientConsumerImpl.callOnMessage(ClientConsumerImpl.java:983) [hornetq-core-2.2.13.Final.jar:]

                at org.hornetq.core.client.impl.ClientConsumerImpl.access$400(ClientConsumerImpl.java:48) [hornetq-core-2.2.13.Final.jar:]

                at org.hornetq.core.client.impl.ClientConsumerImpl$Runner.run(ClientConsumerImpl.java:1113) [hornetq-core-2.2.13.Final.jar:]

                at org.hornetq.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:100) [hornetq-core-2.2.13.Final.jar:]

                at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) [rt.jar:1.7.0_07]

                at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) [rt.jar:1.7.0_07]

                at java.lang.Thread.run(Unknown Source) [rt.jar:1.7.0_07]

       

       

      Is there any documentation that explains all the steps/problems we can encounter when we are trying to setup multiple clusters on the same network ?

        • 1. Re: Multiple Clusters on the same network
          rhusar

          Not sure how HornetQ is handling this, but judging from AS7 clustering view point: did you specify different UDP groups (or ports) for the clusters?

          • 2. Re: Multiple Clusters on the same network
            mandarbk

            I was able to resolve the problem, by making sure that every cluster has a unique value for [broadcast-group -- group-address] and [discovery-group -- group-address]

             

            <broadcast-groups>

                            <broadcast-group name="bg-config">

                                <local-bind-port>9877</local-bind-port>

                                <group-address>224.1.22.1</group-address>

                                <group-port>9876</group-port>

                                <broadcast-period>5000</broadcast-period>

                                <connector-ref>

                                    netty

                                </connector-ref>

                            </broadcast-group>

                        </broadcast-groups>


                        <discovery-groups>

                            <discovery-group name="dg-config">

                                <group-address>224.1.22.1</group-address>

                                <group-port>9876</group-port>

                                <refresh-timeout>10000</refresh-timeout>

                            </discovery-group>

                        </discovery-groups>


                        <cluster-connections>

                            <cluster-connection name="config-cluster">

                                <address>jms</address>

                                <connector-ref>netty</connector-ref>

                                <forward-when-no-consumers>true</forward-when-no-consumers>

                                <max-hops>1</max-hops>

                                <discovery-group-ref discovery-group-name="dg-config"/>

                            </cluster-connection>

                        </cluster-connections>