X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fcds-access-client%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Faccess%2Fclient%2FConnectedClientConnection.java;h=0afc7acf4945996e61e5996060a3b32424eba177;hb=80e6514d56cd4dc6aa40997dea2b460723148341;hp=cade27f77d6070c58df5cb80e0c9a920652cbf15;hpb=8265c26f7692086677fa943976824966f32eecf6;p=controller.git diff --git a/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/ConnectedClientConnection.java b/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/ConnectedClientConnection.java index cade27f77d..0afc7acf49 100644 --- a/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/ConnectedClientConnection.java +++ b/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/ConnectedClientConnection.java @@ -9,6 +9,7 @@ package org.opendaylight.controller.cluster.access.client; import com.google.common.annotations.Beta; import javax.annotation.concurrent.NotThreadSafe; +import org.opendaylight.controller.cluster.access.concepts.RequestException; @Beta @NotThreadSafe @@ -18,8 +19,8 @@ public final class ConnectedClientConnection extends Abst } @Override - ClientActorBehavior lockedReconnect(final ClientActorBehavior current) { - final ReconnectingClientConnection next = new ReconnectingClientConnection<>(this); + ClientActorBehavior lockedReconnect(final ClientActorBehavior current, final RequestException cause) { + final ReconnectingClientConnection next = new ReconnectingClientConnection<>(this, cause); setForwarder(new SimpleReconnectForwarder(next)); current.reconnectConnection(this, next); return current;