activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r382091 [6/6] - in /incubator/activemq/trunk/openwire-cpp: ./ src/command/ src/marshal/
Date Wed, 01 Mar 2006 17:34:38 GMT
Added: incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/SessionInfoMarshaller.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 SessionInfoMarshaller_hpp_
+#define SessionInfoMarshaller_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 SessionInfoMarshaller : public BaseCommandMarshaller
+{
+public:
+    SessionInfoMarshaller() ;
+    virtual ~SessionInfoMarshaller() ;
+
+    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 /*SessionInfoMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.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/ShutdownInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for ShutdownInfo
+ *
+ * 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
+ */
+
+ShutdownInfoMarshaller::ShutdownInfoMarshaller()
+{
+    // no-op
+}
+
+ShutdownInfoMarshaller::~ShutdownInfoMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* ShutdownInfoMarshaller::createObject() 
+{
+    return new ShutdownInfo();
+}
+
+byte ShutdownInfoMarshaller::getDataStructureType() 
+{
+    return ShutdownInfo.ID_ShutdownInfo;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void ShutdownInfoMarshaller::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 ShutdownInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream&
bs) {
+    ShutdownInfo& info = (ShutdownInfo&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void ShutdownInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter&
dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/ShutdownInfoMarshaller.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 ShutdownInfoMarshaller_hpp_
+#define ShutdownInfoMarshaller_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 ShutdownInfoMarshaller : public BaseCommandMarshaller
+{
+public:
+    ShutdownInfoMarshaller() ;
+    virtual ~ShutdownInfoMarshaller() ;
+
+    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 /*ShutdownInfoMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.cpp Wed Mar
 1 09:34:23 2006
@@ -0,0 +1,94 @@
+/*
+ * 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/SubscriptionInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for SubscriptionInfo
+ *
+ * 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
+ */
+
+SubscriptionInfoMarshaller::SubscriptionInfoMarshaller()
+{
+    // no-op
+}
+
+SubscriptionInfoMarshaller::~SubscriptionInfoMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* SubscriptionInfoMarshaller::createObject() 
+{
+    return new SubscriptionInfo();
+}
+
+byte SubscriptionInfoMarshaller::getDataStructureType() 
+{
+    return SubscriptionInfo.ID_SubscriptionInfo;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void SubscriptionInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader&
dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    SubscriptionInfo& info = (SubscriptionInfo&) o;
+        info.setClientId(tightUnmarshalString(dataIn, bs));
+        info.setDestination((ActiveMQDestination) tightUnmarsalCachedObject(wireFormat, dataIn,
bs));
+        info.setSelector(tightUnmarshalString(dataIn, bs));
+        info.setSubcriptionName(tightUnmarshalString(dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int SubscriptionInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream&
bs) {
+    SubscriptionInfo& info = (SubscriptionInfo&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += writeString(info.getClientId(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getDestination(), bs);
+    rc += writeString(info.getSelector(), bs);
+    rc += writeString(info.getSubcriptionName(), bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void SubscriptionInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o,
BinaryWriter& dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    SubscriptionInfo& info = (SubscriptionInfo&) o;
+    writeString(info.getClientId(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getDestination(), dataOut, bs);
+    writeString(info.getSelector(), dataOut, bs);
+    writeString(info.getSubcriptionName(), dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/SubscriptionInfoMarshaller.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 SubscriptionInfoMarshaller_hpp_
+#define SubscriptionInfoMarshaller_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 SubscriptionInfoMarshaller : public BaseDataStreamMarshaller
+{
+public:
+    SubscriptionInfoMarshaller() ;
+    virtual ~SubscriptionInfoMarshaller() ;
+
+    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 /*SubscriptionInfoMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.cpp Wed Mar
 1 09:34:23 2006
@@ -0,0 +1,67 @@
+/*
+ * 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/TransactionIdMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for TransactionId
+ *
+ * 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
+ */
+
+TransactionIdMarshaller::TransactionIdMarshaller()
+{
+    // no-op
+}
+
+TransactionIdMarshaller::~TransactionIdMarshaller()
+{
+    // no-op
+}
+
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void TransactionIdMarshaller::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 TransactionIdMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream&
bs) {
+    TransactionId& info = (TransactionId&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+
+    return rc + 0;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void TransactionIdMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter&
dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionIdMarshaller.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 TransactionIdMarshaller_hpp_
+#define TransactionIdMarshaller_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 TransactionIdMarshaller : public BaseDataStreamMarshaller
+{
+public:
+    TransactionIdMarshaller() ;
+    virtual ~TransactionIdMarshaller() ;
+
+    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 /*TransactionIdMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.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/TransactionInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for TransactionInfo
+ *
+ * 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
+ */
+
+TransactionInfoMarshaller::TransactionInfoMarshaller()
+{
+    // no-op
+}
+
+TransactionInfoMarshaller::~TransactionInfoMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* TransactionInfoMarshaller::createObject() 
+{
+    return new TransactionInfo();
+}
+
+byte TransactionInfoMarshaller::getDataStructureType() 
+{
+    return TransactionInfo.ID_TransactionInfo;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void TransactionInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader&
dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    TransactionInfo& info = (TransactionInfo&) o;
+        info.setConnectionId((ConnectionId) tightUnmarsalCachedObject(wireFormat, dataIn,
bs));
+        info.setTransactionId((TransactionId) tightUnmarsalCachedObject(wireFormat, dataIn,
bs));
+        info.setType(dataIn.readByte());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int TransactionInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream&
bs) {
+    TransactionInfo& info = (TransactionInfo&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+    rc += marshal1CachedObject(wireFormat, info.getConnectionId(), bs);
+    rc += marshal1CachedObject(wireFormat, info.getTransactionId(), bs);
+    
+    return rc + 1;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void TransactionInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter&
dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    TransactionInfo& info = (TransactionInfo&) o;
+    marshal2CachedObject(wireFormat, info.getConnectionId(), dataOut, bs);
+    marshal2CachedObject(wireFormat, info.getTransactionId(), dataOut, bs);
+    DataStreamMarshaller.writeByte(info.getType(), dataOut);
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/TransactionInfoMarshaller.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 TransactionInfoMarshaller_hpp_
+#define TransactionInfoMarshaller_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 TransactionInfoMarshaller : public BaseCommandMarshaller
+{
+public:
+    TransactionInfoMarshaller() ;
+    virtual ~TransactionInfoMarshaller() ;
+
+    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 /*TransactionInfoMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.cpp Wed Mar
 1 09:34:23 2006
@@ -0,0 +1,101 @@
+/*
+ * 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/WireFormatInfoMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for WireFormatInfo
+ *
+ * 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
+ */
+
+WireFormatInfoMarshaller::WireFormatInfoMarshaller()
+{
+    // no-op
+}
+
+WireFormatInfoMarshaller::~WireFormatInfoMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* WireFormatInfoMarshaller::createObject() 
+{
+    return new WireFormatInfo();
+}
+
+byte WireFormatInfoMarshaller::getDataStructureType() 
+{
+    return WireFormatInfo.ID_WireFormatInfo;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void WireFormatInfoMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader&
dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    WireFormatInfo& info = (WireFormatInfo&) o;
+        info.setMagic(tightUnmarshalConstByteArray(dataIn, bs, 8));
+        info.setVersion(dataIn.readInt());
+        info.setCacheEnabled(bs.readBoolean());
+        info.setStackTraceEnabled(bs.readBoolean());
+        info.setTcpNoDelayEnabled(bs.readBoolean());
+        info.setPrefixPacketSize(bs.readBoolean());
+        info.setTightEncodingEnabled(bs.readBoolean());
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int WireFormatInfoMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream&
bs) {
+    WireFormatInfo& info = (WireFormatInfo&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+            bs.writeBoolean(info.isCacheEnabled());
+    bs.writeBoolean(info.isStackTraceEnabled());
+    bs.writeBoolean(info.isTcpNoDelayEnabled());
+    bs.writeBoolean(info.isPrefixPacketSize());
+    bs.writeBoolean(info.isTightEncodingEnabled());
+
+    return rc + 9;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void WireFormatInfoMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter&
dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    WireFormatInfo& info = (WireFormatInfo&) o;
+    dataOut.write(info.getMagic(), 0, 8);
+    DataStreamMarshaller.writeInt(info.getVersion(), dataOut);
+    bs.readBoolean();
+    bs.readBoolean();
+    bs.readBoolean();
+    bs.readBoolean();
+    bs.readBoolean();
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/WireFormatInfoMarshaller.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 WireFormatInfoMarshaller_hpp_
+#define WireFormatInfoMarshaller_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 WireFormatInfoMarshaller : public BaseDataStreamMarshaller
+{
+public:
+    WireFormatInfoMarshaller() ;
+    virtual ~WireFormatInfoMarshaller() ;
+
+    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 /*WireFormatInfoMarshaller_hpp_*/

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.cpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.cpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.cpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.cpp Wed Mar
 1 09:34:23 2006
@@ -0,0 +1,98 @@
+/*
+ * 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/XATransactionIdMarshaller.hpp"
+
+using namespace apache::activemq::client::marshal;
+
+/*
+ *  Marshalling code for Open Wire Format for XATransactionId
+ *
+ * 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
+ */
+
+XATransactionIdMarshaller::XATransactionIdMarshaller()
+{
+    // no-op
+}
+
+XATransactionIdMarshaller::~XATransactionIdMarshaller()
+{
+    // no-op
+}
+
+
+
+DataStructure* XATransactionIdMarshaller::createObject() 
+{
+    return new XATransactionId();
+}
+
+byte XATransactionIdMarshaller::getDataStructureType() 
+{
+    return XATransactionId.ID_XATransactionId;
+}
+
+    /* 
+     * Un-marshal an object instance from the data input stream
+     */ 
+void XATransactionIdMarshaller::unmarshal(OpenWireFormat& wireFormat, Object o, BinaryReader&
dataIn, BooleanStream& bs) 
+{
+    base.unmarshal(wireFormat, o, dataIn, bs);
+
+    XATransactionId& info = (XATransactionId&) o;
+        info.setFormatId(dataIn.readInt());
+        info.setGlobalTransactionId(tightUnmarshalByteArray(dataIn, bs));
+        info.setBranchQualifier(tightUnmarshalByteArray(dataIn, bs));
+
+}
+
+
+/*
+ * Write the booleans that this object uses to a BooleanStream
+ */
+int XATransactionIdMarshaller::marshal1(OpenWireFormat& wireFormat, Object& o, BooleanStream&
bs) {
+    XATransactionId& info = (XATransactionId&) o;
+
+    int rc = base.marshal1(wireFormat, info, bs);
+        bs.writeBoolean(info.getGlobalTransactionId()!=null);
+    rc += info.getGlobalTransactionId()==null ? 0 : info.getGlobalTransactionId().Length+4;
+    bs.writeBoolean(info.getBranchQualifier()!=null);
+    rc += info.getBranchQualifier()==null ? 0 : info.getBranchQualifier().Length+4;
+
+    return rc + 1;
+}
+
+/* 
+ * Write a object instance to data output stream
+ */
+void XATransactionIdMarshaller::marshal2(OpenWireFormat& wireFormat, Object& o, BinaryWriter&
dataOut, BooleanStream& bs) {
+    base.marshal2(wireFormat, o, dataOut, bs);
+
+    XATransactionId& info = (XATransactionId&) o;
+    DataStreamMarshaller.writeInt(info.getFormatId(), dataOut);
+    if(bs.readBoolean()) {
+       DataStreamMarshaller.writeInt(info.getGlobalTransactionId().Length, dataOut);
+       dataOut.write(info.getGlobalTransactionId());
+    }
+    if(bs.readBoolean()) {
+       DataStreamMarshaller.writeInt(info.getBranchQualifier().Length, dataOut);
+       dataOut.write(info.getBranchQualifier());
+    }
+
+}

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.cpp
------------------------------------------------------------------------------
    svn:keywords = Date Author Id Revision HeadURL

Added: incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.hpp
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.hpp?rev=382091&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.hpp (added)
+++ incubator/activemq/trunk/openwire-cpp/src/marshal/XATransactionIdMarshaller.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 XATransactionIdMarshaller_hpp_
+#define XATransactionIdMarshaller_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 XATransactionIdMarshaller : public TransactionIdMarshaller
+{
+public:
+    XATransactionIdMarshaller() ;
+    virtual ~XATransactionIdMarshaller() ;
+
+    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 /*XATransactionIdMarshaller_hpp_*/



Mime
View raw message