svn commit: r1330353 - /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerInfo.h

[ta...@apache.org]

Author: tabish
Date: Wed Apr 25 15:37:53 2012
New Revision: 1330353

URL: http://svn.apache.org/viewvc?rev=1330353&view=rev
Log:
regen the commands to add the current prefetch value

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

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerInfo.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerInfo.h?rev=1330353&r1=1330352&r2=1330353&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerInfo.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/commands/ConsumerInfo.h Wed Apr 25 15:37:53 2012
@@ -76,6 +76,11 @@ namespace commands{
 
     private:
 
+        // Prefetch size that is controlled by the Broker.
+        int currentPrefetchSize;
+
+    private:
+
         ConsumerInfo( const ConsumerInfo& );
         ConsumerInfo& operator= ( const ConsumerInfo& );
 
@@ -97,6 +102,14 @@ namespace commands{
 
         Pointer<RemoveInfo> createRemoveCommand() const;
 
+        int getCurrentPrefetchSize() const {
+            return this->currentPrefetchSize;
+        }
+
+        void setCurrentPrefetchSize(int currentPrefetchSize) {
+            this->currentPrefetchSize = currentPrefetchSize;
+        }
+
         virtual const Pointer<ConsumerId>& getConsumerId() const;
         virtual Pointer<ConsumerId>& getConsumerId();
         virtual void setConsumerId( const Pointer<ConsumerId>& consumerId );