qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r..@apache.org
Subject svn commit: r499929 - /incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java
Date Thu, 25 Jan 2007 19:23:40 GMT
Author: rhs
Date: Thu Jan 25 11:23:39 2007
New Revision: 499929

URL: http://svn.apache.org/viewvc?view=rev&rev=499929
Log:
updated to use session's new close method

Modified:
    incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java

Modified: incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java?view=diff&rev=499929&r1=499928&r2=499929
==============================================================================
--- incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java
(original)
+++ incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java
Thu Jan 25 11:23:39 2007
@@ -192,25 +192,11 @@
      */
     public void closeConnection() throws JMException
     {
-        
-        // AMQP version change: Hardwire the version to 0-9 (major=0, minor=9)
-        // TODO: Connect this to the session version obtained from ProtocolInitiation for
this session.
-        // Be aware of possible changes to parameter order as versions change.
-        final AMQMethodBody request = ConnectionCloseBody.createMethodBody
-            ((byte)0, (byte)9,	// AMQP version (major, minor)
-             0,	// classId
-             0,	// methodId
-             AMQConstant.REPLY_SUCCESS.getCode(),	// replyCode
-             "Broker Management Console has closing the connection."	// replyText
-             );
-        try
-        {
-            if (true) throw new Error("XXX");
-            _session.writeRequest(0, request, null /*XXX*/);
-            _session.closeSession();
-        }
-        catch (AMQException ex)
-        {
+        try {
+            _session.closeSessionRequest
+                (AMQConstant.REPLY_SUCCESS.getCode(), // XXX: Success???
+                 "Broker Management Console has closing the connection.");
+        } catch (AMQException ex) {
             throw new MBeanException(ex, ex.toString());
         }
     }



Mime
View raw message