Improved unit test coverage (covered some untested branches)

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

diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/connection/ConnectionAdapterImpl.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/connection/ConnectionAdapterImpl.java
index 9fe040fcc4fbb630966a21f45ec8949e030a7bf2..19baa930432b29f80ccf510394165ccd5092e612 100644 (file)
--- a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/connection/ConnectionAdapterImpl.java
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/connection/ConnectionAdapterImpl.java
@@ -108,7 +108,7 @@ public class ConnectionAdapterImpl implements ConnectionFacade {
     };
 
     /** expiring cache for future rpcResponses */
-    private final Cache<RpcResponseKey, ResponseExpectedRpcListener<?>> responseCache;
+    private Cache<RpcResponseKey, ResponseExpectedRpcListener<?>> responseCache;
 
     private final ChannelOutboundQueue output;
     private final Channel channel;
@@ -465,7 +465,6 @@ public class ConnectionAdapterImpl implements ConnectionFacade {
         }).start();
     }
 
-
     @Override
     public void setConnectionReadyListener(
             final ConnectionReadyListener connectionReadyListener) {
@@ -476,4 +475,12 @@ public class ConnectionAdapterImpl implements ConnectionFacade {
     public InetSocketAddress getRemoteAddress() {
         return (InetSocketAddress) channel.remoteAddress();
     }
-}
+
+    /**
+     * Used only for testing purposes
+     * @param cache
+     */
+    public void setResponseCache(Cache<RpcResponseKey, ResponseExpectedRpcListener<?>> cache) {
+        this.responseCache = cache;
+    }
+}
\ No newline at end of file