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.
*/