BUG-1075: ingress back pressure

[openflowplugin.git] / openflowplugin / src / main / java / org / opendaylight / openflowplugin / openflow / md / queue / TicketImpl.java

diff --git a/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketImpl.java b/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketImpl.java
index 81c72ef6455768f72732763858b3fb5bc1dd7217..7a11f3f00c523be0eaa668fa42e184ecb022e7bc 100644 (file)
--- a/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketImpl.java
+++ b/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketImpl.java
@@ -10,20 +10,21 @@ package org.opendaylight.openflowplugin.openflow.md.queue;
 import java.util.List;
 
 import org.opendaylight.openflowplugin.openflow.md.core.ConnectionConductor;
+import org.opendaylight.openflowplugin.openflow.md.queue.QueueKeeper.QueueType;
 
 import com.google.common.util.concurrent.SettableFuture;
 
 /**
- * @author mirehak
  * @param <IN> source type
  * @param <OUT> result type
- *
  */
 public class TicketImpl<IN, OUT> implements Ticket<IN, OUT> {
     
     private IN message;
     private ConnectionConductor conductor;
     private SettableFuture<List<OUT>> future;
+    private QueueType queueType;
+    private List<OUT> directResult;
     
     /**
      * default ctor
@@ -66,4 +67,32 @@ public class TicketImpl<IN, OUT> implements Ticket<IN, OUT> {
     public void setConductor(ConnectionConductor conductor) {
         this.conductor = conductor;
     }
+    
+    /**
+     * @param queueType the queueType to set
+     */
+    public void setQueueType(QueueType queueType) {
+        this.queueType = queueType;
+    }
+    
+    @Override
+    public QueueType getQueueType() {
+        return queueType;
+    }
+
+    /**
+     * @return the directResult
+     */
+    @Override
+    public List<OUT> getDirectResult() {
+        return directResult;
+    }
+
+    /**
+     * @param directResult the directResult to set
+     */
+    @Override
+    public void setDirectResult(List<OUT> directResult) {
+        this.directResult = directResult;
+    }
 }