From commits-return-4552-apmail-activemq-commits-archive=activemq.apache.org@activemq.apache.org Sun Feb 04 01:45:09 2007 Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 97416 invoked from network); 4 Feb 2007 01:45:09 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 4 Feb 2007 01:45:09 -0000 Received: (qmail 39294 invoked by uid 500); 4 Feb 2007 01:45:15 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 39260 invoked by uid 500); 4 Feb 2007 01:45:15 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 39251 invoked by uid 99); 4 Feb 2007 01:45:15 -0000 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO eris.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with ESMTP; Sat, 03 Feb 2007 17:45:13 -0800 Received: by eris.apache.org (Postfix, from userid 65534) id BBFB51A981A; Sat, 3 Feb 2007 17:44:16 -0800 (PST) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r503343 - in /activemq/activemq-cpp/trunk/activemq-cpp: src/main/activemq/connector/openwire/ src/main/activemq/connector/openwire/commands/ src/main/activemq/connector/openwire/marshal/ src/main/activemq/connector/openwire/marshal/v2/ vs20... Date: Sun, 04 Feb 2007 01:44:16 -0000 To: commits@activemq.apache.org From: nmittler@apache.org X-Mailer: svnmailer-1.1.0 Message-Id: <20070204014416.BBFB51A981A@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: nmittler Date: Sat Feb 3 17:44:14 2007 New Revision: 503343 URL: http://svn.apache.org/viewvc?view=rev&rev=503343 Log: fixing link error related to openwire classes Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandReader.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandReader.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireConnector.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireConnector.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQMessage.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQTextMessage.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/BaseDataStreamMarshaller.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/ActiveMQDestinationMarshaller.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/ActiveMQTempDestinationMarshaller.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/BaseCommandMarshaller.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/MessageMarshaller.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/MessageMarshaller.h activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/PartialCommandMarshaller.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/TransactionIdMarshaller.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/WireFormatInfoMarshaller.cpp activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/XATransactionIdMarshaller.cpp activemq/activemq-cpp/trunk/activemq-cpp/vs2005-build/vs2005-activemq.vcproj Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.cpp?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.cpp Sat Feb 3 17:44:14 2007 @@ -79,9 +79,6 @@ sizePrefixDisabled = Boolean::parseBoolean( properties.getProperty( "wireFormat.sizePrefixDisabled", "0" ) ); - maxInactivityDuration = Long::parseLong( - properties.getProperty( "wireFormat.maxInactivityDuration", - "30000" ) ); } //////////////////////////////////////////////////////////////////////////////// @@ -119,7 +116,6 @@ preferedWireFormatInfo->setTcpNoDelayEnabled( tcpNoDelayEnabled ); preferedWireFormatInfo->setTightEncodingEnabled( tightEncodingEnabled ); preferedWireFormatInfo->setSizePrefixDisabled( sizePrefixDisabled ); - preferedWireFormatInfo->setMaxInactivityDuration( maxInactivityDuration ); } catch( ActiveMQException& e ) { throw IllegalStateException( __FILE__, __LINE__, @@ -180,7 +176,7 @@ if( !sizePrefixDisabled ) { looseOut->close(); - dataOut->writeInt( baos->getByteArraySize() ); + dataOut->writeInt( (int)baos->getByteArraySize() ); dataOut->write( baos->getByteArray(), baos->getByteArraySize() ); @@ -302,7 +298,7 @@ object->getMarshaledForm(this); bs->writeBoolean( !sequence.empty() ); if( !sequence.empty() ) { - return 1 + sequence.size(); + return (int)(1 + sequence.size()); } } Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.h?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenWireFormat.h Sat Feb 3 17:44:14 2007 @@ -242,22 +242,6 @@ this->sizePrefixDisabled = sizePrefixDisabled; } - /** - * Get the current value of the maxInactivityDuration feild - * @return the value of the maxInactivityDuration - */ - long getMaxInactivityDuration() const { - return maxInactivityDuration; - } - - /** - * Set the current Wireformat Version - * @param version - int that identifies the version - */ - void setMaxInactivityDuration( long maxInactivityDuration ) { - this->maxInactivityDuration = maxInactivityDuration; - } - protected: /** @@ -298,7 +282,6 @@ bool cacheEnabled; bool tightEncodingEnabled; bool sizePrefixDisabled; - int maxInactivityDuration; }; Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandReader.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandReader.cpp?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandReader.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandReader.cpp Sat Feb 3 17:44:14 2007 @@ -54,7 +54,7 @@ } //////////////////////////////////////////////////////////////////////////////// -int OpenwireCommandReader::read( unsigned char* buffer, int count ) +size_t OpenwireCommandReader::read( unsigned char* buffer, size_t count ) throw( io::IOException ) { try @@ -66,7 +66,7 @@ "OpenwireCommandReader::read(char*,int) - input stream is NULL" ); } - int head = 0; + size_t head = 0; // We call the read(buffer, size) version asking for one // byte, if this returns zero, then there wasn't anything Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandReader.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandReader.h?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandReader.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandReader.h Sat Feb 3 17:44:14 2007 @@ -82,7 +82,7 @@ * @return The number of bytes read. * @throws IOException thrown if an error occurs. */ - virtual int read( unsigned char* buffer, int count ) + virtual size_t read( unsigned char* buffer, size_t count ) throw( io::IOException ); /** Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.cpp?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.cpp Sat Feb 3 17:44:14 2007 @@ -38,7 +38,7 @@ } //////////////////////////////////////////////////////////////////////////////// -void OpenwireCommandWriter::writeCommand( const Command* command ) +void OpenwireCommandWriter::writeCommand( Command* command ) throw ( transport::CommandIOException ) { try @@ -59,7 +59,7 @@ } //////////////////////////////////////////////////////////////////////////////// -void OpenwireCommandWriter::write( const unsigned char* buffer, int count ) +void OpenwireCommandWriter::write( const unsigned char* buffer, size_t count ) throw( IOException ) { if( outputStream == NULL ) @@ -85,9 +85,4 @@ outputStream->write( v ); } -//////////////////////////////////////////////////////////////////////////////// -void OpenwireCommandWriter::write( const char* buffer, int count ) - throw( io::IOException ) -{ - write( reinterpret_cast( buffer ), count ); -} + Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.h?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireCommandWriter.h Sat Feb 3 17:44:14 2007 @@ -21,12 +21,11 @@ #include #include #include -#include #include -using namespace activemq{ -using namespace connector{ -using namespace openwire{ +namespace activemq{ +namespace connector{ +namespace openwire{ class OpenwireCommandWriter : public transport::CommandWriter { @@ -40,7 +39,7 @@ /** * Marshaler of Stomp Commands */ - marshal::Marshaler marshaler; + //marshal::Marshaler marshaler; public: @@ -77,7 +76,7 @@ * @param os the target stream for the write. * @throws CommandIOException if a problem occurs during the write. */ - virtual void writeCommand( const transport::Command* command ) + virtual void writeCommand( transport::Command* command ) throw ( transport::CommandIOException ); /** @@ -86,7 +85,7 @@ * @param count the number of bytes in the array to write. * @throws IOException thrown if an error occurs. */ - virtual void write( const unsigned char* buffer, int count ) + virtual void write( const unsigned char* buffer, size_t count ) throw( io::IOException ); /** 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=503343&r1=503342&r2=503343 ============================================================================== --- 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 Sat Feb 3 17:44:14 2007 @@ -23,6 +23,7 @@ #include #include #include +#include using namespace std; using namespace activemq; @@ -159,7 +160,7 @@ try { // Mark this connector as started. - state = this->CONNECTING; + /*state = this->CONNECTING; // TODO - Create a Connect Command @@ -207,7 +208,7 @@ state = CONNECTED; // Clean up - delete response; + delete response;*/ } AMQ_CATCH_RETHROW( BrokerError ) AMQ_CATCH_RETHROW( ActiveMQException ) Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireConnector.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireConnector.h?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireConnector.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/OpenwireConnector.h Sat Feb 3 17:44:14 2007 @@ -46,7 +46,7 @@ #include #include #include -#include +#include #include #include @@ -57,7 +57,7 @@ namespace openwire{ class OpenwireConnector : - public Connector + public Connector, public transport::CommandListener, public transport::TransportExceptionListener { Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQMessage.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQMessage.h?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQMessage.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQMessage.h Sat Feb 3 17:44:14 2007 @@ -45,7 +45,7 @@ * @return src - Source Object */ virtual void copyDataStructure( const DataStructure* src ) { - ActiveMQMessage::copyDataStructure( src ); + ActiveMQMessageBase::copyDataStructure( src ); } public: // cms::Message Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/commands/ActiveMQMessageBase.h Sat Feb 3 17:44:14 2007 @@ -54,7 +54,7 @@ * @return src - Source Object */ virtual void copyDataStructure( const DataStructure* src ) { - Message::copyDataStructure( src ); + openwire::commands::Message::copyDataStructure( src ); } /** 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=503343&r1=503342&r2=503343 ============================================================================== --- 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 Sat Feb 3 17:44:14 2007 @@ -43,7 +43,7 @@ std::string ActiveMQTextMessage::getText() const throw( cms::CMSException ) { try{ - return std::string( getContent()[0], getContent().size() ); + return std::string( (const char*)&getContent()[0], getContent().size() ); } AMQ_CATCH_RETHROW( exceptions::ActiveMQException ) AMQ_CATCHALL_THROW( exceptions::ActiveMQException ) @@ -52,8 +52,8 @@ //////////////////////////////////////////////////////////////////////////////// void ActiveMQTextMessage::setText( const char* msg ) throw( cms::CMSException ) { try{ - int length = strlen( msg ); - for( int i = 0; i < length; ++i ){ + size_t length = strlen( msg ); + for( size_t i = 0; i < length; ++i ){ getContent().push_back( msg[i] ); } } Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/BaseDataStreamMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/BaseDataStreamMarshaller.cpp?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/BaseDataStreamMarshaller.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/BaseDataStreamMarshaller.cpp Sat Feb 3 17:44:14 2007 @@ -222,13 +222,13 @@ bs->writeBoolean( value == "" ); if( value != "" ) { - int strlen = value.length(); + size_t strlen = value.length(); int utflen = 0; int c = 0; bool isOnlyAscii = true; - for( int i = 0; i < strlen; ++i ) { + for( size_t i = 0; i < strlen; ++i ) { c = value[i]; if( (c >= 0x0001) && (c <= 0x007F) ) // ASCII char @@ -661,11 +661,11 @@ if( wireFormat->isStackTraceEnabled() ) { - int length = error->getStackTraceElements().size(); + size_t length = error->getStackTraceElements().size(); dataOut->writeShort( (short)length ); - for( int i = 0; i < length; ++i ) { + for( size_t i = 0; i < length; ++i ) { BrokerError::StackTraceElement* element = error->getStackTraceElements()[i]; @@ -829,7 +829,7 @@ // Now build a string and copy data into it. std::string text; text.resize( size ); - text.copy( (char*)data, size ); + text.assign( (char*)data, (int)size ); delete data; return text; Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/ActiveMQDestinationMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/ActiveMQDestinationMarshaller.h?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/ActiveMQDestinationMarshaller.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/ActiveMQDestinationMarshaller.h Sat Feb 3 17:44:14 2007 @@ -53,18 +53,6 @@ virtual ~ActiveMQDestinationMarshaller() {} /** - * Creates a new instance of this marshalable type. - * @return new DataStructure object pointer caller owns it. - */ - virtual commands::DataStructure* createObject() const; - - /** - * Get the Data Structure Type that identifies this Marshaller - * @return byte holding the data structure type value - */ - virtual unsigned char getDataStructureType() const; - - /** * Un-marshal an object instance from the data input stream * @param wireFormat - describs the wire format of the broker * @param o - Object to be un-marshaled Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/ActiveMQTempDestinationMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/ActiveMQTempDestinationMarshaller.h?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/ActiveMQTempDestinationMarshaller.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/ActiveMQTempDestinationMarshaller.h Sat Feb 3 17:44:14 2007 @@ -53,18 +53,6 @@ virtual ~ActiveMQTempDestinationMarshaller() {} /** - * Creates a new instance of this marshalable type. - * @return new DataStructure object pointer caller owns it. - */ - virtual commands::DataStructure* createObject() const; - - /** - * Get the Data Structure Type that identifies this Marshaller - * @return byte holding the data structure type value - */ - virtual unsigned char getDataStructureType() const; - - /** * Un-marshal an object instance from the data input stream * @param wireFormat - describs the wire format of the broker * @param o - Object to be un-marshaled Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/BaseCommandMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/BaseCommandMarshaller.h?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/BaseCommandMarshaller.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/BaseCommandMarshaller.h Sat Feb 3 17:44:14 2007 @@ -53,18 +53,6 @@ virtual ~BaseCommandMarshaller() {} /** - * Creates a new instance of this marshalable type. - * @return new DataStructure object pointer caller owns it. - */ - virtual commands::DataStructure* createObject() const; - - /** - * Get the Data Structure Type that identifies this Marshaller - * @return byte holding the data structure type value - */ - virtual unsigned char getDataStructureType() const; - - /** * Un-marshal an object instance from the data input stream * @param wireFormat - describs the wire format of the broker * @param o - Object to be un-marshaled Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/MessageMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/MessageMarshaller.cpp?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/MessageMarshaller.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/MessageMarshaller.cpp Sat Feb 3 17:44:14 2007 @@ -111,9 +111,9 @@ rc += tightMarshalLong1( wireFormat, info->getTimestamp(), bs ); rc += tightMarshalString1( info->getType(), bs ); bs->writeBoolean( info->getContent().size() != 0 ); - rc += info->getContent().size() == 0 ? 0 : info->getContent().size() + 4; + rc += (int)(info->getContent().size() == 0 ? 0 : info->getContent().size() + 4); bs->writeBoolean( info->getMarshalledProperties().size() != 0 ); - rc += info->getMarshalledProperties().size() == 0 ? 0 : info->getMarshalledProperties().size() + 4; + rc += (int)(info->getMarshalledProperties().size() == 0 ? 0 : info->getMarshalledProperties().size() + 4); rc += tightMarshalNestedObject1( wireFormat, info->getDataStructure(), bs ); rc += tightMarshalCachedObject1( wireFormat, info->getTargetConsumerId(), bs ); bs->writeBoolean( info->isCompressed() ); @@ -149,11 +149,11 @@ tightMarshalLong2( wireFormat, info->getTimestamp(), dataOut, bs ); tightMarshalString2( info->getType(), dataOut, bs ); if( bs->readBoolean() ) { - dataOut->write( info->getContent().size() ); + dataOut->write( (int)info->getContent().size() ); dataOut->write( &info->getContent()[0], info->getContent().size() ); } if( bs->readBoolean() ) { - dataOut->write( info->getMarshalledProperties().size() ); + dataOut->write( (int)info->getMarshalledProperties().size() ); dataOut->write( &info->getMarshalledProperties()[0], info->getMarshalledProperties().size() ); } tightMarshalNestedObject2( wireFormat, info->getDataStructure(), dataOut, bs ); @@ -245,12 +245,12 @@ looseMarshalString( info->getType(), dataOut ); dataOut->write( info->getContent().size() != 0 ); if( info->getContent().size() != 0 ) { - dataOut->write( info->getContent().size() ); + dataOut->write( (int)info->getContent().size() ); dataOut->write( &info->getContent()[0], info->getContent().size() ); } dataOut->write( info->getMarshalledProperties().size() != 0 ); if( info->getMarshalledProperties().size() != 0 ) { - dataOut->write( info->getMarshalledProperties().size() ); + dataOut->write( (int)info->getMarshalledProperties().size() ); dataOut->write( &info->getMarshalledProperties()[0], info->getMarshalledProperties().size() ); } looseMarshalNestedObject( wireFormat, info->getDataStructure(), dataOut ); Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/MessageMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/MessageMarshaller.h?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/MessageMarshaller.h (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/MessageMarshaller.h Sat Feb 3 17:44:14 2007 @@ -53,18 +53,6 @@ virtual ~MessageMarshaller() {} /** - * Creates a new instance of this marshalable type. - * @return new DataStructure object pointer caller owns it. - */ - virtual commands::DataStructure* createObject() const; - - /** - * Get the Data Structure Type that identifies this Marshaller - * @return byte holding the data structure type value - */ - virtual unsigned char getDataStructureType() const; - - /** * Un-marshal an object instance from the data input stream * @param wireFormat - describs the wire format of the broker * @param o - Object to be un-marshaled Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/PartialCommandMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/PartialCommandMarshaller.cpp?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/PartialCommandMarshaller.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/PartialCommandMarshaller.cpp Sat Feb 3 17:44:14 2007 @@ -64,7 +64,7 @@ int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); bs->writeBoolean( info->getData().size() != 0 ); - rc += info->getData().size() == 0 ? 0 : info->getData().size() + 4; + rc += (int)(info->getData().size() == 0 ? 0 : info->getData().size() + 4); return rc + 4; } @@ -78,7 +78,7 @@ dynamic_cast( dataStructure ); dataOut->write( info->getCommandId() ); if( bs->readBoolean() ) { - dataOut->write( info->getData().size() ); + dataOut->write( (int)info->getData().size() ); dataOut->write( &info->getData()[0], info->getData().size() ); } } @@ -103,7 +103,7 @@ dataOut->write( info->getCommandId() ); dataOut->write( info->getData().size() != 0 ); if( info->getData().size() != 0 ) { - dataOut->write( info->getData().size() ); + dataOut->write( (int)info->getData().size() ); dataOut->write( &info->getData()[0], info->getData().size() ); } } Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/TransactionIdMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/TransactionIdMarshaller.cpp?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/TransactionIdMarshaller.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/TransactionIdMarshaller.cpp Sat Feb 3 17:44:14 2007 @@ -36,6 +36,16 @@ using namespace activemq::connector::openwire::marshal::v2; /////////////////////////////////////////////////////////////////////////////// +unsigned char TransactionIdMarshaller::getDataStructureType() const { + return TransactionId::ID_TRANSACTIONID; +} + +/////////////////////////////////////////////////////////////////////////////// +commands::DataStructure* TransactionIdMarshaller::createObject() const { + return new TransactionId(); +} + +/////////////////////////////////////////////////////////////////////////////// void TransactionIdMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/WireFormatInfoMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/WireFormatInfoMarshaller.cpp?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/WireFormatInfoMarshaller.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/WireFormatInfoMarshaller.cpp Sat Feb 3 17:44:14 2007 @@ -70,7 +70,7 @@ info->beforeMarshal( wireFormat ); int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); bs->writeBoolean( info->getMarshalledProperties().size() != 0 ); - rc += info->getMarshalledProperties().size() == 0 ? 0 : info->getMarshalledProperties().size() + 4; + rc += (int)(info->getMarshalledProperties().size() == 0 ? 0 : info->getMarshalledProperties().size() + 4); return rc + 12; } @@ -85,7 +85,7 @@ dataOut->write( &info->getMagic()[0], 8 ); dataOut->write( info->getVersion() ); if( bs->readBoolean() ) { - dataOut->write( info->getMarshalledProperties().size() ); + dataOut->write( (int)info->getMarshalledProperties().size() ); dataOut->write( &info->getMarshalledProperties()[0], info->getMarshalledProperties().size() ); } info->afterMarshal( wireFormat ); @@ -116,7 +116,7 @@ dataOut->write( info->getVersion() ); dataOut->write( info->getMarshalledProperties().size() != 0 ); if( info->getMarshalledProperties().size() != 0 ) { - dataOut->write( info->getMarshalledProperties().size() ); + dataOut->write( (int)info->getMarshalledProperties().size() ); dataOut->write( &info->getMarshalledProperties()[0], info->getMarshalledProperties().size() ); } info->afterMarshal( wireFormat ); Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/XATransactionIdMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/XATransactionIdMarshaller.cpp?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/XATransactionIdMarshaller.cpp (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/connector/openwire/marshal/v2/XATransactionIdMarshaller.cpp Sat Feb 3 17:44:14 2007 @@ -65,9 +65,9 @@ int rc = TransactionIdMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); bs->writeBoolean( info->getGlobalTransactionId().size() != 0 ); - rc += info->getGlobalTransactionId().size() == 0 ? 0 : info->getGlobalTransactionId().size() + 4; + rc += (int)(info->getGlobalTransactionId().size() == 0 ? 0 : info->getGlobalTransactionId().size() + 4); bs->writeBoolean( info->getBranchQualifier().size() != 0 ); - rc += info->getBranchQualifier().size() == 0 ? 0 : info->getBranchQualifier().size() + 4; + rc += (int)(info->getBranchQualifier().size() == 0 ? 0 : info->getBranchQualifier().size() + 4); return rc + 4; } @@ -81,11 +81,11 @@ dynamic_cast( dataStructure ); dataOut->write( info->getFormatId() ); if( bs->readBoolean() ) { - dataOut->write( info->getGlobalTransactionId().size() ); + dataOut->write( (int)info->getGlobalTransactionId().size() ); dataOut->write( &info->getGlobalTransactionId()[0], info->getGlobalTransactionId().size() ); } if( bs->readBoolean() ) { - dataOut->write( info->getBranchQualifier().size() ); + dataOut->write( (int)info->getBranchQualifier().size() ); dataOut->write( &info->getBranchQualifier()[0], info->getBranchQualifier().size() ); } } @@ -111,12 +111,12 @@ dataOut->write( info->getFormatId() ); dataOut->write( info->getGlobalTransactionId().size() != 0 ); if( info->getGlobalTransactionId().size() != 0 ) { - dataOut->write( info->getGlobalTransactionId().size() ); + dataOut->write( (int)info->getGlobalTransactionId().size() ); dataOut->write( &info->getGlobalTransactionId()[0], info->getGlobalTransactionId().size() ); } dataOut->write( info->getBranchQualifier().size() != 0 ); if( info->getBranchQualifier().size() != 0 ) { - dataOut->write( info->getBranchQualifier().size() ); + dataOut->write( (int)info->getBranchQualifier().size() ); dataOut->write( &info->getBranchQualifier()[0], info->getBranchQualifier().size() ); } } Modified: activemq/activemq-cpp/trunk/activemq-cpp/vs2005-build/vs2005-activemq.vcproj URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/vs2005-build/vs2005-activemq.vcproj?view=diff&rev=503343&r1=503342&r2=503343 ============================================================================== --- activemq/activemq-cpp/trunk/activemq-cpp/vs2005-build/vs2005-activemq.vcproj (original) +++ activemq/activemq-cpp/trunk/activemq-cpp/vs2005-build/vs2005-activemq.vcproj Sat Feb 3 17:44:14 2007 @@ -659,6 +659,54 @@ + + + + + + + + + + + + + + + + + + + + + + + + @@ -691,6 +739,18 @@ Name="marshal" > + + + + + + @@ -698,11 +758,503 @@ RelativePath="..\src\main\activemq\connector\openwire\marshal\PrimitiveMapMarshaller.h" > + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + @@ -711,6 +1263,34 @@ > + + + + + + + + + + + + + + @@ -719,6 +1299,14 @@ > + + + + @@ -743,6 +1331,14 @@ > + + + + @@ -764,6 +1360,382 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +