.class);   }    //re-subscribe when restart   @Override   public void postStop() {     cluster.unsubscribe(getSelf());   }    @Override   public Receive createReceive() {     return receiveBuilder()       .match(TransformationJob.class, job -> {         