X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fclient%2FAccessClientUtil.java;h=987b90c57272dd9af821b175657462fbb6a0dc18;hp=9929b402ca94e8d1a3a924126198bfd4e7e59338;hb=df34f194596eed9494f64a691bec244be70c2a5e;hpb=f5fcfe86c7baeea72b81886e01215840fbf1b91b diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/access/client/AccessClientUtil.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/access/client/AccessClientUtil.java index 9929b402ca..987b90c572 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/access/client/AccessClientUtil.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/access/client/AccessClientUtil.java @@ -9,7 +9,10 @@ package org.opendaylight.controller.cluster.access.client; import akka.actor.ActorRef; import akka.actor.ActorSystem; +import java.util.function.Consumer; import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier; +import org.opendaylight.controller.cluster.access.concepts.Request; +import org.opendaylight.controller.cluster.access.concepts.Response; import org.opendaylight.controller.cluster.access.concepts.ResponseEnvelope; /** @@ -32,4 +35,10 @@ public class AccessClientUtil { connection.receiveResponse(envelope); } + public static ConnectionEntry createConnectionEntry(final Request request, + final Consumer> callback, + final long now) { + return new ConnectionEntry(request, callback, now); + } + } \ No newline at end of file