activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r509365 - in /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire: OpenWireConnector.cpp commands/ActiveMQTextMessage.cpp
Date Mon, 19 Feb 2007 22:50:59 GMT
Author: tabish
Date: Mon Feb 19 14:50:58 2007
New Revision: 509365

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

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQTextMessage.cpp

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp?view=diff&rev=509365&r1=509364&r2=509365
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireConnector.cpp
Mon Feb 19 14:50:58 2007
@@ -504,7 +504,7 @@
         consumerInfo->setBrowser( Boolean::parseBoolean(
             options.getProperty( "consumer.browser", "false" )) );
         consumerInfo->setPrefetchSize( Integer::parseInt(
-            options.getProperty( "consumer.prefetchSize", "0" )) );
+            options.getProperty( "consumer.prefetchSize", "1000" )) );
         consumerInfo->setMaximumPendingMessageLimit( Integer::parseInt(
             options.getProperty( "consumer.maximumPendingMessageLimit", "0" )) );
         consumerInfo->setDispatchAsync( Boolean::parseBoolean(

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQTextMessage.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQTextMessage.cpp?view=diff&rev=509365&r1=509364&r2=509365
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQTextMessage.cpp
(original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQTextMessage.cpp
Mon Feb 19 14:50:58 2007
@@ -73,7 +73,7 @@
         io::ByteArrayOutputStream bos( content );
         io::DataOutputStream dos( &bos );
 
-        dos.writeInt( msg.length() );
+        dos.writeInt( (int)msg.length() );
         dos.write( (const unsigned char*)msg.c_str(), msg.length() );
     }
     AMQ_CATCH_RETHROW( exceptions::ActiveMQException )



Mime
View raw message