Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 91052 invoked from network); 18 Oct 2007 13:12:18 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 18 Oct 2007 13:12:18 -0000 Received: (qmail 17319 invoked by uid 500); 18 Oct 2007 13:12:06 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 17301 invoked by uid 500); 18 Oct 2007 13:12: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 17291 invoked by uid 99); 18 Oct 2007 13:12:06 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 18 Oct 2007 06:12:06 -0700 X-ASF-Spam-Status: No, hits=-100.0 required=10.0 tests=ALL_TRUSTED 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; Thu, 18 Oct 2007 13:12:16 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 1867A1A9832; Thu, 18 Oct 2007 06:11:26 -0700 (PDT) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r585955 [1/10] - /activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ Date: Thu, 18 Oct 2007 13:11:14 -0000 To: commits@activemq.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20071018131126.1867A1A9832@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: tabish Date: Thu Oct 18 06:11:09 2007 New Revision: 585955 URL: http://svn.apache.org/viewvc?rev=585955&view=rev Log: https://issues.apache.org/activemq/browse/AMQCPP-142 Adding in Openwire V1 support code. Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQDestinationMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQDestinationMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMapMessageMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMapMessageMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMessageMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMessageMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQQueueMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQQueueMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQStreamMessageMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQStreamMessageMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQTempDestinationMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQTempDestinationMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQTempQueueMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQTempQueueMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQTempTopicMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQTempTopicMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQTextMessageMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQTextMessageMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQTopicMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQTopicMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/BaseCommandMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/BaseCommandMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/BrokerIdMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/BrokerIdMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/BrokerInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/BrokerInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConnectionControlMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConnectionControlMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConnectionErrorMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConnectionErrorMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConnectionIdMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConnectionIdMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConnectionInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConnectionInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConsumerControlMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConsumerControlMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConsumerIdMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConsumerIdMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConsumerInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ConsumerInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ControlCommandMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ControlCommandMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/DataArrayResponseMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/DataArrayResponseMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/DataResponseMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/DataResponseMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/DestinationInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/DestinationInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/DiscoveryEventMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/DiscoveryEventMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ExceptionResponseMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ExceptionResponseMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/FlushCommandMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/FlushCommandMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/IntegerResponseMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/IntegerResponseMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/JournalQueueAckMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/JournalQueueAckMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/JournalTopicAckMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/JournalTopicAckMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/JournalTraceMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/JournalTraceMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/JournalTransactionMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/JournalTransactionMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/KeepAliveInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/KeepAliveInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/LastPartialCommandMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/LastPartialCommandMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/LocalTransactionIdMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/LocalTransactionIdMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MarshallerFactory.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MarshallerFactory.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessageAckMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessageAckMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessageDispatchMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessageDispatchMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessageDispatchNotificationMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessageDispatchNotificationMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessageIdMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessageIdMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessageMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessageMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessagePullMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/MessagePullMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/NetworkBridgeFilterMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/NetworkBridgeFilterMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/PartialCommandMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/PartialCommandMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ProducerIdMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ProducerIdMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ProducerInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ProducerInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/RemoveInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/RemoveInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/RemoveSubscriptionInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/RemoveSubscriptionInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ReplayCommandMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ReplayCommandMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ResponseMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ResponseMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SessionIdMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SessionIdMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SessionInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SessionInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ShutdownInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ShutdownInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SubscriptionInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/SubscriptionInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionIdMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionIdMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/TransactionInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/WireFormatInfoMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/WireFormatInfoMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/XATransactionIdMarshaller.cpp activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/XATransactionIdMarshaller.h activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/srcmakefile.mk Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,133 @@ +/* + * 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 + +// +// 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::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ActiveMQBytesMessageMarshaller::createObject() const { + return new ActiveMQBytesMessage(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ActiveMQBytesMessageMarshaller::getDataStructureType() const { + return ActiveMQBytesMessage::ID_ACTIVEMQBYTESMESSAGE; +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBytesMessageMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + MessageMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ActiveMQBytesMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + + + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQBytesMessageMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + ActiveMQBytesMessage* info = + dynamic_cast( dataStructure ); + + info->beforeMarshal( wireFormat ); + int rc = MessageMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBytesMessageMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + MessageMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ActiveMQBytesMessage* info = + dynamic_cast( dataStructure ); + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBytesMessageMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + MessageMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ActiveMQBytesMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQBytesMessageMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + ActiveMQBytesMessage* info = + dynamic_cast( dataStructure ); + info->beforeMarshal( wireFormat ); + MessageMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQBytesMessageMarshaller.h Thu Oct 18 06:11:09 2007 @@ -0,0 +1,127 @@ +/* + * 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_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQBYTESMESSAGEMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQBYTESMESSAGEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for ActiveMQBytesMessageMarshaller + * + * 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 ActiveMQBytesMessageMarshaller : public MessageMarshaller + { + public: + + ActiveMQBytesMessageMarshaller() {} + virtual ~ActiveMQBytesMessageMarshaller() {} + + /** + * 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 + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQBYTESMESSAGEMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQDestinationMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQDestinationMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQDestinationMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQDestinationMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,118 @@ +/* + * 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 + +// +// 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::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQDestinationMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ActiveMQDestination* info = + dynamic_cast( dataStructure ); + info->setPhysicalName( tightUnmarshalString( dataIn, bs ) ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQDestinationMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + ActiveMQDestination* info = + dynamic_cast( dataStructure ); + + int rc = BaseDataStreamMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + rc += tightMarshalString1( info->getPhysicalName(), bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQDestinationMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ActiveMQDestination* info = + dynamic_cast( dataStructure ); + tightMarshalString2( info->getPhysicalName(), dataOut, bs ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQDestinationMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + BaseDataStreamMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ActiveMQDestination* info = + dynamic_cast( dataStructure ); + info->setPhysicalName( looseUnmarshalString( dataIn ) ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQDestinationMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + ActiveMQDestination* info = + dynamic_cast( dataStructure ); + BaseDataStreamMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + looseMarshalString( info->getPhysicalName(), dataOut ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQDestinationMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQDestinationMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQDestinationMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQDestinationMarshaller.h Thu Oct 18 06:11:09 2007 @@ -0,0 +1,115 @@ +/* + * 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_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQDESTINATIONMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQDESTINATIONMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for ActiveMQDestinationMarshaller + * + * 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 ActiveMQDestinationMarshaller : public BaseDataStreamMarshaller + { + public: + + ActiveMQDestinationMarshaller() {} + virtual ~ActiveMQDestinationMarshaller() {} + + /** + * 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 + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQDESTINATIONMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMapMessageMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMapMessageMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMapMessageMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMapMessageMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,133 @@ +/* + * 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 + +// +// 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::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ActiveMQMapMessageMarshaller::createObject() const { + return new ActiveMQMapMessage(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ActiveMQMapMessageMarshaller::getDataStructureType() const { + return ActiveMQMapMessage::ID_ACTIVEMQMAPMESSAGE; +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMapMessageMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + MessageMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ActiveMQMapMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + + + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQMapMessageMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + ActiveMQMapMessage* info = + dynamic_cast( dataStructure ); + + info->beforeMarshal( wireFormat ); + int rc = MessageMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMapMessageMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + MessageMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ActiveMQMapMessage* info = + dynamic_cast( dataStructure ); + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMapMessageMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + MessageMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ActiveMQMapMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMapMessageMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + ActiveMQMapMessage* info = + dynamic_cast( dataStructure ); + info->beforeMarshal( wireFormat ); + MessageMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMapMessageMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMapMessageMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMapMessageMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMapMessageMarshaller.h Thu Oct 18 06:11:09 2007 @@ -0,0 +1,127 @@ +/* + * 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_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQMAPMESSAGEMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQMAPMESSAGEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for ActiveMQMapMessageMarshaller + * + * 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 ActiveMQMapMessageMarshaller : public MessageMarshaller + { + public: + + ActiveMQMapMessageMarshaller() {} + virtual ~ActiveMQMapMessageMarshaller() {} + + /** + * 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 + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQMAPMESSAGEMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMessageMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMessageMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMessageMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMessageMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,133 @@ +/* + * 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 + +// +// 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::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ActiveMQMessageMarshaller::createObject() const { + return new ActiveMQMessage(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ActiveMQMessageMarshaller::getDataStructureType() const { + return ActiveMQMessage::ID_ACTIVEMQMESSAGE; +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMessageMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + MessageMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ActiveMQMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + + + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQMessageMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + ActiveMQMessage* info = + dynamic_cast( dataStructure ); + + info->beforeMarshal( wireFormat ); + int rc = MessageMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMessageMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + MessageMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ActiveMQMessage* info = + dynamic_cast( dataStructure ); + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMessageMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + MessageMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ActiveMQMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQMessageMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + ActiveMQMessage* info = + dynamic_cast( dataStructure ); + info->beforeMarshal( wireFormat ); + MessageMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMessageMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMessageMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMessageMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQMessageMarshaller.h Thu Oct 18 06:11:09 2007 @@ -0,0 +1,127 @@ +/* + * 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_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQMESSAGEMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQMESSAGEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for ActiveMQMessageMarshaller + * + * 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 ActiveMQMessageMarshaller : public MessageMarshaller + { + public: + + ActiveMQMessageMarshaller() {} + virtual ~ActiveMQMessageMarshaller() {} + + /** + * 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 + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQMESSAGEMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,133 @@ +/* + * 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 + +// +// 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::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ActiveMQObjectMessageMarshaller::createObject() const { + return new ActiveMQObjectMessage(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ActiveMQObjectMessageMarshaller::getDataStructureType() const { + return ActiveMQObjectMessage::ID_ACTIVEMQOBJECTMESSAGE; +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQObjectMessageMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + MessageMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + ActiveMQObjectMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + + + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQObjectMessageMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + ActiveMQObjectMessage* info = + dynamic_cast( dataStructure ); + + info->beforeMarshal( wireFormat ); + int rc = MessageMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQObjectMessageMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + MessageMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + ActiveMQObjectMessage* info = + dynamic_cast( dataStructure ); + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQObjectMessageMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + MessageMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + ActiveMQObjectMessage* info = + dynamic_cast( dataStructure ); + info->beforeUnmarshal( wireFormat ); + info->afterUnmarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQObjectMessageMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + ActiveMQObjectMessage* info = + dynamic_cast( dataStructure ); + info->beforeMarshal( wireFormat ); + MessageMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + info->afterMarshal( wireFormat ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQObjectMessageMarshaller.h Thu Oct 18 06:11:09 2007 @@ -0,0 +1,127 @@ +/* + * 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_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQOBJECTMESSAGEMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQOBJECTMESSAGEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for ActiveMQObjectMessageMarshaller + * + * 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 ActiveMQObjectMessageMarshaller : public MessageMarshaller + { + public: + + ActiveMQObjectMessageMarshaller() {} + virtual ~ActiveMQObjectMessageMarshaller() {} + + /** + * 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 + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQOBJECTMESSAGEMARSHALLER_H_*/ + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQQueueMarshaller.cpp URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQQueueMarshaller.cpp?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQQueueMarshaller.cpp (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQQueueMarshaller.cpp Thu Oct 18 06:11:09 2007 @@ -0,0 +1,112 @@ +/* + * 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 + +// +// 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::io; +using namespace activemq::connector; +using namespace activemq::connector::openwire; +using namespace activemq::connector::openwire::commands; +using namespace activemq::connector::openwire::marshal; +using namespace activemq::connector::openwire::utils; +using namespace activemq::connector::openwire::marshal::v1; + +/////////////////////////////////////////////////////////////////////////////// +DataStructure* ActiveMQQueueMarshaller::createObject() const { + return new ActiveMQQueue(); +} + +/////////////////////////////////////////////////////////////////////////////// +unsigned char ActiveMQQueueMarshaller::getDataStructureType() const { + return ActiveMQQueue::ID_ACTIVEMQQUEUE; +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQQueueMarshaller::tightUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn, BooleanStream* bs ) throw( io::IOException ) { + + try { + + ActiveMQDestinationMarshaller::tightUnmarshal( wireFormat, dataStructure, dataIn, bs ); + + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +int ActiveMQQueueMarshaller::tightMarshal1( OpenWireFormat* wireFormat, DataStructure* dataStructure, BooleanStream* bs ) throw( io::IOException ) { + + try { + + int rc = ActiveMQDestinationMarshaller::tightMarshal1( wireFormat, dataStructure, bs ); + + return rc + 0; + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQQueueMarshaller::tightMarshal2( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut, BooleanStream* bs ) throw( io::IOException ) { + + try { + + ActiveMQDestinationMarshaller::tightMarshal2( wireFormat, dataStructure, dataOut, bs ); + + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQQueueMarshaller::looseUnmarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataInputStream* dataIn ) throw( io::IOException ) { + + try { + + ActiveMQDestinationMarshaller::looseUnmarshal( wireFormat, dataStructure, dataIn ); + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + +/////////////////////////////////////////////////////////////////////////////// +void ActiveMQQueueMarshaller::looseMarshal( OpenWireFormat* wireFormat, DataStructure* dataStructure, DataOutputStream* dataOut ) throw( io::IOException ) { + + try { + + ActiveMQDestinationMarshaller::looseMarshal( wireFormat, dataStructure, dataOut ); + + } + AMQ_CATCH_RETHROW( io::IOException ) + AMQ_CATCH_EXCEPTION_CONVERT( exceptions::ActiveMQException, io::IOException ) + AMQ_CATCHALL_THROW( io::IOException ) +} + Added: activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQQueueMarshaller.h URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQQueueMarshaller.h?rev=585955&view=auto ============================================================================== --- activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQQueueMarshaller.h (added) +++ activemq/activemq-cpp/trunk/src/main/activemq/connector/openwire/marshal/v1/ActiveMQQueueMarshaller.h Thu Oct 18 06:11:09 2007 @@ -0,0 +1,127 @@ +/* + * 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_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQQUEUEMARSHALLER_H_ +#define _ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQQUEUEMARSHALLER_H_ + +// Turn off warning message for ignored exception specification +#ifdef _MSC_VER +#pragma warning( disable : 4290 ) +#endif + +#include + +#include +#include +#include +#include +#include +#include + +namespace activemq{ +namespace connector{ +namespace openwire{ +namespace marshal{ +namespace v1{ + + /** + * Marshalling code for Open Wire Format for ActiveMQQueueMarshaller + * + * 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 ActiveMQQueueMarshaller : public ActiveMQDestinationMarshaller + { + public: + + ActiveMQQueueMarshaller() {} + virtual ~ActiveMQQueueMarshaller() {} + + /** + * 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 + * @param dataIn - BinaryReader that provides that data + * @param bs - BooleanStream + */ + virtual void tightUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write the booleans that this object uses to a BooleanStream + * @param wireFormat - describis the wire format of the broker + * @param o - Object to be marshaled + * @param bs - BooleanStream + * @returns int + */ + virtual int tightMarshal1( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryReader that provides that data sink + * @param bs - BooleanStream + */ + virtual void tightMarshal2( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut, + utils::BooleanStream* bs ) throw( io::IOException ); + + /** + * Un-marshal an object instance from the data input stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataIn - BinaryReader that provides that data source + */ + virtual void looseUnmarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataInputStream* dataIn ) throw( io::IOException ); + + /** + * Write a object instance to data output stream + * @param wireFormat - describs the wire format of the broker + * @param o - Object to be marshaled + * @param dataOut - BinaryWriter that provides that data sink + */ + virtual void looseMarshal( OpenWireFormat* wireFormat, + commands::DataStructure* dataStructure, + io::DataOutputStream* dataOut ) throw( io::IOException ); + + }; + +}}}}} + +#endif /*_ACTIVEMQ_CONNECTOR_OPENWIRE_MARSAHAL_V1_ACTIVEMQQUEUEMARSHALLER_H_*/ +