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

Убедитесь, что вы выполнили следующие шаги.

  • IP-адрес в Обновление хранилища/CONF/broker.xml

МВ1

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

МБ1

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

Надеется, что это поможет вам.

 Смежные вопросы

  • Нет связанных вопросов^_^