X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActorContext.java;fp=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActorContext.java;h=e971ed4f6de95d5d53d02e7eeb9d3d6c89628db6;hp=b5f3afdc16839252f2f2069986e3ef5955c995ae;hb=7daddd72031b33ed686abe18a0813e41263aac8d;hpb=096e92fc0595f6f87db4b681b0fe9cdeeb365164 diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContext.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContext.java index b5f3afdc16..e971ed4f6d 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContext.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorContext.java @@ -15,6 +15,7 @@ import akka.cluster.Cluster; import com.google.common.annotations.VisibleForTesting; import java.util.Collection; import java.util.Optional; +import java.util.concurrent.Executor; import java.util.function.Consumer; import java.util.function.LongSupplier; import org.eclipse.jdt.annotation.NonNull; @@ -64,6 +65,13 @@ public interface RaftActorContext { */ ActorRef getActor(); + /** + * Return an Executor which is guaranteed to run tasks in the context of {@link #getActor()}. + * + * @return An executor. + */ + @NonNull Executor getExecutor(); + /** * The akka Cluster singleton for the actor system if one is configured. *