public static Message buildNewEpochMessage ( long epoch , int syncTimeoutMs ) { NewEpoch nEpoch = NewEpoch . newBuilder ( ) . setNewEpoch ( epoch ) . setSyncTimeout ( syncTimeoutMs ) . build ( ) ; return Message . newBuilder ( ) . setType ( MessageType . NEW_EPOCH ) . setNewEpoch ( nEpoch ) . build ( ) ; }
Creates a NEW_EPOCH message .