diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2007-01-10 21:47:30 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2007-01-10 21:47:30 +0000 |
| commit | b6b0463b260df363667c08131e5e5b16bb4daa5e (patch) | |
| tree | 774096746bbf939d92b3c4a8d2479eef3e0fd748 /java/client/src | |
| parent | ddf86268e7bea00710a49bc66fff1a398d41cf0b (diff) | |
| download | qpid-python-b6b0463b260df363667c08131e5e5b16bb4daa5e.tar.gz | |
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
Diffstat (limited to 'java/client/src')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolSession.java | 3 |
1 files changed, 2 insertions, 1 deletions
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; |