Revert "Bug-2827: role switch proposal"

[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 75da4c114780ef0c1c2d6b791955386b80a6f3cc..cd301de78a3f0700744b34036b23e1443b17b9dc 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
@@ -9,22 +9,22 @@ package org.opendaylight.openflowplugin.openflow.md.queue;
 
 import java.util.List;
 
-import org.opendaylight.openflowplugin.openflow.md.core.ConnectionConductor;
+import org.opendaylight.openflowplugin.api.openflow.md.core.ConnectionConductor;
+import org.opendaylight.openflowplugin.api.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 Class<? extends IN> registeredMessageType;
+    private QueueType queueType;
+    private List<OUT> directResult;
     
     /**
      * default ctor
@@ -67,20 +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;
+    }
 
     /**
-     * @param registeredMessageType
+     * @return the directResult
      */
-    public void setRegisteredMessageType(
-            Class<? extends IN> registeredMessageType) {
-        this.registeredMessageType = registeredMessageType;
+    @Override
+    public List<OUT> getDirectResult() {
+        return directResult;
     }
 
     /**
-     * @return the registeredMessageType
+     * @param directResult the directResult to set
      */
     @Override
-    public Class<? extends IN> getRegisteredMessageType() {
-        return registeredMessageType;
+    public void setDirectResult(List<OUT> directResult) {
+        this.directResult = directResult;
     }
 }