From b6b0463b260df363667c08131e5e5b16bb4daa5e Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Wed, 10 Jan 2007 21:47:30 +0000 Subject: Created new common interfaces to support the RequestResponseManager on both client and server git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@495000 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'java/client/src') diff --git a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java index 6a40fd3133..167c3e68db 100644 --- a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java +++ b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java @@ -36,6 +36,7 @@ import org.apache.qpid.framing.ContentBody; import org.apache.qpid.framing.ContentHeaderBody; import org.apache.qpid.framing.ProtocolInitiation; import org.apache.qpid.framing.ProtocolVersionList; +import org.apache.qpid.protocol.AMQProtocolWriter; import org.apache.commons.lang.StringUtils; import javax.jms.JMSException; @@ -49,7 +50,7 @@ import java.util.concurrent.ConcurrentMap; * The underlying protocol session is still available but clients should not * use it to obtain session attributes. */ -public class AMQProtocolSession implements ProtocolVersionList +public class AMQProtocolSession implements AMQProtocolWriter, ProtocolVersionList { protected static final int LAST_WRITE_FUTURE_JOIN_TIMEOUT = 1000 * 60 * 2; -- cgit v1.2.1