Github user gaohoward commented on a diff in the pull request:

    https://github.com/apache/activemq-artemis/pull/1999#discussion_r180279022
  
    --- Diff: 
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/TopologyMemberImpl.java
 ---
    @@ -105,12 +105,16 @@ public void setUniqueEventID(final long 
uniqueEventID) {
           return connector;
        }
     
    +   /**
    +    * We only need to check if the connection point to the same node,
    +    * don't need to compare the whole params map.
    +    * @param connection The connection to the target node
    +    * @return true if the connection point to the same node
    +    * as this member represents.
    +    */
        @Override
        public boolean isMember(RemotingConnection connection) {
    -      TransportConfiguration connectorConfig = 
connection.getTransportConnection() != null ? 
connection.getTransportConnection().getConnectorConfig() : null;
    -
    -      return isMember(connectorConfig);
    -
    +      return connection.isSameTarget(getConnector().getA(), 
getConnector().getB());
    --- End diff --
    
    ok, I'll fix the isMember() and put some context.


---

Reply via email to