Return-Path: Delivered-To: apmail-geronimo-activemq-commits-archive@www.apache.org Received: (qmail 13617 invoked from network); 1 Mar 2006 17:38:36 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 1 Mar 2006 17:38:36 -0000 Received: (qmail 2145 invoked by uid 500); 1 Mar 2006 17:39:22 -0000 Delivered-To: apmail-geronimo-activemq-commits-archive@geronimo.apache.org Received: (qmail 2031 invoked by uid 500); 1 Mar 2006 17:39:21 -0000 Mailing-List: contact activemq-commits-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-commits@geronimo.apache.org Received: (qmail 1947 invoked by uid 99); 1 Mar 2006 17:39:20 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 01 Mar 2006 09:39:20 -0800 X-ASF-Spam-Status: No, hits=-9.4 required=10.0 tests=ALL_TRUSTED,NO_REAL_NAME X-Spam-Check-By: apache.org Received: from [209.237.227.194] (HELO minotaur.apache.org) (209.237.227.194) by apache.org (qpsmtpd/0.29) with SMTP; Wed, 01 Mar 2006 09:39:14 -0800 Received: (qmail 13332 invoked by uid 65534); 1 Mar 2006 17:38:06 -0000 Message-ID: <20060301173806.13330.qmail@minotaur.apache.org> Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r382091 [4/6] - in /incubator/activemq/trunk/openwire-cpp: ./ src/command/ src/marshal/ Date: Wed, 01 Mar 2006 17:34:38 -0000 To: activemq-commits@geronimo.apache.org From: jstrachan@apache.org X-Mailer: svnmailer-1.0.7 X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,85 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/ControlCommandMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for ControlCommand + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +ControlCommandMarshaller::ControlCommandMarshaller() +{ + // no-op +} + +ControlCommandMarshaller::~ControlCommandMarshaller() +{ + // no-op +} + + + +DataStructure* ControlCommandMarshaller::createObject() +{ + return new ControlCommand(); +} + +byte ControlCommandMarshaller::getDataStructureType() +{ + return ControlCommand.ID_ControlCommand; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void ControlCommandMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + ControlCommand& info = (ControlCommand&) o; + info.setCommand(tightUnmarshalString(dataIn, bs)); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int ControlCommandMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + ControlCommand& info = (ControlCommand&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += writeString(info.getCommand(), bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void ControlCommandMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + ControlCommand& info = (ControlCommand&) o; + writeString(info.getCommand(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ControlCommandMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 ControlCommandMarshaller_hpp_ +#define ControlCommandMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseCommandMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class ControlCommandMarshaller : public BaseCommandMarshaller +{ +public: + ControlCommandMarshaller() ; + virtual ~ControlCommandMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ControlCommandMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,96 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/DataArrayResponseMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for DataArrayResponse + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +DataArrayResponseMarshaller::DataArrayResponseMarshaller() +{ + // no-op +} + +DataArrayResponseMarshaller::~DataArrayResponseMarshaller() +{ + // no-op +} + + + +DataStructure* DataArrayResponseMarshaller::createObject() +{ + return new DataArrayResponse(); +} + +byte DataArrayResponseMarshaller::getDataStructureType() +{ + return DataArrayResponse.ID_DataArrayResponse; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void DataArrayResponseMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + DataArrayResponse& info = (DataArrayResponse&) o; + + if (bs.readBoolean()) { + short size = dataIn.readShort(); + DataStructure value[] = new DataStructure[size]; + for( int i=0; i < size; i++ ) { + value[i] = (DataStructure) tightUnmarsalNestedObject(wireFormat,dataIn, bs); + } + info.setData(value); + } + else { + info.setData(null); + } + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int DataArrayResponseMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + DataArrayResponse& info = (DataArrayResponse&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshalObjectArray(wireFormat, info.getData(), bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void DataArrayResponseMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + DataArrayResponse& info = (DataArrayResponse&) o; + marshalObjectArray(wireFormat, info.getData(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DataArrayResponseMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 DataArrayResponseMarshaller_hpp_ +#define DataArrayResponseMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ResponseMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class DataArrayResponseMarshaller : public ResponseMarshaller +{ +public: + DataArrayResponseMarshaller() ; + virtual ~DataArrayResponseMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*DataArrayResponseMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,85 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/DataResponseMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for DataResponse + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +DataResponseMarshaller::DataResponseMarshaller() +{ + // no-op +} + +DataResponseMarshaller::~DataResponseMarshaller() +{ + // no-op +} + + + +DataStructure* DataResponseMarshaller::createObject() +{ + return new DataResponse(); +} + +byte DataResponseMarshaller::getDataStructureType() +{ + return DataResponse.ID_DataResponse; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void DataResponseMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + DataResponse& info = (DataResponse&) o; + info.setData((DataStructure) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int DataResponseMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + DataResponse& info = (DataResponse&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1NestedObject(wireFormat, info.getData(), bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void DataResponseMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + DataResponse& info = (DataResponse&) o; + marshal2NestedObject(wireFormat, info.getData(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DataResponseMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 DataResponseMarshaller_hpp_ +#define DataResponseMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ResponseMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class DataResponseMarshaller : public ResponseMarshaller +{ +public: + DataResponseMarshaller() ; + virtual ~DataResponseMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*DataResponseMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,107 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/DestinationInfoMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for DestinationInfo + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +DestinationInfoMarshaller::DestinationInfoMarshaller() +{ + // no-op +} + +DestinationInfoMarshaller::~DestinationInfoMarshaller() +{ + // no-op +} + + + +DataStructure* DestinationInfoMarshaller::createObject() +{ + return new DestinationInfo(); +} + +byte DestinationInfoMarshaller::getDataStructureType() +{ + return DestinationInfo.ID_DestinationInfo; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void DestinationInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + DestinationInfo& info = (DestinationInfo&) o; + info.setConnectionId((ConnectionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + info.setOperationType(dataIn.readByte()); + info.setTimeout(tightUnmarshalLong(wireFormat, dataIn, bs)); + + if (bs.readBoolean()) { + short size = dataIn.readShort(); + BrokerId value[] = new BrokerId[size]; + for( int i=0; i < size; i++ ) { + value[i] = (BrokerId) tightUnmarsalNestedObject(wireFormat,dataIn, bs); + } + info.setBrokerPath(value); + } + else { + info.setBrokerPath(null); + } + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int DestinationInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + DestinationInfo& info = (DestinationInfo&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1CachedObject(wireFormat, info.getConnectionId(), bs); + rc += marshal1CachedObject(wireFormat, info.getDestination(), bs); + rc += marshal1Long(wireFormat, info.getTimeout(), bs); + rc += marshalObjectArray(wireFormat, info.getBrokerPath(), bs); + + return rc + 1; +} + +/* + * Write a object instance to data output stream + */ +void DestinationInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + DestinationInfo& info = (DestinationInfo&) o; + marshal2CachedObject(wireFormat, info.getConnectionId(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs); + DataStreamMarshaller.writeByte(info.getOperationType(), dataOut); + marshal2Long(wireFormat, info.getTimeout(), dataOut, bs); + marshalObjectArray(wireFormat, info.getBrokerPath(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DestinationInfoMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 DestinationInfoMarshaller_hpp_ +#define DestinationInfoMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseCommandMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class DestinationInfoMarshaller : public BaseCommandMarshaller +{ +public: + DestinationInfoMarshaller() ; + virtual ~DestinationInfoMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*DestinationInfoMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,88 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/DiscoveryEventMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for DiscoveryEvent + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +DiscoveryEventMarshaller::DiscoveryEventMarshaller() +{ + // no-op +} + +DiscoveryEventMarshaller::~DiscoveryEventMarshaller() +{ + // no-op +} + + + +DataStructure* DiscoveryEventMarshaller::createObject() +{ + return new DiscoveryEvent(); +} + +byte DiscoveryEventMarshaller::getDataStructureType() +{ + return DiscoveryEvent.ID_DiscoveryEvent; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void DiscoveryEventMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + DiscoveryEvent& info = (DiscoveryEvent&) o; + info.setServiceName(tightUnmarshalString(dataIn, bs)); + info.setBrokerName(tightUnmarshalString(dataIn, bs)); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int DiscoveryEventMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + DiscoveryEvent& info = (DiscoveryEvent&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += writeString(info.getServiceName(), bs); + rc += writeString(info.getBrokerName(), bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void DiscoveryEventMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + DiscoveryEvent& info = (DiscoveryEvent&) o; + writeString(info.getServiceName(), dataOut, bs); + writeString(info.getBrokerName(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/DiscoveryEventMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 DiscoveryEventMarshaller_hpp_ +#define DiscoveryEventMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseDataStreamMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class DiscoveryEventMarshaller : public BaseDataStreamMarshaller +{ +public: + DiscoveryEventMarshaller() ; + virtual ~DiscoveryEventMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*DiscoveryEventMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,85 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/ExceptionResponseMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for ExceptionResponse + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +ExceptionResponseMarshaller::ExceptionResponseMarshaller() +{ + // no-op +} + +ExceptionResponseMarshaller::~ExceptionResponseMarshaller() +{ + // no-op +} + + + +DataStructure* ExceptionResponseMarshaller::createObject() +{ + return new ExceptionResponse(); +} + +byte ExceptionResponseMarshaller::getDataStructureType() +{ + return ExceptionResponse.ID_ExceptionResponse; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void ExceptionResponseMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + ExceptionResponse& info = (ExceptionResponse&) o; + info.setException((Throwable) tightUnmarsalThrowable(wireFormat, dataIn, bs)); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int ExceptionResponseMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + ExceptionResponse& info = (ExceptionResponse&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshalBrokerError(wireFormat, info.getException(), bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void ExceptionResponseMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + ExceptionResponse& info = (ExceptionResponse&) o; + marshalBrokerError(wireFormat, info.getException(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/ExceptionResponseMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 ExceptionResponseMarshaller_hpp_ +#define ExceptionResponseMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ResponseMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class ExceptionResponseMarshaller : public ResponseMarshaller +{ +public: + ExceptionResponseMarshaller() ; + virtual ~ExceptionResponseMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*ExceptionResponseMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,78 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/FlushCommandMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for FlushCommand + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +FlushCommandMarshaller::FlushCommandMarshaller() +{ + // no-op +} + +FlushCommandMarshaller::~FlushCommandMarshaller() +{ + // no-op +} + + + +DataStructure* FlushCommandMarshaller::createObject() +{ + return new FlushCommand(); +} + +byte FlushCommandMarshaller::getDataStructureType() +{ + return FlushCommand.ID_FlushCommand; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void FlushCommandMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int FlushCommandMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + FlushCommand& info = (FlushCommand&) o; + + int rc = base.marshal1(wireFormat, info, bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void FlushCommandMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/FlushCommandMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 FlushCommandMarshaller_hpp_ +#define FlushCommandMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseCommandMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class FlushCommandMarshaller : public BaseCommandMarshaller +{ +public: + FlushCommandMarshaller() ; + virtual ~FlushCommandMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*FlushCommandMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,84 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/IntegerResponseMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for IntegerResponse + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +IntegerResponseMarshaller::IntegerResponseMarshaller() +{ + // no-op +} + +IntegerResponseMarshaller::~IntegerResponseMarshaller() +{ + // no-op +} + + + +DataStructure* IntegerResponseMarshaller::createObject() +{ + return new IntegerResponse(); +} + +byte IntegerResponseMarshaller::getDataStructureType() +{ + return IntegerResponse.ID_IntegerResponse; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void IntegerResponseMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + IntegerResponse& info = (IntegerResponse&) o; + info.setResult(dataIn.readInt()); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int IntegerResponseMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + IntegerResponse& info = (IntegerResponse&) o; + + int rc = base.marshal1(wireFormat, info, bs); + + return rc + 1; +} + +/* + * Write a object instance to data output stream + */ +void IntegerResponseMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + IntegerResponse& info = (IntegerResponse&) o; + DataStreamMarshaller.writeInt(info.getResult(), dataOut); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/IntegerResponseMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 IntegerResponseMarshaller_hpp_ +#define IntegerResponseMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/ResponseMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class IntegerResponseMarshaller : public ResponseMarshaller +{ +public: + IntegerResponseMarshaller() ; + virtual ~IntegerResponseMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*IntegerResponseMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,88 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/JournalQueueAckMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for JournalQueueAck + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +JournalQueueAckMarshaller::JournalQueueAckMarshaller() +{ + // no-op +} + +JournalQueueAckMarshaller::~JournalQueueAckMarshaller() +{ + // no-op +} + + + +DataStructure* JournalQueueAckMarshaller::createObject() +{ + return new JournalQueueAck(); +} + +byte JournalQueueAckMarshaller::getDataStructureType() +{ + return JournalQueueAck.ID_JournalQueueAck; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void JournalQueueAckMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + JournalQueueAck& info = (JournalQueueAck&) o; + info.setDestination((ActiveMQDestination) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setMessageAck((MessageAck) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int JournalQueueAckMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + JournalQueueAck& info = (JournalQueueAck&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1NestedObject(wireFormat, info.getDestination(), bs); + rc += marshal1NestedObject(wireFormat, info.getMessageAck(), bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void JournalQueueAckMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + JournalQueueAck& info = (JournalQueueAck&) o; + marshal2NestedObject(wireFormat, info.getDestination(), dataOut, bs); + marshal2NestedObject(wireFormat, info.getMessageAck(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalQueueAckMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 JournalQueueAckMarshaller_hpp_ +#define JournalQueueAckMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseDataStreamMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class JournalQueueAckMarshaller : public BaseDataStreamMarshaller +{ +public: + JournalQueueAckMarshaller() ; + virtual ~JournalQueueAckMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*JournalQueueAckMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,100 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/JournalTopicAckMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for JournalTopicAck + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +JournalTopicAckMarshaller::JournalTopicAckMarshaller() +{ + // no-op +} + +JournalTopicAckMarshaller::~JournalTopicAckMarshaller() +{ + // no-op +} + + + +DataStructure* JournalTopicAckMarshaller::createObject() +{ + return new JournalTopicAck(); +} + +byte JournalTopicAckMarshaller::getDataStructureType() +{ + return JournalTopicAck.ID_JournalTopicAck; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void JournalTopicAckMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + JournalTopicAck& info = (JournalTopicAck&) o; + info.setDestination((ActiveMQDestination) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setMessageId((MessageId) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setMessageSequenceId(tightUnmarshalLong(wireFormat, dataIn, bs)); + info.setSubscritionName(tightUnmarshalString(dataIn, bs)); + info.setClientId(tightUnmarshalString(dataIn, bs)); + info.setTransactionId((TransactionId) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int JournalTopicAckMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + JournalTopicAck& info = (JournalTopicAck&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1NestedObject(wireFormat, info.getDestination(), bs); + rc += marshal1NestedObject(wireFormat, info.getMessageId(), bs); + rc += marshal1Long(wireFormat, info.getMessageSequenceId(), bs); + rc += writeString(info.getSubscritionName(), bs); + rc += writeString(info.getClientId(), bs); + rc += marshal1NestedObject(wireFormat, info.getTransactionId(), bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void JournalTopicAckMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + JournalTopicAck& info = (JournalTopicAck&) o; + marshal2NestedObject(wireFormat, info.getDestination(), dataOut, bs); + marshal2NestedObject(wireFormat, info.getMessageId(), dataOut, bs); + marshal2Long(wireFormat, info.getMessageSequenceId(), dataOut, bs); + writeString(info.getSubscritionName(), dataOut, bs); + writeString(info.getClientId(), dataOut, bs); + marshal2NestedObject(wireFormat, info.getTransactionId(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTopicAckMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 JournalTopicAckMarshaller_hpp_ +#define JournalTopicAckMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseDataStreamMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class JournalTopicAckMarshaller : public BaseDataStreamMarshaller +{ +public: + JournalTopicAckMarshaller() ; + virtual ~JournalTopicAckMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*JournalTopicAckMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,85 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/JournalTraceMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for JournalTrace + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +JournalTraceMarshaller::JournalTraceMarshaller() +{ + // no-op +} + +JournalTraceMarshaller::~JournalTraceMarshaller() +{ + // no-op +} + + + +DataStructure* JournalTraceMarshaller::createObject() +{ + return new JournalTrace(); +} + +byte JournalTraceMarshaller::getDataStructureType() +{ + return JournalTrace.ID_JournalTrace; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void JournalTraceMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + JournalTrace& info = (JournalTrace&) o; + info.setMessage(tightUnmarshalString(dataIn, bs)); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int JournalTraceMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + JournalTrace& info = (JournalTrace&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += writeString(info.getMessage(), bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void JournalTraceMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + JournalTrace& info = (JournalTrace&) o; + writeString(info.getMessage(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTraceMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 JournalTraceMarshaller_hpp_ +#define JournalTraceMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseDataStreamMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class JournalTraceMarshaller : public BaseDataStreamMarshaller +{ +public: + JournalTraceMarshaller() ; + virtual ~JournalTraceMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*JournalTraceMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,90 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/JournalTransactionMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for JournalTransaction + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +JournalTransactionMarshaller::JournalTransactionMarshaller() +{ + // no-op +} + +JournalTransactionMarshaller::~JournalTransactionMarshaller() +{ + // no-op +} + + + +DataStructure* JournalTransactionMarshaller::createObject() +{ + return new JournalTransaction(); +} + +byte JournalTransactionMarshaller::getDataStructureType() +{ + return JournalTransaction.ID_JournalTransaction; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void JournalTransactionMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + JournalTransaction& info = (JournalTransaction&) o; + info.setTransactionId((TransactionId) tightUnmarsalNestedObject(wireFormat, dataIn, bs)); + info.setType(dataIn.readByte()); + info.setWasPrepared(bs.readBoolean()); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int JournalTransactionMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + JournalTransaction& info = (JournalTransaction&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1NestedObject(wireFormat, info.getTransactionId(), bs); + bs.writeBoolean(info.getWasPrepared()); + + return rc + 1; +} + +/* + * Write a object instance to data output stream + */ +void JournalTransactionMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + JournalTransaction& info = (JournalTransaction&) o; + marshal2NestedObject(wireFormat, info.getTransactionId(), dataOut, bs); + DataStreamMarshaller.writeByte(info.getType(), dataOut); + bs.readBoolean(); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/JournalTransactionMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 JournalTransactionMarshaller_hpp_ +#define JournalTransactionMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseDataStreamMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class JournalTransactionMarshaller : public BaseDataStreamMarshaller +{ +public: + JournalTransactionMarshaller() ; + virtual ~JournalTransactionMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*JournalTransactionMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,78 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/KeepAliveInfoMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for KeepAliveInfo + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +KeepAliveInfoMarshaller::KeepAliveInfoMarshaller() +{ + // no-op +} + +KeepAliveInfoMarshaller::~KeepAliveInfoMarshaller() +{ + // no-op +} + + + +DataStructure* KeepAliveInfoMarshaller::createObject() +{ + return new KeepAliveInfo(); +} + +byte KeepAliveInfoMarshaller::getDataStructureType() +{ + return KeepAliveInfo.ID_KeepAliveInfo; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void KeepAliveInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int KeepAliveInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + KeepAliveInfo& info = (KeepAliveInfo&) o; + + int rc = base.marshal1(wireFormat, info, bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void KeepAliveInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/KeepAliveInfoMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 KeepAliveInfoMarshaller_hpp_ +#define KeepAliveInfoMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/BaseDataStreamMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class KeepAliveInfoMarshaller : public BaseDataStreamMarshaller +{ +public: + KeepAliveInfoMarshaller() ; + virtual ~KeepAliveInfoMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*KeepAliveInfoMarshaller_hpp_*/ Added: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,88 @@ +/* + * Copyright 2006 The Apache Software Foundation or its licensors, as + * applicable. + * + * Licensed 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 "marshal/LocalTransactionIdMarshaller.hpp" + +using namespace apache::activemq::client::marshal; + +/* + * Marshalling code for Open Wire Format for LocalTransactionId + * + * NOTE!: This file is autogenerated - do not modify! + * if you need to make a change, please see the Groovy scripts in the + * activemq-core module + */ + +LocalTransactionIdMarshaller::LocalTransactionIdMarshaller() +{ + // no-op +} + +LocalTransactionIdMarshaller::~LocalTransactionIdMarshaller() +{ + // no-op +} + + + +DataStructure* LocalTransactionIdMarshaller::createObject() +{ + return new LocalTransactionId(); +} + +byte LocalTransactionIdMarshaller::getDataStructureType() +{ + return LocalTransactionId.ID_LocalTransactionId; +} + + /* + * Un-marshal an object instance from the data input stream + */ +void LocalTransactionIdMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) +{ + base.unmarshal(wireFormat, o, dataIn, bs); + + LocalTransactionId& info = (LocalTransactionId&) o; + info.setValue(tightUnmarshalLong(wireFormat, dataIn, bs)); + info.setConnectionId((ConnectionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs)); + +} + + +/* + * Write the booleans that this object uses to a BooleanStream + */ +int LocalTransactionIdMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) { + LocalTransactionId& info = (LocalTransactionId&) o; + + int rc = base.marshal1(wireFormat, info, bs); + rc += marshal1Long(wireFormat, info.getValue(), bs); + rc += marshal1CachedObject(wireFormat, info.getConnectionId(), bs); + + return rc + 0; +} + +/* + * Write a object instance to data output stream + */ +void LocalTransactionIdMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) { + base.marshal2(wireFormat, o, dataOut, bs); + + LocalTransactionId& info = (LocalTransactionId&) o; + marshal2Long(wireFormat, info.getValue(), dataOut, bs); + marshal2CachedObject(wireFormat, info.getConnectionId(), dataOut, bs); + +} Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp ------------------------------------------------------------------------------ svn:eol-style = native Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.cpp ------------------------------------------------------------------------------ svn:keywords = Date Author Id Revision HeadURL Added: incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp?rev=382091&view=auto ============================================================================== --- incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp (added) +++ incubator/activemq/trunk/openwire-cpp/src/marshal/LocalTransactionIdMarshaller.hpp Wed Mar 1 09:34:23 2006 @@ -0,0 +1,71 @@ +/* +* Copyright 2006 The Apache Software Foundation or its licensors, as +* applicable. +* +* Licensed 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 LocalTransactionIdMarshaller_hpp_ +#define LocalTransactionIdMarshaller_hpp_ + +#include + +#include "command/DataStructure.hpp" + +/* we could cut this down - for now include all possible headers */ +#include "command/BrokerId.hpp" +#include "command/ConnectionId.hpp" +#include "command/ConsumerId.hpp" +#include "command/ProducerId.hpp" +#include "command/SessionId.hpp" + +#include "io/BinaryReader.hpp" +#include "io/BinaryWriter.hpp" + +#include "command/TransactionIdMarshaller.hpp" +#include "util/ifr/p" + +namespace apache +{ + namespace activemq + { + namespace client + { + namespace marshal + { + using namespace ifr ; + using namespace apache::activemq::client::command; + using namespace apache::activemq::client::io; + +/* + * + */ +class LocalTransactionIdMarshaller : public TransactionIdMarshaller +{ +public: + LocalTransactionIdMarshaller() ; + virtual ~LocalTransactionIdMarshaller() ; + + virtual DataStructure* createCommand() ; + virtual byte getDataStructureType() ; + + virtual void unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader& dataIn, BooleanStream& bs) ; + virtual int marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream& bs) ; + virtual void marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter& dataOut, BooleanStream& bs) ; +} ; + +/* namespace */ + } + } + } +} +#endif /*LocalTransactionIdMarshaller_hpp_*/