Examples of org.apache.helix.ipc.netty.NettyHelixIPCService.send()

Class org.apache.helix.ipc.netty.NettyHelixIPCService

Examples of org.apache.helix.ipc.netty.NettyHelixIPCService.send()

org.apache.helix.ipc.netty.NettyHelixIPCService.send()
Sends a message to all partitions with a given state in the cluster.

                .resource(RESOURCE_NAME).partition(partitionName).state("ONLINE").build();


        Set<HelixAddress> destinations = secondResolver.getDestinations(scope);
        for (HelixAddress destination : destinations) {
          ByteBuf message = Unpooled.wrappedBuffer(("Hello" + i).getBytes());
          secondIPC.send(destination, messageType, UUID.randomUUID(), message);
        }
      }
    }


    // Check

View Full Code Here


      @Override
      public void onMessage(HelixMessageScope scope, UUID messageId, ByteBuf message) {
        if (random.nextInt() % 2 == 0) {
          HelixAddress sender = firstResolver.getSource(scope);
          firstIPC.send(sender, ackMessageType, messageId, null);
        }
      }
    });
    firstIPC.start();

View Full Code Here


      @Override
      public void onMessage(HelixMessageScope scope, UUID messageId, ByteBuf message) {
        if (random.nextInt() % 2 == 0) {
          HelixAddress sender = secondResolver.getSource(scope);
          secondIPC.send(sender, ackMessageType, messageId, null);
        }
      }
    });
    secondIPC.start();

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.