BUG-5280: add SimpleDataStoreClientBehavior

[controller.git] / opendaylight / md-sal / cds-access-client / src / main / java / org / opendaylight / controller / cluster / access / client / AbstractReceivingClientConnection.java

diff --git a/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/AbstractReceivingClientConnection.java b/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/AbstractReceivingClientConnection.java
index 180ac942a361b034eb3ee41078ef7b5f39519649..85ca5fee65e0ea86e11c9d53d5c0fcbc23fa0066 100644 (file)
--- a/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/AbstractReceivingClientConnection.java
+++ b/opendaylight/md-sal/cds-access-client/src/main/java/org/opendaylight/controller/cluster/access/client/AbstractReceivingClientConnection.java
@@ -108,7 +108,10 @@ abstract class AbstractReceivingClientConnection<T extends BackendInfo> extends
         }
 
         lastProgress = readTime();
-        maybeEntry.get().complete(envelope.getMessage());
+
+        final TransmittedConnectionEntry entry = maybeEntry.get();
+        LOG.debug("Completing {} with {}", entry, envelope);
+        entry.complete(envelope.getMessage());
 
         // We have freed up a slot, try to transmit something
         final int toSend = remoteMaxMessages() - inflight.size();