From 09d5704b80e7b7936ec913c107c4537faf643d73 Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Mon, 8 Aug 2011 22:54:37 +0000 Subject: QPID-3385: assign IDs from a generator within the MultiVersionProtocolEngineFactory, which is shared across all protocol versions git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1155136 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/transport/network/mina/MinaNetworkHandlerTest.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'qpid/java/common/src/test') diff --git a/qpid/java/common/src/test/java/org/apache/qpid/transport/network/mina/MinaNetworkHandlerTest.java b/qpid/java/common/src/test/java/org/apache/qpid/transport/network/mina/MinaNetworkHandlerTest.java index 1a1b5af805..976b141fc0 100644 --- a/qpid/java/common/src/test/java/org/apache/qpid/transport/network/mina/MinaNetworkHandlerTest.java +++ b/qpid/java/common/src/test/java/org/apache/qpid/transport/network/mina/MinaNetworkHandlerTest.java @@ -34,6 +34,7 @@ import java.util.concurrent.TimeUnit; import org.apache.qpid.framing.AMQDataBlock; import org.apache.qpid.protocol.ProtocolEngine; import org.apache.qpid.protocol.ProtocolEngineFactory; +import org.apache.qpid.protocol.ServerProtocolEngine; import org.apache.qpid.test.utils.QpidTestCase; import org.apache.qpid.transport.ConnectionSettings; import org.apache.qpid.transport.NetworkTransportConfiguration; @@ -333,7 +334,7 @@ public class MinaNetworkHandlerTest extends QpidTestCase } } - public class CountingProtocolEngine implements ProtocolEngine + public class CountingProtocolEngine implements ServerProtocolEngine { public ArrayList _receivedBytes = new ArrayList(); private int _readBytes; @@ -447,6 +448,11 @@ public class MinaNetworkHandlerTest extends QpidTestCase return _closed; } + public long getConnectionId() + { + return -1; + } + } private class EchoProtocolEngine extends CountingProtocolEngine -- cgit v1.2.1