WSO2 Message Broker, Dieser Knoten ist im Moment nicht der Slot Coordinator

Question

Ich möchte meinen WSO2 Message Broker 3.1.0 in zwei Knoten zusammenfassen. ich konfiguriert diese beiden Knoten durch das Repository/conf/axis2/axis2.xml Datei zu ändern:

ohne Problem

<parameter name="localMemberHost">10.0.0.43</parameter> 

<parameter name="membershipScheme">wka</parameter> 
<clustering class="org.wso2.carbon.core.clustering.hazelcast.HazelcastClusteringAgent" 
      enable="true"> 


<members> 
     <member> 
      <hostName>10.0.0.45</hostName> 
      <port>4000</port> 
     </member> 
    </members> 

den ersten Knoten arbeiten, aber wenn ich den zweiten Knoten zu starten, erhalte ich die Meldung:

ERROR {org.apache.thrift.ProcessFunction} - Internal error processing updateCurrentMessageIdForSafeZone org.apache.thrift.TException: This node is not the slot coordinator right now 
    at org.wso2.andes.thrift.SlotManagementServiceImpl.updateCurrentMessageIdForSafeZone(SlotManagementServiceImpl.java:110) 

Answer 1

Vergewissern Sie sich, dass Sie die folgenden Schritte ausgeführt haben.

• Update-IP-Adresse im Repository/conf/broker.xml

MB1

<!-- Thrift is used to maintain and sync slot (message groups) ranges between MB nodes. --> 
     <thriftServerHost>10.0.0.43</thriftServerHost> 

MB2

<!-- Thrift is used to maintain and sync slot (message groups) ranges between MB nodes. --> 
     <thriftServerHost>10.0.0.45</thriftServerHost> 

• aktualisieren unten Eigenschaften in Hazelcast beiden Knoten. Repository/conf/axis2/axis2.xml

MB1

<clustering class="org.wso2.carbon.core.clustering.hazelcast.HazelcastClusteringAgent" 
       enable="true"> 
<parameter name="membershipScheme">wka</parameter> 

<parameter name="localMemberHost">10.0.0.43</parameter> 

<members> 
      <member> 
       <hostName>10.0.0.45</hostName> 
       <port>4000</port> 
      </member> 
     </members> 

MB2

<clustering class="org.wso2.carbon.core.clustering.hazelcast.HazelcastClusteringAgent" 
       enable="true"> 
<parameter name="membershipScheme">wka</parameter> 

<parameter name="localMemberHost">10.0.0.45</parameter> 

<members> 
      <member> 
       <hostName>10.0.0.43</hostName> 
       <port>4000</port> 
      </member> 
     </members> 

Hope this Sie helfen würde.