Barrier turn on/off - StackedOutboundQueue definition

[openflowjava.git] / openflow-protocol-impl / src / main / java / org / opendaylight / openflowjava / protocol / impl / core / connection / OutboundQueueManager.java

diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/OutboundQueueManager.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/OutboundQueueManager.java
index 6b90daae2695d1e937026af0dc730b6cbbd8b0b1..90db23da65d3dfa37b245edf3ce1b6af5d7fd951 100644 (file)
--- a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/OutboundQueueManager.java
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/OutboundQueueManager.java
@@ -16,7 +16,8 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-final class OutboundQueueManager<T extends OutboundQueueHandler> extends AbstractOutboundQueueManager<T> {
+final class OutboundQueueManager<T extends OutboundQueueHandler> extends
+        AbstractOutboundQueueManager<T, StackedOutboundQueue> {
     private static final Logger LOG = LoggerFactory.getLogger(OutboundQueueManager.class);
 
     private final int maxNonBarrierMessages;
@@ -44,6 +45,10 @@ final class OutboundQueueManager<T extends OutboundQueueHandler> extends Abstrac
         this.maxBarrierNanos = maxBarrierNanos;
     }
 
+    @Override
+    protected StackedOutboundQueue initializeStackedOutboudnqueue() {
+        return new StackedOutboundQueue(this);
+    }
 
     private void scheduleBarrierTimer(final long now) {
         long next = lastBarrierNanos + maxBarrierNanos;