Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
Subject: svn commit: r686635 -
 /activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h
Date: Sun, 17 Aug 2008 19:21:45 -0000
To: commits@activemq.apache.org
From: tabish@apache.org
Message-Id: <20080817192145.EBC6C2388986@eris.apache.org>

Author: tabish
Date: Sun Aug 17 12:21:45 2008
New Revision: 686635

URL: http://svn.apache.org/viewvc?rev=686635&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQCPP-189

Adding timed and un-timed requests to the Response correlator code via the Future response object, refactored FutureReponse to use a Latch to wait for the response.

This fixes the first part of Adding Producer Flow control, clients will now block waiting for the broker when using sync style sends.  The async transport will keep running right now consuming all client memory if allowed to run long enough.

Modified:
    activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h

Modified: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h?rev=686635&r1=686634&r2=686635&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h (original)
+++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h Sun Aug 17 12:21:45 2008
@@ -37,7 +37,7 @@
      * type.  The class implements the basic wrapper around the generated
      * Message class as well as satisfying the contract of the
      * core::ActiveMQMessage interface and the cms::Message method of which
-     * T must be a derviation of.
+     * T must be a derivation of.
      */
     template< typename T>
     class ActiveMQMessageBase : public T,
@@ -79,7 +79,7 @@
         }
 
         /**
-         * Handles the marshalling of the objects properties into the
+         * Handles the marshaling of the objects properties into the
          * internal byte array before the object is marshalled to the
          * wire
          * @param wireFormat - the wireformatting controller
@@ -174,7 +174,7 @@
     public:   // core::ActiveMQMessage
 
         /**
-         * Sets the Acknowledgement Handler that this Message will use
+         * Sets the Acknowledgment Handler that this Message will use
          * when the Acknowledge method is called.
          * @param handler ActiveMQAckHandler to call
          */
@@ -183,7 +183,7 @@
         }
 
         /**
-         * Gets the Acknowledgement Handler that this Message will use
+         * Gets the Acknowledgment Handler that this Message will use
          * when the Acknowledge method is called.
          * @returns handler ActiveMQAckHandler to call or NULL if not set
          */
@@ -254,7 +254,7 @@
         }
 
         /**
-         * Retrieves the propery names.
+         * Retrieves the property names.
          * @return The complete set of property names currently in this
          * message.
          */