HazelcastAPI AbstractJetMessageTask Sınıfı - Member Üzerindeki Client Thread Çalıştırır

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.impl.client.protocol.task.AbstractJetMessageTask;

getInvocationBuilder metodu

Kodu şöyle

@Override
protected InvocationBuilder getInvocationBuilder(Operation operation) {
  Address address;
  if (getLightJobCoordinator() != null) {
    MemberImpl member = nodeEngine.getClusterService().getMember(getLightJobCoordinator());
    if (member == null) {
      throw new TopologyChangedException("Light job coordinator left the cluster");
    }
    address = member.getAddress();
  } else {
    address = nodeEngine.getMasterAddress();
    if (address == null) {
      throw new RetryableHazelcastException("master not yet known");
    }
  }
  return nodeEngine.getOperationService()
    .createInvocationBuilder(JetServiceBackend.SERVICE_NAME,
    operation, address);
}