You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by jraju <j....@gmail.com> on 2019/02/10 17:50:37 UTC

Artemis (AMQ7.2) Symmetric Cluster with Multi-Server - Replication not working

Hi,

I am trying a Symmetric cluster with Multi server environment (all nodes
active) where JGroups is used for discovery & broadcast. The JGroup ping
file is pointed to a shared file location.

I think the cluster is forming fine, but messages produced in Node1 is not
routed to the only consumer available in Node2. Please refer the Node2
Cluster connectivity logs.

One key thing to note is, both the clusters have taken the same NodeUUID. I
know I am missing something basic, but not getting the correct direction.

2019-02-10 16:49:14,289 DEBUG
[org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl]
Reconnection successful
2019-02-10 16:49:14,346 DEBUG
[org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl]
ClientSessionFactoryImpl received backup update for live/backup pair =
TransportConfiguration(name=node1-connector,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=<node2IP> / null but it didn't belong to
TransportConfiguration(name=node1-connector,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=<node2IP>
2019-02-10 16:49:14,527 DEBUG
[org.apache.activemq.artemis.core.server.cluster.impl.ClusterConnectionImpl]
ClusterConnectionImpl@283039401[nodeUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6,
connector=TransportConfiguration(name=node1-connector,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=<node1IP>, address=,
server=ActiveMQServerImpl::serverUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6]receiving
nodeUP for nodeID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6
connectionPair=TopologyMember[id = 2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6,
connector=Pair[a=TransportConfiguration(name=node1-connector,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=<node1IP>, b=null], backupGroupName=null,
scaleDownGroupName=null]
2019-02-10 16:49:14,606 INFO 
[org.apache.activemq.artemis.core.server.plugin.impl] AMQ841000: created
connection: RemotingConnectionImpl [ID=e9c30c78, clientID=null,
nodeID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6,
transportConnection=org.apache.activemq.artemis.core.remoting.impl.netty.NettyServerConnection@74033d2f[ID=e9c30c78,
local= /<node1IP>:61616, remote=/<node2IP>:54652]]
2019-02-10 16:49:14,619 DEBUG
[org.apache.activemq.artemis.core.client.impl.Topology]
Topology@17a1e4ca[owner=ClusterConnectionImpl@283039401[nodeUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6,
connector=TransportConfiguration(name=node1-connector,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=<node1IP>, address=,
server=ActiveMQServerImpl::serverUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6]]
is sending topology to Remote Proxy on channel 6061112f
2019-02-10 16:49:14,620 DEBUG
[org.apache.activemq.artemis.core.client.impl.Topology]
Topology@17a1e4ca[owner=ClusterConnectionImpl@283039401[nodeUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6,
connector=TransportConfiguration(name=node1-connector,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=<node1IP>, address=,
server=ActiveMQServerImpl::serverUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6]]
sending 2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6 /
Pair[a=TransportConfiguration(name=node1-connector,
factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
?port=61616&host=<node1IP>, b=null] to Remote Proxy on channel 6061112f

Thanks.
Raju J



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Artemis (AMQ7.2) Symmetric Cluster with Multi-Server - Replication not working

Posted by jraju <j....@gmail.com>.
Thanks very much clebertsuconic.

Yes, my mistake . I had an AWS Image which has the broker created in it,
hence this issue. Have now changed the scripts to create the broker while
provisioning the actual server instance, so that new Uid gets created every
time.

Thanks Again!!



--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Artemis (AMQ7.2) Symmetric Cluster with Multi-Server - Replication not working

Posted by Clebert Suconic <cl...@gmail.com>.
I bet you copied the data between the two modes.  Don’t do that.


The NodeID is an uuid.  You can only duplicate it if you copied the data.


Remove the journals and restart your tests.

If you have real data you need to keep (queue created for instance) remove
the lock files. And keep everything else.

On Mon, Feb 11, 2019 at 3:32 PM jraju <j....@gmail.com> wrote:

> Hi,
>
> I am trying a Symmetric cluster with Multi server environment (all nodes
> active) where JGroups is used for discovery & broadcast. The JGroup ping
> file is pointed to a shared file location.
>
> I think the cluster is forming fine, but messages produced in Node1 is not
> routed to the only consumer available in Node2. Please refer the Node2
> Cluster connectivity logs.
>
> One key thing to note is, both the clusters have taken the same NodeUUID. I
> know I am missing something basic, but not getting the correct direction.
>
> 2019-02-10 16:49:14,289 DEBUG
> [org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl]
> Reconnection successful
> 2019-02-10 16:49:14,346 DEBUG
> [org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl]
> ClientSessionFactoryImpl received backup update for live/backup pair =
> TransportConfiguration(name=node1-connector,
>
> factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
> ?port=61616&host=<node2IP> / null but it didn't belong to
> TransportConfiguration(name=node1-connector,
>
> factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
> ?port=61616&host=<node2IP>
> 2019-02-10 16:49:14,527 DEBUG
>
> [org.apache.activemq.artemis.core.server.cluster.impl.ClusterConnectionImpl]
> ClusterConnectionImpl@283039401
> [nodeUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6,
> connector=TransportConfiguration(name=node1-connector,
>
> factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
> ?port=61616&host=<node1IP>, address=,
>
> server=ActiveMQServerImpl::serverUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6]receiving
> nodeUP for nodeID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6
> connectionPair=TopologyMember[id = 2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6,
> connector=Pair[a=TransportConfiguration(name=node1-connector,
>
> factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
> ?port=61616&host=<node1IP>, b=null], backupGroupName=null,
> scaleDownGroupName=null]
> 2019-02-10 16:49:14,606 INFO
> [org.apache.activemq.artemis.core.server.plugin.impl] AMQ841000: created
> connection: RemotingConnectionImpl [ID=e9c30c78, clientID=null,
> nodeID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6,
>
> transportConnection=org.apache.activemq.artemis.core.remoting.impl.netty.NettyServerConnection@74033d2f
> [ID=e9c30c78,
> local= /<node1IP>:61616, remote=/<node2IP>:54652]]
> 2019-02-10 16:49:14,619 DEBUG
> [org.apache.activemq.artemis.core.client.impl.Topology]
> Topology@17a1e4ca[owner=ClusterConnectionImpl@283039401
> [nodeUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6,
> connector=TransportConfiguration(name=node1-connector,
>
> factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
> ?port=61616&host=<node1IP>, address=,
>
> server=ActiveMQServerImpl::serverUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6]]
> is sending topology to Remote Proxy on channel 6061112f
> 2019-02-10 16:49:14,620 DEBUG
> [org.apache.activemq.artemis.core.client.impl.Topology]
> Topology@17a1e4ca[owner=ClusterConnectionImpl@283039401
> [nodeUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6,
> connector=TransportConfiguration(name=node1-connector,
>
> factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
> ?port=61616&host=<node1IP>, address=,
>
> server=ActiveMQServerImpl::serverUUID=2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6]]
> sending 2d1a2525-2aeb-11e9-a24f-02ee0bbe6df6 /
> Pair[a=TransportConfiguration(name=node1-connector,
>
> factory=org-apache-activemq-artemis-core-remoting-impl-netty-NettyConnectorFactory)
> ?port=61616&host=<node1IP>, b=null] to Remote Proxy on channel 6061112f
>
> Thanks.
> Raju J
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>
-- 
Clebert Suconic