[hornetq-commits] JBoss hornetq SVN: r11651 - in trunk: tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/remoting/impl/netty and 1 other directory.

do-not-reply at jboss.org do-not-reply at jboss.org
Thu Nov 3 09:41:08 EDT 2011


Author: borges
Date: 2011-11-03 09:41:08 -0400 (Thu, 03 Nov 2011)
New Revision: 11651

Modified:
   trunk/hornetq-core/src/main/java/org/hornetq/core/remoting/impl/netty/NettyConnection.java
   trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/remoting/impl/netty/NettyConnectionTest.java
Log:
Delete constructor only used in tests.

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/remoting/impl/netty/NettyConnection.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/remoting/impl/netty/NettyConnection.java	2011-11-03 09:43:12 UTC (rev 11650)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/remoting/impl/netty/NettyConnection.java	2011-11-03 13:41:08 UTC (rev 11651)
@@ -68,14 +68,6 @@
 
    // Constructors --------------------------------------------------
 
-   public NettyConnection(final Channel channel,
-                          final ConnectionLifeCycleListener listener,
-                          boolean batchingEnabled,
-                          boolean directDeliver)
-   {
-      this(null, channel, listener, batchingEnabled, directDeliver);
-   }
-
    public NettyConnection(final Acceptor acceptor,
                           final Channel channel,
                           final ConnectionLifeCycleListener listener,

Modified: trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/remoting/impl/netty/NettyConnectionTest.java
===================================================================
--- trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/remoting/impl/netty/NettyConnectionTest.java	2011-11-03 09:43:12 UTC (rev 11650)
+++ trunk/tests/unit-tests/src/test/java/org/hornetq/tests/unit/core/remoting/impl/netty/NettyConnectionTest.java	2011-11-03 13:41:08 UTC (rev 11651)
@@ -48,7 +48,7 @@
    public void testGetID() throws Exception
    {
       Channel channel = new SimpleChannel(RandomUtil.randomInt());
-      NettyConnection conn = new NettyConnection(channel, new MyListener(), false, false);
+      NettyConnection conn = new NettyConnection(null, channel, new MyListener(), false, false);
 
       Assert.assertEquals(channel.getId().intValue(), conn.getID());
    }
@@ -60,7 +60,7 @@
 
       Assert.assertEquals(0, channel.getWritten().size());
 
-      NettyConnection conn = new NettyConnection(channel, new MyListener(), false, false);
+      NettyConnection conn = new NettyConnection(null, channel, new MyListener(), false, false);
       conn.write(buff);
 
       Assert.assertEquals(1, channel.getWritten().size());
@@ -69,7 +69,7 @@
    public void testCreateBuffer() throws Exception
    {
       Channel channel = new SimpleChannel(RandomUtil.randomInt());
-      NettyConnection conn = new NettyConnection(channel, new MyListener(), false, false);
+      NettyConnection conn = new NettyConnection(null, channel, new MyListener(), false, false);
 
       final int size = 1234;
 
@@ -235,7 +235,7 @@
       {
 
       }
-      
+
       public void connectionReadyForWrites(Object connectionID, boolean ready)
       {
       }



More information about the hornetq-commits mailing list