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 | 12181a6cd1fde75d48d4c048d9dd704e2f901524 (patch) | |
| tree | cc5e1f99d40c5703f59302fe357d4c9823c7ed21 /java/common/src/test | |
| parent | 04ee94c3acc0f2240af0eb39f037d7bf096c019d (diff) | |
| download | qpid-python-12181a6cd1fde75d48d4c048d9dd704e2f901524.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/qpid@1155136 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src/test')
| -rw-r--r-- | java/common/src/test/java/org/apache/qpid/transport/network/mina/MinaNetworkHandlerTest.java | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/java/common/src/test/java/org/apache/qpid/transport/network/mina/MinaNetworkHandlerTest.java b/java/common/src/test/java/org/apache/qpid/transport/network/mina/MinaNetworkHandlerTest.java index 1a1b5af805..976b141fc0 100644 --- a/java/common/src/test/java/org/apache/qpid/transport/network/mina/MinaNetworkHandlerTest.java +++ b/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 |