2016-04-15 44 views
1

我想在兩個節點中集成WSO2 Message Broker 3.1.0。 我通過改變存儲庫/ conf目錄/ Axis2的/ axis2.xml文件中配置這兩個節點:WSO2 Message Broker,此節點現在不是插槽協調器

<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> 

的第一個節點的工作沒有問題,但是當我推出第二點,我得到的消息:

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) 

回答

1

請確保您已按照以下步驟操作。在庫/ conf目錄/ broker.xml

  • 更新IP地址

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> 
  • 更新下面的兩個節點hazelcast性能。庫/ 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> 

希望這會幫助你。

相關問題