activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nmitt...@apache.org
Subject svn commit: r516819 - /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/stomp/StompConnector.cpp
Date Sun, 11 Mar 2007 00:42:59 GMT
Author: nmittler
Date: Sat Mar 10 16:42:58 2007
New Revision: 516819

URL: http://svn.apache.org/viewvc?view=rev&rev=516819
Log:
AMQCPP-62 - don't send poison acks after a rollback with stomp

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/stomp/StompConnector.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/stomp/StompConnector.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/stomp/StompConnector.cpp?view=diff&rev=516819&r1=516818&r2=516819
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/stomp/StompConnector.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/stomp/StompConnector.cpp
Sat Mar 10 16:42:58 2007
@@ -498,8 +498,8 @@
 
         // Auto to Stomp means don't do anything, so we drop it here
         // for client acknowledge we have to send and ack.
-        if( session->getAckMode() == cms::Session::CLIENT_ACKNOWLEDGE ||
-            session->getAckMode() == cms::Session::SESSION_TRANSACTED )
+        if( session->getAckMode() == cms::Session::CLIENT_ACKNOWLEDGE /*||
+            session->getAckMode() == cms::Session::SESSION_TRANSACTED*/ )
         {
             AckCommand cmd;
 
@@ -513,12 +513,12 @@
 
             cmd.setMessageId( message->getCMSMessageId() );
 
-            if( session->getAckMode() == cms::Session::SESSION_TRANSACTED )
+            /*if( session->getAckMode() == cms::Session::SESSION_TRANSACTED )
             {
                 cmd.setTransactionId(
                     Integer::toString(
                         session->getTransactionInfo()->getTransactionId() ) );
-            }
+            }*/
 
             transport->oneway( &cmd );
         }



Mime
View raw message