From 01715f837a9425c4ece62cd74957dfb9826c3c6e Mon Sep 17 00:00:00 2001 From: Tomas Slusny Date: Thu, 26 Jan 2017 13:36:36 +0100 Subject: [PATCH] Add isComplete callback to commitEntry Implement commitEntry with isComplete callback from https://git.opendaylight.org/gerrit/#/c/51064/ to OpenflowPlugin OutboundQueueProviderImpl. See also: bug 7140 Change-Id: I7c4224e029f175a54b46246e1d409356f2447b16 Signed-off-by: Tomas Slusny --- .../impl/connection/OutboundQueueProviderImpl.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/connection/OutboundQueueProviderImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/connection/OutboundQueueProviderImpl.java index 8c03adc94b..ac1a084fda 100644 --- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/connection/OutboundQueueProviderImpl.java +++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/connection/OutboundQueueProviderImpl.java @@ -9,6 +9,7 @@ package org.opendaylight.openflowplugin.impl.connection; import com.google.common.util.concurrent.FutureCallback; +import java.util.function.Function; import javax.annotation.Nonnull; import org.opendaylight.openflowjava.protocol.api.connection.OutboundQueue; import org.opendaylight.openflowplugin.api.openflow.connection.OutboundQueueProvider; @@ -77,4 +78,10 @@ public class OutboundQueueProviderImpl implements OutboundQueueProvider { public void commitEntry(final Long xid, final OfHeader message, final FutureCallback callback) { outboundQueue.commitEntry(xid, message, callback); } + + @Override + public void commitEntry(final Long xid, final OfHeader message, final FutureCallback callback, + final Function isComplete) { + outboundQueue.commitEntry(xid, message, callback, isComplete); + } } -- 2.36.6