summaryrefslogtreecommitdiff
path: root/java/systests/src
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-01-29 18:53:27 +0000
committerGordon Sim <gsim@apache.org>2007-01-29 18:53:27 +0000
commit06fc36ba2e32bc5c17ba18c1338f602cb84d54bb (patch)
treef5f1cbfb1cdfc8f1d5dfa84784442566a52f0583 /java/systests/src
parent55fd03d058a965422e2369817c6c3f323e51ce55 (diff)
downloadqpid-python-06fc36ba2e32bc5c17ba18c1338f602cb84d54bb.tar.gz
Moved across fixes from trunk for handling exclusive consumers and no_local consumption.
Fixed close process in AMQChannel (remove channel from map only after consumer cancellations have been processed). git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@501144 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/systests/src')
-rw-r--r--java/systests/src/test/java/org/apache/qpid/server/queue/MockProtocolSession.java6
1 files changed, 6 insertions, 0 deletions
diff --git a/java/systests/src/test/java/org/apache/qpid/server/queue/MockProtocolSession.java b/java/systests/src/test/java/org/apache/qpid/server/queue/MockProtocolSession.java
index 6ecb54300f..400b21c5b1 100644
--- a/java/systests/src/test/java/org/apache/qpid/server/queue/MockProtocolSession.java
+++ b/java/systests/src/test/java/org/apache/qpid/server/queue/MockProtocolSession.java
@@ -143,6 +143,12 @@ public class MockProtocolSession implements AMQProtocolSession
{
}
+
+ public Object getClientIdentifier()
+ {
+ return null;
+ }
+
public void closeChannelRequest(int channelId, int replyCode, String replyText) throws AMQException {
// TODO Auto-generated method stub