[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.

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) { }