BUG-542 - adding overall statictics

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

diff --git a/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketProcessorFactory.java b/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketProcessorFactory.java
index c72134fffd3aea08aee6d1d77762d180daef4d23..ace82888294444b66b399db8f9a5c01bd7dbfbc7 100644 (file)
--- a/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketProcessorFactory.java
+++ b/openflowplugin/src/main/java/org/opendaylight/openflowplugin/openflow/md/queue/TicketProcessorFactory.java
@@ -16,6 +16,8 @@ import org.opendaylight.openflowplugin.openflow.md.core.ConnectionConductor;
 import org.opendaylight.openflowplugin.openflow.md.core.IMDMessageTranslator;
 import org.opendaylight.openflowplugin.openflow.md.core.SwitchConnectionDistinguisher;
 import org.opendaylight.openflowplugin.openflow.md.core.TranslatorKey;
+import org.opendaylight.yangtools.yang.binding.DataContainer;
+import org.opendaylight.yangtools.yang.binding.DataObject;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -23,7 +25,7 @@ import org.slf4j.LoggerFactory;
  * @param <IN>
  * @param <OUT>
  */
-public class TicketProcessorFactory<IN, OUT> {
+public class TicketProcessorFactory<IN extends DataObject, OUT extends DataObject> {
 
     protected static final Logger LOG = LoggerFactory
             .getLogger(TicketProcessorFactory.class);
@@ -31,7 +33,7 @@ public class TicketProcessorFactory<IN, OUT> {
     protected VersionExtractor<IN> versionExtractor;
     protected RegisteredTypeExtractor<IN> registeredTypeExtractor;
     protected Map<TranslatorKey, Collection<IMDMessageTranslator<IN, List<OUT>>>> translatorMapping;
-    protected MessageSpy<IN, OUT> spy;
+    protected MessageSpy<DataContainer> spy;
 
     /**
      * @param versionExtractor the versionExtractor to set
@@ -59,7 +61,7 @@ public class TicketProcessorFactory<IN, OUT> {
     /**
      * @param spy the spy to set
      */
-    public void setSpy(MessageSpy<IN, OUT> spy) {
+    public void setSpy(MessageSpy<DataContainer> spy) {
         this.spy = spy;
     }
 
@@ -82,7 +84,9 @@ public class TicketProcessorFactory<IN, OUT> {
                     // spying on result
                     if (spy != null) {
                         spy.spyIn(ticket.getMessage());
-                        spy.spyOut(ticket.getResult().get());
+                        for (OUT outMessage : ticket.getResult().get()) {
+                            spy.spyOut(outMessage);
+                        }
                     }
                 } catch (Exception e) {
                     LOG.error("translation problem: {}", e.getMessage());