EnhancedMessageTypeKey add hash(), ChannelOutboundQueue change address to final and...

[openflowjava.git] / openflow-protocol-impl / src / test / java / org / opendaylight / openflowjava / protocol / impl / connection / ChannelOutboundQueueTest.java

diff --git a/openflow-protocol-impl/src/test/java/org/opendaylight/openflowjava/protocol/impl/connection/ChannelOutboundQueueTest.java b/openflow-protocol-impl/src/test/java/org/opendaylight/openflowjava/protocol/impl/connection/ChannelOutboundQueueTest.java
index 060072d560a495c4c86af5c7e14fe84fd1363bb9..7017eae22ea009e06428cf7df586cfe0d7f4b797 100644 (file)
--- a/openflow-protocol-impl/src/test/java/org/opendaylight/openflowjava/protocol/impl/connection/ChannelOutboundQueueTest.java
+++ b/openflow-protocol-impl/src/test/java/org/opendaylight/openflowjava/protocol/impl/connection/ChannelOutboundQueueTest.java
@@ -35,7 +35,7 @@ public class ChannelOutboundQueueTest {
      */\r
     @Test(expected=IllegalArgumentException.class)\r
     public void testIncorrectQueueCreation() {\r
-        new ChannelOutboundQueue(channel, 0);\r
+        new ChannelOutboundQueue(channel, 0, null);\r
     }\r
 \r
     /**\r
@@ -43,7 +43,7 @@ public class ChannelOutboundQueueTest {
      */\r
     @Test\r
     public void testEnqueue() {\r
-        ChannelOutboundQueue queue = new ChannelOutboundQueue(channel, 1);\r
+        ChannelOutboundQueue queue = new ChannelOutboundQueue(channel, 1, null);\r
         boolean enqueued = queue.enqueue(new SimpleRpcListener("INPUT", "Failed to send INPUT"));\r
         Assert.assertTrue("Enqueue problem", enqueued);\r
         enqueued = queue.enqueue(new SimpleRpcListener("INPUT", "Failed to send INPUT"));\r