summaryrefslogtreecommitdiff
path: root/java/broker/src
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2007-01-10 21:47:30 +0000
committerKim van der Riet <kpvdr@apache.org>2007-01-10 21:47:30 +0000
commitb6b0463b260df363667c08131e5e5b16bb4daa5e (patch)
tree774096746bbf939d92b3c4a8d2479eef3e0fd748 /java/broker/src
parentddf86268e7bea00710a49bc66fff1a398d41cf0b (diff)
downloadqpid-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/broker/src')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java15
1 files changed, 9 insertions, 6 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
index a75627d240..b1ed999f72 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSession.java
@@ -27,8 +27,9 @@ import org.apache.qpid.AMQException;
import javax.security.sasl.SaslServer;
+import org.apache.qpid.protocol.AMQProtocolWriter;
-public interface AMQProtocolSession
+public interface AMQProtocolSession extends AMQProtocolWriter
{
/**
* Called when a protocol data block is received
@@ -37,11 +38,13 @@ public interface AMQProtocolSession
*/
void dataBlockReceived(AMQDataBlock message) throws Exception;
- /**
- * Write a datablock, encoding where necessary (e.g. into a sequence of bytes)
- * @param frame the frame to be encoded and written
- */
- void writeFrame(AMQDataBlock frame);
+// This is now a part of AMQProtocolWriter (inherited) to provide uniformity across both
+// client and server.
+// /**
+// * Write a datablock, encoding where necessary (e.g. into a sequence of bytes)
+// * @param frame the frame to be encoded and written
+// */
+// void writeFrame(AMQDataBlock frame);
/**
* Get the context key associated with this session. Context key is described