You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2007/02/11 21:19:54 UTC
svn commit: r506118 -
/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp
Author: tabish
Date: Sun Feb 11 12:19:54 2007
New Revision: 506118
URL: http://svn.apache.org/viewvc?view=rev&rev=506118
Log:
http://issues.apache.org/activemq/browse/AMQCPP-30
Modified:
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp?view=diff&rev=506118&r1=506117&r2=506118
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormatNegotiator.cpp Sun Feb 11 12:19:54 2007
@@ -117,7 +117,7 @@
////////////////////////////////////////////////////////////////////////////////
void OpenWireFormatNegotiator::onTransportException(
- Transport* source,
+ Transport* source AMQCPP_UNUSED,
const exceptions::ActiveMQException& ex ) {
readyCountDownLatch.countDown();
@@ -135,18 +135,31 @@
}
if( commandlistener == NULL ){
- throw exceptions::ActiveMQException( __FILE__, __LINE__,
+ throw exceptions::ActiveMQException(
+ __FILE__, __LINE__,
+ "OpenWireFormatNegotiator::start - "
"commandListener is invalid" );
}
if( exceptionListener == NULL ){
- throw exceptions::ActiveMQException( __FILE__, __LINE__,
+ throw exceptions::ActiveMQException(
+ __FILE__, __LINE__,
+ "OpenWireFormatNegotiator::start - "
"exceptionListener is invalid" );
}
if( next == NULL ){
- throw exceptions::ActiveMQException( __FILE__, __LINE__,
+ throw exceptions::ActiveMQException(
+ __FILE__, __LINE__,
+ "OpenWireFormatNegotiator::start - "
"next transport is NULL" );
+ }
+
+ if( openWireFormat == NULL ){
+ throw exceptions::ActiveMQException(
+ __FILE__, __LINE__,
+ "OpenWireFormatNegotiator::start - "
+ "openWireFormat is NULL" );
}
// Start the delegate transport object.