docs: void sendMigrationEvent(final MigrationInfo migrationInfo, final MigrationEvent.MigrationStatus status) {
          if (migrationInfo.getSourceCurrentReplicaIndex() != 0
                  && migrationInfo.getDestinationNewReplicaIndex() != 0) {
              // only fire events for 0th replica migrations
              return;
          }
  
          ClusterServiceImpl clusterService = node.getClusterService();
          MemberImpl current = clusterService.getMember(migrationInfo.getSourceAddress());
          MemberImpl newOwner = clusterService.getMember(migrationInfo.getDestinationAddress());
          MigrationEvent event = new MigrationEvent(migrationInfo.getPartitionId(), current, newOwner, status);
          EventService eventService = nodeEngine.getEventService();
          Collection<EventRegistration> registrations = eventService.getRegistrations(SERVICE_NAME, MIGRATION_EVENT_TOPIC);
          eventService.publishEvent(SERVICE_NAME, registrations, event, event.getPartitionId());
      }