X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fcds-access-client%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fclient%2FAccessClientUtil.java;h=7521ed639e734f03cb27e217f0730bd863f8f51d;hb=72d71d1cded60bcac65296211272754006b3f89a;hp=586fb591eb30f8a33d5c13399c067d173c09c240;hpb=94362614be25e34e8427c02799daffb8cae29d94;p=controller.git diff --git a/opendaylight/md-sal/cds-access-client/src/test/java/org/opendaylight/controller/cluster/access/client/AccessClientUtil.java b/opendaylight/md-sal/cds-access-client/src/test/java/org/opendaylight/controller/cluster/access/client/AccessClientUtil.java index 586fb591eb..7521ed639e 100644 --- a/opendaylight/md-sal/cds-access-client/src/test/java/org/opendaylight/controller/cluster/access/client/AccessClientUtil.java +++ b/opendaylight/md-sal/cds-access-client/src/test/java/org/opendaylight/controller/cluster/access/client/AccessClientUtil.java @@ -22,13 +22,15 @@ import org.opendaylight.controller.cluster.access.concepts.ResponseEnvelope; /** * Util class to access package private members in cds-access-client for test purposes. */ -public class AccessClientUtil { +public final class AccessClientUtil { + private AccessClientUtil() { + throw new UnsupportedOperationException(); + } public static ClientActorContext createClientActorContext(final ActorSystem system, final ActorRef actor, final ClientIdentifier id, final String persistenceId) { - return spy(new ClientActorContext(actor, system.scheduler(), system.dispatcher(), persistenceId, id, - newMockClientActorConfig())); + return spy(new ClientActorContext(actor, persistenceId, system, id, newMockClientActorConfig())); } public static ClientActorConfig newMockClientActorConfig() { @@ -45,7 +47,8 @@ public class AccessClientUtil { public static ConnectedClientConnection createConnectedConnection( final ClientActorContext context, final Long cookie, final T backend) { - return new ConnectedClientConnection<>(context, cookie, backend); + return new ConnectedClientConnection<>(new ConnectingClientConnection<>(context, cookie, backend.getName()), + backend); } public static void completeRequest(final AbstractClientConnection connection,