From: Robert Varga <rovarga@cisco.com>
Date: Sat, 16 May 2015 17:21:25 +0000 (+0200)
Subject: Make sure we route error messages back
X-Git-Tag: release/lithium~26
X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=commitdiff_plain;ds=sidebyside;h=cd8f3f3c6bd1013558f0fdef84ce95cf711b016f;p=openflowjava.git

Make sure we route error messages back

Error messages need to be routed/paired with requests, too.

Change-Id: I265343f2e44d07ce8182fe9d399d594ee549d0fe
Signed-off-by: Robert Varga <rovarga@cisco.com>
---

diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/ConnectionAdapterImpl.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/ConnectionAdapterImpl.java
index 7dca1965..6d9013ec 100644
--- a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/ConnectionAdapterImpl.java
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/connection/ConnectionAdapterImpl.java
@@ -284,6 +284,9 @@ public class ConnectionAdapterImpl implements ConnectionFacade {
                 statisticsCounters.incrementCounter(CounterEventTypes.US_MESSAGE_PASS);
             } else if (message instanceof ErrorMessage) {
                 messageListener.onErrorMessage((ErrorMessage) message);
+                if (outputManager != null) {
+                    outputManager.onMessage((OfHeader) message);
+                }
                 statisticsCounters.incrementCounter(CounterEventTypes.US_MESSAGE_PASS);
             } else if (message instanceof ExperimenterMessage) {
                 messageListener.onExperimenterMessage((ExperimenterMessage) message);