From 06fc36ba2e32bc5c17ba18c1338f602cb84d54bb Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Mon, 29 Jan 2007 18:53:27 +0000 Subject: 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 --- .../test/java/org/apache/qpid/server/queue/MockProtocolSession.java | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'java/systests/src') 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 -- cgit v1.2.1