2016-04-15 47 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> 

希望这会帮助你。

相关问题