activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r761361 - /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp
Date Thu, 02 Apr 2009 17:57:33 GMT
Author: tabish
Date: Thu Apr  2 17:57:32 2009
New Revision: 761361

URL: http://svn.apache.org/viewvc?rev=761361&view=rev
Log:
Clean up some dead code.

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp?rev=761361&r1=761360&r2=761361&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp Thu
Apr  2 17:57:32 2009
@@ -762,9 +762,6 @@
                     session->oneway( ack );
                 }
 
-//                // stop the delivery of messages.
-//                unconsumedMessages.stop();
-
                 std::auto_ptr< Iterator< Pointer<Message> > > iter( dispatchedMessages.iterator()
);
 
                 while( iter->hasNext() ) {
@@ -772,23 +769,6 @@
                     unconsumedMessages.enqueueFront( dispatch );
                 }
 
-//                if (redeliveryDelay > 0 && !unconsumedMessages.isClosed()) {
-//                    // Start up the delivery again a little later.
-//                    scheduler.executeAfterDelay(new Runnable() {
-//                        public void run() {
-//                            try {
-//                                if (started.get()) {
-//                                    start();
-//                                }
-//                            } catch (JMSException e) {
-//                                session.connection.onAsyncException(e);
-//                            }
-//                        }
-//                    }, redeliveryDelay);
-//                } else {
-//                    start();
-//                }
-
             }
             deliveredCounter -= dispatchedMessages.size();
             dispatchedMessages.clear();



Mime
View raw message