diff options
| author | Robert Gemmell <robbie@apache.org> | 2011-08-08 22:54:37 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2011-08-08 22:54:37 +0000 |
| commit | 09d5704b80e7b7936ec913c107c4537faf643d73 (patch) | |
| tree | 63434cd7ccf8ac3085d7558632da65550b1a09de /qpid/java/common/src/test | |
| parent | 2dda5290066f4e5b7ac07a80cbbe659b519a8200 (diff) | |
| download | qpid-python-09d5704b80e7b7936ec913c107c4537faf643d73.tar.gz | |
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
Diffstat (limited to 'qpid/java/common/src/test')
| -rw-r--r-- | qpid/java/common/src/test/java/org/apache/qpid/transport/network/mina/MinaNetworkHandlerTest.java | 8 |
1 files changed, 7 insertions, 1 deletions
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<ByteBuffer> _receivedBytes = new ArrayList<ByteBuffer>(); private int _readBytes; @@ -447,6 +448,11 @@ public class MinaNetworkHandlerTest extends QpidTestCase return _closed; } + public long getConnectionId() + { + return -1; + } + } private class EchoProtocolEngine extends CountingProtocolEngine |