Here is an example from Pinot. https://github.com/linkedin/pinot/blob/7fe310f3eb20dcac0bb5e8d39a21894fdae2b5ee/pinot-server/src/main/java/com/linkedin/pinot/server/starter/helix/SegmentMessageHandlerFactory.java
// Register message handler factory SegmentMessageHandlerFactory messageHandlerFactory = new SegmentMessageHandlerFactory(fetcherAndLoader, _serverInstance. getInstanceDataManager()); _helixManager.getMessagingService() .registerMessageHandlerFactory(Message.MessageType.USER_DEFINE_MSG.toString(), messageHandlerFactory); On Sat, Oct 6, 2018 at 7:51 AM Rob McKinnon <[email protected]> wrote: > Is there a good example available for Cluster Messaging? The tutorial > demonstrated how to send a message but didn't didn't go into detail about > how to receive a message. Specifically, I am looking on how to send and > receive user defined cluster messages. > > Thanks, > > Rob >
