import static java.util.Objects.requireNonNull;
import akka.actor.typed.ActorRef;
+import akka.pattern.StatusReply;
import java.io.Serializable;
import org.eclipse.jdt.annotation.NonNull;
-abstract class OwnerSupervisorRequest<T extends OwnerSupervisorReply> extends OwnerSupervisorCommand
+public abstract class OwnerSupervisorRequest<T extends OwnerSupervisorReply> extends OwnerSupervisorCommand
implements Serializable {
private static final long serialVersionUID = 1L;
- private final @NonNull ActorRef<T> replyTo;
+ private final @NonNull ActorRef<StatusReply<T>> replyTo;
- OwnerSupervisorRequest(final ActorRef<T> replyTo) {
+ OwnerSupervisorRequest(final ActorRef<StatusReply<T>> replyTo) {
this.replyTo = requireNonNull(replyTo);
}
- public final @NonNull ActorRef<T> getReplyTo() {
+ public final @NonNull ActorRef<StatusReply<T>> getReplyTo() {
return replyTo;
}
}