You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/03/01 18:34:38 UTC
svn commit: r382091 [4/6] - in /incubator/activemq/trunk/openwire-cpp: ./
src/command/ src/marshal/
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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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 <string>
+
+#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_*/