private void registerHandlers ( ) { // Register TCP message handlers. bootstrapService . getMessagingService ( ) . registerHandler ( MEMBERSHIP_SYNC , syncHandler , swimScheduler ) ; bootstrapService . getMessagingService ( ) . registerHandler ( MEMBERSHIP_PROBE , probeHandler , swimScheduler ) ; bootstrapService . getMessagingService ( ) . registerHandler ( MEMBERSHIP_PROBE_REQUEST , probeRequestHandler ) ; // Register UDP message listeners. bootstrapService . getUnicastService ( ) . addListener ( MEMBERSHIP_GOSSIP , gossipListener , swimScheduler ) ; }
Registers message handlers for the SWIM protocol .