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