Author: tabish
Date: Wed Jan 31 06:25:20 2007
New Revision: 501852
URL: http://svn.apache.org/viewvc?view=rev&rev=501852
Log:
http://issues.apache.org/activemq/browse/AMQCPP-63
Update Session to clone sent messages and destroy the clones once the message
is sent. This is to allow the user to delete their message pointers after a
send. We may want to change to CMS API at some point so that we control object
lifetime after a send.
Modified:
incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.cpp
Modified:
incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.cpp
URL:
http://svn.apache.org/viewvc/incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.cpp?view=diff&rev=501852&r1=501851&r2=501852
==============================================================================
---
incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.cpp
(original)
+++
incubator/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQSession.cpp
Wed Jan 31 06:25:20 2007
@@ -572,9 +572,11 @@
if( useAsyncSend == true ) {
- // Put it in the send queue, thread will dispatch it.
+ // Put it in the send queue, thread will dispatch it. We clone it
+ // in case the client deletes their copy before we get a chance to
+ // send it.
synchronized( &msgQueue ) {
- msgQueue.push( make_pair( message, producer ) );
+ msgQueue.push( make_pair( message->clone(), producer ) );
msgQueue.notifyAll();
}
@@ -686,6 +688,8 @@
messagePair.first,
messagePair.second->getProducerInfo() );
+ // Destroy Our copy of the message
+ delete messagePair.first;
}
}
catch(...)
