Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 50715 invoked from network); 12 Jan 2009 22:09:06 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 12 Jan 2009 22:09:06 -0000 Received: (qmail 52938 invoked by uid 500); 12 Jan 2009 22:09:06 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 52899 invoked by uid 500); 12 Jan 2009 22:09:06 -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 52844 invoked by uid 99); 12 Jan 2009 22:09:06 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 12 Jan 2009 14:09:06 -0800 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 12 Jan 2009 22:08:59 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 93AD22388BC1; Mon, 12 Jan 2009 14:08:13 -0800 (PST) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r733927 [8/22] - in /activemq/activemq-cpp/trunk/src: main/ main/activemq/connector/openwire/ main/activemq/connector/openwire/commands/ main/activemq/connector/openwire/marshal/ main/activemq/connector/openwire/utils/ main/activemq/connect... Date: Mon, 12 Jan 2009 22:07:40 -0000 To: commits@activemq.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20090112220813.93AD22388BC1@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshallerTest.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshallerTest.cpp?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshallerTest.cpp (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshallerTest.cpp Mon Jan 12 14:07:09 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include +#include + +CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::v1::RemoveInfoMarshallerTest ); + +#include +#include +#include +#include +#include +#include +#include +#include +#include +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::util; +using namespace activemq::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v1; +using namespace decaf::io; +using namespace decaf::lang; +using namespace decaf::util; + +/////////////////////////////////////////////////////////////////////////////// +void RemoveInfoMarshallerTest::test() { + + RemoveInfoMarshaller myMarshaller; + RemoveInfo myCommand; + RemoveInfo* myCommand2; + + CPPUNIT_ASSERT( myMarshaller.getDataStructureType() == myCommand.getDataStructureType() ); + myCommand2 = dynamic_cast( myMarshaller.createObject() ); + CPPUNIT_ASSERT( myCommand2 != NULL ); + delete myCommand2; +} + +/////////////////////////////////////////////////////////////////////////////// +void RemoveInfoMarshallerTest::testLooseMarshal() { + + RemoveInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( false ); + + RemoveInfo outCommand; + RemoveInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + dataOut.writeByte( outCommand.getDataStructureType() ); + marshaller.looseMarshal( &openWireFormat, &outCommand, &dataOut ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + marshaller.looseUnmarshal( &openWireFormat, &inCommand, &dataIn ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + +/////////////////////////////////////////////////////////////////////////////// +void RemoveInfoMarshallerTest::testTightMarshal() { + + RemoveInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( true ); + + RemoveInfo outCommand; + RemoveInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + // Phase 1 - count the size + int size = 1; + BooleanStream bs; + size += marshaller.tightMarshal1( &openWireFormat, &outCommand, &bs ); + size += bs.marshalledSize(); + // Phase 2 - marshal + dataOut.writeByte( outCommand.getDataStructureType() ); + bs.marshal( &dataOut ); + marshaller.tightMarshal2( &openWireFormat, &outCommand, &dataOut, &bs ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + bs.clear(); + bs.unmarshal( &dataIn ); + marshaller.tightUnmarshal( &openWireFormat, &inCommand, &dataIn, &bs ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshallerTest.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshallerTest.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshallerTest.h?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshallerTest.h (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshallerTest.h Mon Jan 12 14:07:09 2009 @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_REMOVEINFOMARSHALLERTEST_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_REMOVEINFOMARSHALLERTEST_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling Test code for Open Wire Format for RemoveInfoMarshallerTest + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class RemoveInfoMarshallerTest : public CppUnit::TestFixture { + + CPPUNIT_TEST_SUITE( RemoveInfoMarshallerTest ); + CPPUNIT_TEST( test ); + CPPUNIT_TEST( testLooseMarshal ); + CPPUNIT_TEST( testTightMarshal ); + CPPUNIT_TEST_SUITE_END(); + + public: + + RemoveInfoMarshallerTest() {} + virtual ~RemoveInfoMarshallerTest() {} + + /** + * Test the marshaller and its marshalled type. + */ + virtual void test(); + virtual void testLooseMarshal(); + virtual void testTightMarshal(); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_REMOVEINFOMARSHALLERTEST_H_*/ Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveInfoMarshallerTest.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshallerTest.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshallerTest.cpp?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshallerTest.cpp (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshallerTest.cpp Mon Jan 12 14:07:09 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include +#include + +CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::v1::RemoveSubscriptionInfoMarshallerTest ); + +#include +#include +#include +#include +#include +#include +#include +#include +#include +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::util; +using namespace activemq::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v1; +using namespace decaf::io; +using namespace decaf::lang; +using namespace decaf::util; + +/////////////////////////////////////////////////////////////////////////////// +void RemoveSubscriptionInfoMarshallerTest::test() { + + RemoveSubscriptionInfoMarshaller myMarshaller; + RemoveSubscriptionInfo myCommand; + RemoveSubscriptionInfo* myCommand2; + + CPPUNIT_ASSERT( myMarshaller.getDataStructureType() == myCommand.getDataStructureType() ); + myCommand2 = dynamic_cast( myMarshaller.createObject() ); + CPPUNIT_ASSERT( myCommand2 != NULL ); + delete myCommand2; +} + +/////////////////////////////////////////////////////////////////////////////// +void RemoveSubscriptionInfoMarshallerTest::testLooseMarshal() { + + RemoveSubscriptionInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( false ); + + RemoveSubscriptionInfo outCommand; + RemoveSubscriptionInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + dataOut.writeByte( outCommand.getDataStructureType() ); + marshaller.looseMarshal( &openWireFormat, &outCommand, &dataOut ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + marshaller.looseUnmarshal( &openWireFormat, &inCommand, &dataIn ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + +/////////////////////////////////////////////////////////////////////////////// +void RemoveSubscriptionInfoMarshallerTest::testTightMarshal() { + + RemoveSubscriptionInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( true ); + + RemoveSubscriptionInfo outCommand; + RemoveSubscriptionInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + // Phase 1 - count the size + int size = 1; + BooleanStream bs; + size += marshaller.tightMarshal1( &openWireFormat, &outCommand, &bs ); + size += bs.marshalledSize(); + // Phase 2 - marshal + dataOut.writeByte( outCommand.getDataStructureType() ); + bs.marshal( &dataOut ); + marshaller.tightMarshal2( &openWireFormat, &outCommand, &dataOut, &bs ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + bs.clear(); + bs.unmarshal( &dataIn ); + marshaller.tightUnmarshal( &openWireFormat, &inCommand, &dataIn, &bs ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshallerTest.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshallerTest.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshallerTest.h?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshallerTest.h (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshallerTest.h Mon Jan 12 14:07:09 2009 @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_REMOVESUBSCRIPTIONINFOMARSHALLERTEST_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_REMOVESUBSCRIPTIONINFOMARSHALLERTEST_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling Test code for Open Wire Format for RemoveSubscriptionInfoMarshallerTest + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class RemoveSubscriptionInfoMarshallerTest : public CppUnit::TestFixture { + + CPPUNIT_TEST_SUITE( RemoveSubscriptionInfoMarshallerTest ); + CPPUNIT_TEST( test ); + CPPUNIT_TEST( testLooseMarshal ); + CPPUNIT_TEST( testTightMarshal ); + CPPUNIT_TEST_SUITE_END(); + + public: + + RemoveSubscriptionInfoMarshallerTest() {} + virtual ~RemoveSubscriptionInfoMarshallerTest() {} + + /** + * Test the marshaller and its marshalled type. + */ + virtual void test(); + virtual void testLooseMarshal(); + virtual void testTightMarshal(); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_REMOVESUBSCRIPTIONINFOMARSHALLERTEST_H_*/ Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/RemoveSubscriptionInfoMarshallerTest.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshallerTest.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshallerTest.cpp?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshallerTest.cpp (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshallerTest.cpp Mon Jan 12 14:07:09 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include +#include + +CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::v1::ReplayCommandMarshallerTest ); + +#include +#include +#include +#include +#include +#include +#include +#include +#include +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::util; +using namespace activemq::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v1; +using namespace decaf::io; +using namespace decaf::lang; +using namespace decaf::util; + +/////////////////////////////////////////////////////////////////////////////// +void ReplayCommandMarshallerTest::test() { + + ReplayCommandMarshaller myMarshaller; + ReplayCommand myCommand; + ReplayCommand* myCommand2; + + CPPUNIT_ASSERT( myMarshaller.getDataStructureType() == myCommand.getDataStructureType() ); + myCommand2 = dynamic_cast( myMarshaller.createObject() ); + CPPUNIT_ASSERT( myCommand2 != NULL ); + delete myCommand2; +} + +/////////////////////////////////////////////////////////////////////////////// +void ReplayCommandMarshallerTest::testLooseMarshal() { + + ReplayCommandMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( false ); + + ReplayCommand outCommand; + ReplayCommand inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + dataOut.writeByte( outCommand.getDataStructureType() ); + marshaller.looseMarshal( &openWireFormat, &outCommand, &dataOut ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + marshaller.looseUnmarshal( &openWireFormat, &inCommand, &dataIn ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + +/////////////////////////////////////////////////////////////////////////////// +void ReplayCommandMarshallerTest::testTightMarshal() { + + ReplayCommandMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( true ); + + ReplayCommand outCommand; + ReplayCommand inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + // Phase 1 - count the size + int size = 1; + BooleanStream bs; + size += marshaller.tightMarshal1( &openWireFormat, &outCommand, &bs ); + size += bs.marshalledSize(); + // Phase 2 - marshal + dataOut.writeByte( outCommand.getDataStructureType() ); + bs.marshal( &dataOut ); + marshaller.tightMarshal2( &openWireFormat, &outCommand, &dataOut, &bs ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + bs.clear(); + bs.unmarshal( &dataIn ); + marshaller.tightUnmarshal( &openWireFormat, &inCommand, &dataIn, &bs ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshallerTest.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshallerTest.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshallerTest.h?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshallerTest.h (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshallerTest.h Mon Jan 12 14:07:09 2009 @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_REPLAYCOMMANDMARSHALLERTEST_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_REPLAYCOMMANDMARSHALLERTEST_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling Test code for Open Wire Format for ReplayCommandMarshallerTest + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class ReplayCommandMarshallerTest : public CppUnit::TestFixture { + + CPPUNIT_TEST_SUITE( ReplayCommandMarshallerTest ); + CPPUNIT_TEST( test ); + CPPUNIT_TEST( testLooseMarshal ); + CPPUNIT_TEST( testTightMarshal ); + CPPUNIT_TEST_SUITE_END(); + + public: + + ReplayCommandMarshallerTest() {} + virtual ~ReplayCommandMarshallerTest() {} + + /** + * Test the marshaller and its marshalled type. + */ + virtual void test(); + virtual void testLooseMarshal(); + virtual void testTightMarshal(); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_REPLAYCOMMANDMARSHALLERTEST_H_*/ Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ReplayCommandMarshallerTest.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ResponseMarshallerTest.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ResponseMarshallerTest.cpp?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ResponseMarshallerTest.cpp (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ResponseMarshallerTest.cpp Mon Jan 12 14:07:09 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include +#include + +CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::v1::ResponseMarshallerTest ); + +#include +#include +#include +#include +#include +#include +#include +#include +#include +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::util; +using namespace activemq::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v1; +using namespace decaf::io; +using namespace decaf::lang; +using namespace decaf::util; + +/////////////////////////////////////////////////////////////////////////////// +void ResponseMarshallerTest::test() { + + ResponseMarshaller myMarshaller; + Response myCommand; + Response* myCommand2; + + CPPUNIT_ASSERT( myMarshaller.getDataStructureType() == myCommand.getDataStructureType() ); + myCommand2 = dynamic_cast( myMarshaller.createObject() ); + CPPUNIT_ASSERT( myCommand2 != NULL ); + delete myCommand2; +} + +/////////////////////////////////////////////////////////////////////////////// +void ResponseMarshallerTest::testLooseMarshal() { + + ResponseMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( false ); + + Response outCommand; + Response inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + dataOut.writeByte( outCommand.getDataStructureType() ); + marshaller.looseMarshal( &openWireFormat, &outCommand, &dataOut ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + marshaller.looseUnmarshal( &openWireFormat, &inCommand, &dataIn ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + +/////////////////////////////////////////////////////////////////////////////// +void ResponseMarshallerTest::testTightMarshal() { + + ResponseMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( true ); + + Response outCommand; + Response inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + // Phase 1 - count the size + int size = 1; + BooleanStream bs; + size += marshaller.tightMarshal1( &openWireFormat, &outCommand, &bs ); + size += bs.marshalledSize(); + // Phase 2 - marshal + dataOut.writeByte( outCommand.getDataStructureType() ); + bs.marshal( &dataOut ); + marshaller.tightMarshal2( &openWireFormat, &outCommand, &dataOut, &bs ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + bs.clear(); + bs.unmarshal( &dataIn ); + marshaller.tightUnmarshal( &openWireFormat, &inCommand, &dataIn, &bs ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ResponseMarshallerTest.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ResponseMarshallerTest.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ResponseMarshallerTest.h?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ResponseMarshallerTest.h (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ResponseMarshallerTest.h Mon Jan 12 14:07:09 2009 @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_RESPONSEMARSHALLERTEST_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_RESPONSEMARSHALLERTEST_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling Test code for Open Wire Format for ResponseMarshallerTest + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class ResponseMarshallerTest : public CppUnit::TestFixture { + + CPPUNIT_TEST_SUITE( ResponseMarshallerTest ); + CPPUNIT_TEST( test ); + CPPUNIT_TEST( testLooseMarshal ); + CPPUNIT_TEST( testTightMarshal ); + CPPUNIT_TEST_SUITE_END(); + + public: + + ResponseMarshallerTest() {} + virtual ~ResponseMarshallerTest() {} + + /** + * Test the marshaller and its marshalled type. + */ + virtual void test(); + virtual void testLooseMarshal(); + virtual void testTightMarshal(); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_RESPONSEMARSHALLERTEST_H_*/ Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ResponseMarshallerTest.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionIdMarshallerTest.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionIdMarshallerTest.cpp?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionIdMarshallerTest.cpp (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionIdMarshallerTest.cpp Mon Jan 12 14:07:09 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include +#include + +CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::v1::SessionIdMarshallerTest ); + +#include +#include +#include +#include +#include +#include +#include +#include +#include +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::util; +using namespace activemq::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v1; +using namespace decaf::io; +using namespace decaf::lang; +using namespace decaf::util; + +/////////////////////////////////////////////////////////////////////////////// +void SessionIdMarshallerTest::test() { + + SessionIdMarshaller myMarshaller; + SessionId myCommand; + SessionId* myCommand2; + + CPPUNIT_ASSERT( myMarshaller.getDataStructureType() == myCommand.getDataStructureType() ); + myCommand2 = dynamic_cast( myMarshaller.createObject() ); + CPPUNIT_ASSERT( myCommand2 != NULL ); + delete myCommand2; +} + +/////////////////////////////////////////////////////////////////////////////// +void SessionIdMarshallerTest::testLooseMarshal() { + + SessionIdMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( false ); + + SessionId outCommand; + SessionId inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + dataOut.writeByte( outCommand.getDataStructureType() ); + marshaller.looseMarshal( &openWireFormat, &outCommand, &dataOut ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + marshaller.looseUnmarshal( &openWireFormat, &inCommand, &dataIn ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + +/////////////////////////////////////////////////////////////////////////////// +void SessionIdMarshallerTest::testTightMarshal() { + + SessionIdMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( true ); + + SessionId outCommand; + SessionId inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + // Phase 1 - count the size + int size = 1; + BooleanStream bs; + size += marshaller.tightMarshal1( &openWireFormat, &outCommand, &bs ); + size += bs.marshalledSize(); + // Phase 2 - marshal + dataOut.writeByte( outCommand.getDataStructureType() ); + bs.marshal( &dataOut ); + marshaller.tightMarshal2( &openWireFormat, &outCommand, &dataOut, &bs ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + bs.clear(); + bs.unmarshal( &dataIn ); + marshaller.tightUnmarshal( &openWireFormat, &inCommand, &dataIn, &bs ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionIdMarshallerTest.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionIdMarshallerTest.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionIdMarshallerTest.h?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionIdMarshallerTest.h (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionIdMarshallerTest.h Mon Jan 12 14:07:09 2009 @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SESSIONIDMARSHALLERTEST_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SESSIONIDMARSHALLERTEST_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling Test code for Open Wire Format for SessionIdMarshallerTest + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class SessionIdMarshallerTest : public CppUnit::TestFixture { + + CPPUNIT_TEST_SUITE( SessionIdMarshallerTest ); + CPPUNIT_TEST( test ); + CPPUNIT_TEST( testLooseMarshal ); + CPPUNIT_TEST( testTightMarshal ); + CPPUNIT_TEST_SUITE_END(); + + public: + + SessionIdMarshallerTest() {} + virtual ~SessionIdMarshallerTest() {} + + /** + * Test the marshaller and its marshalled type. + */ + virtual void test(); + virtual void testLooseMarshal(); + virtual void testTightMarshal(); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SESSIONIDMARSHALLERTEST_H_*/ Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionIdMarshallerTest.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshallerTest.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshallerTest.cpp?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshallerTest.cpp (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshallerTest.cpp Mon Jan 12 14:07:09 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include +#include + +CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::v1::SessionInfoMarshallerTest ); + +#include +#include +#include +#include +#include +#include +#include +#include +#include +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::util; +using namespace activemq::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v1; +using namespace decaf::io; +using namespace decaf::lang; +using namespace decaf::util; + +/////////////////////////////////////////////////////////////////////////////// +void SessionInfoMarshallerTest::test() { + + SessionInfoMarshaller myMarshaller; + SessionInfo myCommand; + SessionInfo* myCommand2; + + CPPUNIT_ASSERT( myMarshaller.getDataStructureType() == myCommand.getDataStructureType() ); + myCommand2 = dynamic_cast( myMarshaller.createObject() ); + CPPUNIT_ASSERT( myCommand2 != NULL ); + delete myCommand2; +} + +/////////////////////////////////////////////////////////////////////////////// +void SessionInfoMarshallerTest::testLooseMarshal() { + + SessionInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( false ); + + SessionInfo outCommand; + SessionInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + dataOut.writeByte( outCommand.getDataStructureType() ); + marshaller.looseMarshal( &openWireFormat, &outCommand, &dataOut ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + marshaller.looseUnmarshal( &openWireFormat, &inCommand, &dataIn ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + +/////////////////////////////////////////////////////////////////////////////// +void SessionInfoMarshallerTest::testTightMarshal() { + + SessionInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( true ); + + SessionInfo outCommand; + SessionInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + // Phase 1 - count the size + int size = 1; + BooleanStream bs; + size += marshaller.tightMarshal1( &openWireFormat, &outCommand, &bs ); + size += bs.marshalledSize(); + // Phase 2 - marshal + dataOut.writeByte( outCommand.getDataStructureType() ); + bs.marshal( &dataOut ); + marshaller.tightMarshal2( &openWireFormat, &outCommand, &dataOut, &bs ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + bs.clear(); + bs.unmarshal( &dataIn ); + marshaller.tightUnmarshal( &openWireFormat, &inCommand, &dataIn, &bs ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshallerTest.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshallerTest.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshallerTest.h?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshallerTest.h (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshallerTest.h Mon Jan 12 14:07:09 2009 @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SESSIONINFOMARSHALLERTEST_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SESSIONINFOMARSHALLERTEST_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling Test code for Open Wire Format for SessionInfoMarshallerTest + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class SessionInfoMarshallerTest : public CppUnit::TestFixture { + + CPPUNIT_TEST_SUITE( SessionInfoMarshallerTest ); + CPPUNIT_TEST( test ); + CPPUNIT_TEST( testLooseMarshal ); + CPPUNIT_TEST( testTightMarshal ); + CPPUNIT_TEST_SUITE_END(); + + public: + + SessionInfoMarshallerTest() {} + virtual ~SessionInfoMarshallerTest() {} + + /** + * Test the marshaller and its marshalled type. + */ + virtual void test(); + virtual void testLooseMarshal(); + virtual void testTightMarshal(); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SESSIONINFOMARSHALLERTEST_H_*/ Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SessionInfoMarshallerTest.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshallerTest.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshallerTest.cpp?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshallerTest.cpp (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshallerTest.cpp Mon Jan 12 14:07:09 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include +#include + +CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::v1::ShutdownInfoMarshallerTest ); + +#include +#include +#include +#include +#include +#include +#include +#include +#include +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::util; +using namespace activemq::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v1; +using namespace decaf::io; +using namespace decaf::lang; +using namespace decaf::util; + +/////////////////////////////////////////////////////////////////////////////// +void ShutdownInfoMarshallerTest::test() { + + ShutdownInfoMarshaller myMarshaller; + ShutdownInfo myCommand; + ShutdownInfo* myCommand2; + + CPPUNIT_ASSERT( myMarshaller.getDataStructureType() == myCommand.getDataStructureType() ); + myCommand2 = dynamic_cast( myMarshaller.createObject() ); + CPPUNIT_ASSERT( myCommand2 != NULL ); + delete myCommand2; +} + +/////////////////////////////////////////////////////////////////////////////// +void ShutdownInfoMarshallerTest::testLooseMarshal() { + + ShutdownInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( false ); + + ShutdownInfo outCommand; + ShutdownInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + dataOut.writeByte( outCommand.getDataStructureType() ); + marshaller.looseMarshal( &openWireFormat, &outCommand, &dataOut ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + marshaller.looseUnmarshal( &openWireFormat, &inCommand, &dataIn ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + +/////////////////////////////////////////////////////////////////////////////// +void ShutdownInfoMarshallerTest::testTightMarshal() { + + ShutdownInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( true ); + + ShutdownInfo outCommand; + ShutdownInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + // Phase 1 - count the size + int size = 1; + BooleanStream bs; + size += marshaller.tightMarshal1( &openWireFormat, &outCommand, &bs ); + size += bs.marshalledSize(); + // Phase 2 - marshal + dataOut.writeByte( outCommand.getDataStructureType() ); + bs.marshal( &dataOut ); + marshaller.tightMarshal2( &openWireFormat, &outCommand, &dataOut, &bs ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + bs.clear(); + bs.unmarshal( &dataIn ); + marshaller.tightUnmarshal( &openWireFormat, &inCommand, &dataIn, &bs ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshallerTest.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshallerTest.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshallerTest.h?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshallerTest.h (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshallerTest.h Mon Jan 12 14:07:09 2009 @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SHUTDOWNINFOMARSHALLERTEST_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SHUTDOWNINFOMARSHALLERTEST_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling Test code for Open Wire Format for ShutdownInfoMarshallerTest + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class ShutdownInfoMarshallerTest : public CppUnit::TestFixture { + + CPPUNIT_TEST_SUITE( ShutdownInfoMarshallerTest ); + CPPUNIT_TEST( test ); + CPPUNIT_TEST( testLooseMarshal ); + CPPUNIT_TEST( testTightMarshal ); + CPPUNIT_TEST_SUITE_END(); + + public: + + ShutdownInfoMarshallerTest() {} + virtual ~ShutdownInfoMarshallerTest() {} + + /** + * Test the marshaller and its marshalled type. + */ + virtual void test(); + virtual void testLooseMarshal(); + virtual void testTightMarshal(); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SHUTDOWNINFOMARSHALLERTEST_H_*/ Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/ShutdownInfoMarshallerTest.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshallerTest.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshallerTest.cpp?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshallerTest.cpp (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshallerTest.cpp Mon Jan 12 14:07:09 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include +#include + +CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::v1::SubscriptionInfoMarshallerTest ); + +#include +#include +#include +#include +#include +#include +#include +#include +#include +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::util; +using namespace activemq::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v1; +using namespace decaf::io; +using namespace decaf::lang; +using namespace decaf::util; + +/////////////////////////////////////////////////////////////////////////////// +void SubscriptionInfoMarshallerTest::test() { + + SubscriptionInfoMarshaller myMarshaller; + SubscriptionInfo myCommand; + SubscriptionInfo* myCommand2; + + CPPUNIT_ASSERT( myMarshaller.getDataStructureType() == myCommand.getDataStructureType() ); + myCommand2 = dynamic_cast( myMarshaller.createObject() ); + CPPUNIT_ASSERT( myCommand2 != NULL ); + delete myCommand2; +} + +/////////////////////////////////////////////////////////////////////////////// +void SubscriptionInfoMarshallerTest::testLooseMarshal() { + + SubscriptionInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( false ); + + SubscriptionInfo outCommand; + SubscriptionInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + dataOut.writeByte( outCommand.getDataStructureType() ); + marshaller.looseMarshal( &openWireFormat, &outCommand, &dataOut ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + marshaller.looseUnmarshal( &openWireFormat, &inCommand, &dataIn ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + +/////////////////////////////////////////////////////////////////////////////// +void SubscriptionInfoMarshallerTest::testTightMarshal() { + + SubscriptionInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( true ); + + SubscriptionInfo outCommand; + SubscriptionInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + // Phase 1 - count the size + int size = 1; + BooleanStream bs; + size += marshaller.tightMarshal1( &openWireFormat, &outCommand, &bs ); + size += bs.marshalledSize(); + // Phase 2 - marshal + dataOut.writeByte( outCommand.getDataStructureType() ); + bs.marshal( &dataOut ); + marshaller.tightMarshal2( &openWireFormat, &outCommand, &dataOut, &bs ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + bs.clear(); + bs.unmarshal( &dataIn ); + marshaller.tightUnmarshal( &openWireFormat, &inCommand, &dataIn, &bs ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshallerTest.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshallerTest.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshallerTest.h?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshallerTest.h (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshallerTest.h Mon Jan 12 14:07:09 2009 @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SUBSCRIPTIONINFOMARSHALLERTEST_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SUBSCRIPTIONINFOMARSHALLERTEST_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling Test code for Open Wire Format for SubscriptionInfoMarshallerTest + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class SubscriptionInfoMarshallerTest : public CppUnit::TestFixture { + + CPPUNIT_TEST_SUITE( SubscriptionInfoMarshallerTest ); + CPPUNIT_TEST( test ); + CPPUNIT_TEST( testLooseMarshal ); + CPPUNIT_TEST( testTightMarshal ); + CPPUNIT_TEST_SUITE_END(); + + public: + + SubscriptionInfoMarshallerTest() {} + virtual ~SubscriptionInfoMarshallerTest() {} + + /** + * Test the marshaller and its marshalled type. + */ + virtual void test(); + virtual void testLooseMarshal(); + virtual void testTightMarshal(); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_SUBSCRIPTIONINFOMARSHALLERTEST_H_*/ Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/SubscriptionInfoMarshallerTest.h ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshallerTest.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshallerTest.cpp?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshallerTest.cpp (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshallerTest.cpp Mon Jan 12 14:07:09 2009 @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include + +#include +#include + +CPPUNIT_TEST_SUITE_REGISTRATION( activemq::wireformat::openwire::marshal::v1::TransactionInfoMarshallerTest ); + +#include +#include +#include +#include +#include +#include +#include +#include +#include +// +// NOTE!: This file is autogenerated - do not modify! +// if you need to make a change, please see the Java Classes in the +// activemq-core module +// + +using namespace std; +using namespace activemq; +using namespace activemq::util; +using namespace activemq::exceptions; +using namespace activemq::commands; +using namespace activemq::wireformat; +using namespace activemq::wireformat::openwire; +using namespace activemq::wireformat::openwire::marshal; +using namespace activemq::wireformat::openwire::utils; +using namespace activemq::wireformat::openwire::marshal::v1; +using namespace decaf::io; +using namespace decaf::lang; +using namespace decaf::util; + +/////////////////////////////////////////////////////////////////////////////// +void TransactionInfoMarshallerTest::test() { + + TransactionInfoMarshaller myMarshaller; + TransactionInfo myCommand; + TransactionInfo* myCommand2; + + CPPUNIT_ASSERT( myMarshaller.getDataStructureType() == myCommand.getDataStructureType() ); + myCommand2 = dynamic_cast( myMarshaller.createObject() ); + CPPUNIT_ASSERT( myCommand2 != NULL ); + delete myCommand2; +} + +/////////////////////////////////////////////////////////////////////////////// +void TransactionInfoMarshallerTest::testLooseMarshal() { + + TransactionInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( false ); + + TransactionInfo outCommand; + TransactionInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + dataOut.writeByte( outCommand.getDataStructureType() ); + marshaller.looseMarshal( &openWireFormat, &outCommand, &dataOut ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + marshaller.looseUnmarshal( &openWireFormat, &inCommand, &dataIn ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + +/////////////////////////////////////////////////////////////////////////////// +void TransactionInfoMarshallerTest::testTightMarshal() { + + TransactionInfoMarshaller marshaller; + Properties props; + OpenWireFormat openWireFormat( props ); + + // Configure for this test. + openWireFormat.setVersion( 1 ); + openWireFormat.setTightEncodingEnabled( true ); + + TransactionInfo outCommand; + TransactionInfo inCommand; + + try { + + // Marshal the dataStructure to a byte array. + ByteArrayOutputStream baos; + DataOutputStream dataOut( &baos ); + // Phase 1 - count the size + int size = 1; + BooleanStream bs; + size += marshaller.tightMarshal1( &openWireFormat, &outCommand, &bs ); + size += bs.marshalledSize(); + // Phase 2 - marshal + dataOut.writeByte( outCommand.getDataStructureType() ); + bs.marshal( &dataOut ); + marshaller.tightMarshal2( &openWireFormat, &outCommand, &dataOut, &bs ); + + // Now read it back in and make sure it's all right. + ByteArrayInputStream bais( baos.toByteArray(), baos.size() ); + DataInputStream dataIn( &bais ); + + unsigned char dataType = dataIn.readByte(); + CPPUNIT_ASSERT( dataType == outCommand.getDataStructureType() ); + bs.clear(); + bs.unmarshal( &dataIn ); + marshaller.tightUnmarshal( &openWireFormat, &inCommand, &dataIn, &bs ); + + CPPUNIT_ASSERT( inCommand.equals( &outCommand ) == true ); + + } catch( ActiveMQException& e ) { + e.printStackTrace(); + CPPUNIT_ASSERT( false ); + } catch( ... ) { + CPPUNIT_ASSERT( false ); + } +} + Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshallerTest.cpp ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshallerTest.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshallerTest.h?rev=733927&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshallerTest.h (added) +++ activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshallerTest.h Mon Jan 12 14:07:09 2009 @@ -0,0 +1,66 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_TRANSACTIONINFOMARSHALLERTEST_H_ +#define _ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_TRANSACTIONINFOMARSHALLERTEST_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include +#include + +namespace activemq{ +namespace wireformat{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling Test code for Open Wire Format for TransactionInfoMarshallerTest + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Java Classes + * in the activemq-openwire-generator module + */ + class TransactionInfoMarshallerTest : public CppUnit::TestFixture { + + CPPUNIT_TEST_SUITE( TransactionInfoMarshallerTest ); + CPPUNIT_TEST( test ); + CPPUNIT_TEST( testLooseMarshal ); + CPPUNIT_TEST( testTightMarshal ); + CPPUNIT_TEST_SUITE_END(); + + public: + + TransactionInfoMarshallerTest() {} + virtual ~TransactionInfoMarshallerTest() {} + + /** + * Test the marshaller and its marshalled type. + */ + virtual void test(); + virtual void testLooseMarshal(); + virtual void testTightMarshal(); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_WIREFORMAT_OPENWIRE_MARSAHAL_V1_TRANSACTIONINFOMARSHALLERTEST_H_*/ Propchange: activemq/activemq-cpp/trunk/src/test/activemq/wireformat/openwire/marshal/v1/TransactionInfoMarshallerTest.h ------------------------------------------------------------------------------ svn:eol-style = native