public interface

HelixIPCService

org.apache.helix.ipc.HelixIPCService
Known Indirect Subclasses

Class Overview

Allows message passing among instances in Helix clusters.

Messages are sent asynchronously using send(HelixAddress, int, UUID, ByteBuf), and handled by callbacks registered via registerCallback(int, HelixIPCCallback)

Summary

Constants
String IPC_PORT
Public Methods
abstract void registerCallback(int messageType, HelixIPCCallback callback)
Registers a callback for a given message type
abstract void send(HelixAddress destination, int messageType, UUID messageId, ByteBuf message)
Sends a message to one or more instances that map to a cluster scope.
abstract void shutdown()
Shuts down service and releases any resources
abstract void start()
Starts service (must call before send(HelixAddress, int, UUID, ByteBuf))

Constants

public static final String IPC_PORT

Constant Value: "IPC_PORT"

Public Methods

public abstract void registerCallback (int messageType, HelixIPCCallback callback)

Registers a callback for a given message type

public abstract void send (HelixAddress destination, int messageType, UUID messageId, ByteBuf message)

Sends a message to one or more instances that map to a cluster scope.

public abstract void shutdown ()

Shuts down service and releases any resources

Throws
Exception

public abstract void start ()

Starts service (must call before send(HelixAddress, int, UUID, ByteBuf))

Throws
Exception