activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r775191 - in /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands: SessionInfo.cpp SessionInfo.h
Date Fri, 15 May 2009 15:29:54 GMT
Author: tabish
Date: Fri May 15 15:29:54 2009
New Revision: 775191

URL: http://svn.apache.org/viewvc?rev=775191&view=rev
Log:
Regenerated Session Info command that stores a transient ackMode value indicating the Acknowledge
mode of the Session for use elsewhere in the client code.

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.h

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.cpp?rev=775191&r1=775190&r2=775191&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.cpp Fri
May 15 15:29:54 2009
@@ -18,6 +18,7 @@
 #include <activemq/commands/SessionInfo.h>
 #include <activemq/exceptions/ActiveMQException.h>
 #include <activemq/state/CommandVisitor.h>
+#include <cms/Session.h>
 #include <decaf/lang/exceptions/NullPointerException.h>
 
 using namespace std;
@@ -40,6 +41,7 @@
 ////////////////////////////////////////////////////////////////////////////////
 SessionInfo::SessionInfo() {
 
+    this->ackMode = (unsigned int)cms::Session::AUTO_ACKNOWLEDGE;
 }
 
 ////////////////////////////////////////////////////////////////////////////////

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.h?rev=775191&r1=775190&r2=775191&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/SessionInfo.h Fri
May 15 15:29:54 2009
@@ -45,6 +45,11 @@
      *
      */
     class AMQCPP_API SessionInfo : public BaseCommand {
+    private:
+
+        // The ACK mode that the Session was created with
+        unsigned int ackMode;
+
     protected:
 
         Pointer<SessionId> sessionId;
@@ -100,6 +105,14 @@
          */
         virtual bool equals( const DataStructure* value ) const;
 
+        unsigned int getAckMode() const {
+            return this->ackMode;
+        }
+
+        void setAckMode( unsigned int mode ) {
+            this->ackMode = mode;
+        }
+
         virtual const Pointer<SessionId>& getSessionId() const;
         virtual Pointer<SessionId>& getSessionId();
         virtual void setSessionId( const Pointer<SessionId>& sessionId );



Mime
View raw message