activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1133445 [9/9] - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp: Commands/ OpenWire/V7/ OpenWire/V8/
Date Wed, 08 Jun 2011 15:50:43 GMT
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SubscriptionInfoMarshaller.cs?rev=1133445&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SubscriptionInfoMarshaller.cs
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SubscriptionInfoMarshaller.cs
Wed Jun  8 15:50:39 2011
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/*
+ *
+ *  Marshaler code for OpenWire format for SubscriptionInfo
+ *
+ *  NOTE!: This file is auto generated - do not modify!
+ *         if you need to make a change, please see the Java Classes
+ *         in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V8
+{
+    /// <summary>
+    ///  Marshalling code for Open Wire Format for SubscriptionInfo
+    /// </summary>
+    class SubscriptionInfoMarshaller : BaseDataStreamMarshaller
+    {
+        /// <summery>
+        ///  Creates an instance of the Object that this marshaller handles.
+        /// </summery>
+        public override DataStructure CreateObject() 
+        {
+            return new SubscriptionInfo();
+        }
+
+        /// <summery>
+        ///  Returns the type code for the Object that this Marshaller handles..
+        /// </summery>
+        public override byte GetDataStructureType() 
+        {
+            return SubscriptionInfo.ID_SUBSCRIPTIONINFO;
+        }
+
+        // 
+        // Un-marshal an object instance from the data input stream
+        // 
+        public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader
dataIn, BooleanStream bs) 
+        {
+            base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+            SubscriptionInfo info = (SubscriptionInfo)o;
+            info.ClientId = TightUnmarshalString(dataIn, bs);
+            info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat,
dataIn, bs);
+            info.Selector = TightUnmarshalString(dataIn, bs);
+            info.SubcriptionName = TightUnmarshalString(dataIn, bs);
+            info.SubscribedDestination = (ActiveMQDestination) TightUnmarshalNestedObject(wireFormat,
dataIn, bs);
+        }
+
+        //
+        // Write the booleans that this object uses to a BooleanStream
+        //
+        public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream
bs)
+        {
+            SubscriptionInfo info = (SubscriptionInfo)o;
+
+            int rc = base.TightMarshal1(wireFormat, o, bs);
+            rc += TightMarshalString1(info.ClientId, bs);
+            rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination,
bs);
+            rc += TightMarshalString1(info.Selector, bs);
+            rc += TightMarshalString1(info.SubcriptionName, bs);
+        rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.SubscribedDestination,
bs);
+
+            return rc + 0;
+        }
+
+        // 
+        // Write a object instance to data output stream
+        //
+        public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter
dataOut, BooleanStream bs)
+        {
+            base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+            SubscriptionInfo info = (SubscriptionInfo)o;
+            TightMarshalString2(info.ClientId, dataOut, bs);
+            TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut,
bs);
+            TightMarshalString2(info.Selector, dataOut, bs);
+            TightMarshalString2(info.SubcriptionName, dataOut, bs);
+            TightMarshalNestedObject2(wireFormat, (DataStructure)info.SubscribedDestination,
dataOut, bs);
+        }
+
+        // 
+        // Un-marshal an object instance from the data input stream
+        // 
+        public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader
dataIn) 
+        {
+            base.LooseUnmarshal(wireFormat, o, dataIn);
+
+            SubscriptionInfo info = (SubscriptionInfo)o;
+            info.ClientId = LooseUnmarshalString(dataIn);
+            info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat,
dataIn);
+            info.Selector = LooseUnmarshalString(dataIn);
+            info.SubcriptionName = LooseUnmarshalString(dataIn);
+            info.SubscribedDestination = (ActiveMQDestination) LooseUnmarshalNestedObject(wireFormat,
dataIn);
+        }
+
+        // 
+        // Write a object instance to data output stream
+        //
+        public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter
dataOut)
+        {
+
+            SubscriptionInfo info = (SubscriptionInfo)o;
+
+            base.LooseMarshal(wireFormat, o, dataOut);
+            LooseMarshalString(info.ClientId, dataOut);
+            LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut);
+            LooseMarshalString(info.Selector, dataOut);
+            LooseMarshalString(info.SubcriptionName, dataOut);
+            LooseMarshalNestedObject(wireFormat, (DataStructure)info.SubscribedDestination,
dataOut);
+        }
+    }
+}

Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SubscriptionInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/TransactionIdMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/TransactionIdMarshaller.cs?rev=1133445&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/TransactionIdMarshaller.cs
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/TransactionIdMarshaller.cs
Wed Jun  8 15:50:39 2011
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/*
+ *
+ *  Marshaler code for OpenWire format for TransactionId
+ *
+ *  NOTE!: This file is auto generated - do not modify!
+ *         if you need to make a change, please see the Java Classes
+ *         in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V8
+{
+    /// <summary>
+    ///  Marshalling code for Open Wire Format for TransactionId
+    /// </summary>
+    abstract class TransactionIdMarshaller : BaseDataStreamMarshaller
+    {
+
+        // 
+        // Un-marshal an object instance from the data input stream
+        // 
+        public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader
dataIn, BooleanStream bs) 
+        {
+            base.TightUnmarshal(wireFormat, o, dataIn, bs);
+        }
+
+        //
+        // Write the booleans that this object uses to a BooleanStream
+        //
+        public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream
bs)
+        {
+
+            int rc = base.TightMarshal1(wireFormat, o, bs);
+
+            return rc + 0;
+        }
+
+        // 
+        // Write a object instance to data output stream
+        //
+        public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter
dataOut, BooleanStream bs)
+        {
+            base.TightMarshal2(wireFormat, o, dataOut, bs);
+        }
+
+        // 
+        // Un-marshal an object instance from the data input stream
+        // 
+        public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader
dataIn) 
+        {
+            base.LooseUnmarshal(wireFormat, o, dataIn);
+        }
+
+        // 
+        // Write a object instance to data output stream
+        //
+        public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter
dataOut)
+        {
+
+            base.LooseMarshal(wireFormat, o, dataOut);
+        }
+    }
+}

Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/TransactionIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/TransactionInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/TransactionInfoMarshaller.cs?rev=1133445&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/TransactionInfoMarshaller.cs
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/TransactionInfoMarshaller.cs
Wed Jun  8 15:50:39 2011
@@ -0,0 +1,123 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/*
+ *
+ *  Marshaler code for OpenWire format for TransactionInfo
+ *
+ *  NOTE!: This file is auto generated - do not modify!
+ *         if you need to make a change, please see the Java Classes
+ *         in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V8
+{
+    /// <summary>
+    ///  Marshalling code for Open Wire Format for TransactionInfo
+    /// </summary>
+    class TransactionInfoMarshaller : BaseCommandMarshaller
+    {
+        /// <summery>
+        ///  Creates an instance of the Object that this marshaller handles.
+        /// </summery>
+        public override DataStructure CreateObject() 
+        {
+            return new TransactionInfo();
+        }
+
+        /// <summery>
+        ///  Returns the type code for the Object that this Marshaller handles..
+        /// </summery>
+        public override byte GetDataStructureType() 
+        {
+            return TransactionInfo.ID_TRANSACTIONINFO;
+        }
+
+        // 
+        // Un-marshal an object instance from the data input stream
+        // 
+        public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader
dataIn, BooleanStream bs) 
+        {
+            base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+            TransactionInfo info = (TransactionInfo)o;
+            info.ConnectionId = (ConnectionId) TightUnmarshalCachedObject(wireFormat, dataIn,
bs);
+            info.TransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn,
bs);
+            info.Type = dataIn.ReadByte();
+        }
+
+        //
+        // Write the booleans that this object uses to a BooleanStream
+        //
+        public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream
bs)
+        {
+            TransactionInfo info = (TransactionInfo)o;
+
+            int rc = base.TightMarshal1(wireFormat, o, bs);
+            rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId,
bs);
+            rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId,
bs);
+
+            return rc + 1;
+        }
+
+        // 
+        // Write a object instance to data output stream
+        //
+        public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter
dataOut, BooleanStream bs)
+        {
+            base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+            TransactionInfo info = (TransactionInfo)o;
+            TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut,
bs);
+            TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut,
bs);
+            dataOut.Write(info.Type);
+        }
+
+        // 
+        // Un-marshal an object instance from the data input stream
+        // 
+        public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader
dataIn) 
+        {
+            base.LooseUnmarshal(wireFormat, o, dataIn);
+
+            TransactionInfo info = (TransactionInfo)o;
+            info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+            info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn);
+            info.Type = dataIn.ReadByte();
+        }
+
+        // 
+        // Write a object instance to data output stream
+        //
+        public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter
dataOut)
+        {
+
+            TransactionInfo info = (TransactionInfo)o;
+
+            base.LooseMarshal(wireFormat, o, dataOut);
+            LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut);
+            LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut);
+            dataOut.Write(info.Type);
+        }
+    }
+}

Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/TransactionInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/WireFormatInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/WireFormatInfoMarshaller.cs?rev=1133445&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/WireFormatInfoMarshaller.cs
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/WireFormatInfoMarshaller.cs
Wed Jun  8 15:50:39 2011
@@ -0,0 +1,148 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/*
+ *
+ *  Marshaler code for OpenWire format for WireFormatInfo
+ *
+ *  NOTE!: This file is auto generated - do not modify!
+ *         if you need to make a change, please see the Java Classes
+ *         in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V8
+{
+    /// <summary>
+    ///  Marshalling code for Open Wire Format for WireFormatInfo
+    /// </summary>
+    class WireFormatInfoMarshaller : BaseDataStreamMarshaller
+    {
+        /// <summery>
+        ///  Creates an instance of the Object that this marshaller handles.
+        /// </summery>
+        public override DataStructure CreateObject() 
+        {
+            return new WireFormatInfo();
+        }
+
+        /// <summery>
+        ///  Returns the type code for the Object that this Marshaller handles..
+        /// </summery>
+        public override byte GetDataStructureType() 
+        {
+            return WireFormatInfo.ID_WIREFORMATINFO;
+        }
+
+        // 
+        // Un-marshal an object instance from the data input stream
+        // 
+        public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader
dataIn, BooleanStream bs) 
+        {
+            base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+            WireFormatInfo info = (WireFormatInfo)o;
+
+            info.BeforeUnmarshall(wireFormat);
+
+            info.Magic = ReadBytes(dataIn, 8);
+            info.Version = dataIn.ReadInt32();
+            info.MarshalledProperties = ReadBytes(dataIn, bs.ReadBoolean());
+
+            info.AfterUnmarshall(wireFormat);
+        }
+
+        //
+        // Write the booleans that this object uses to a BooleanStream
+        //
+        public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream
bs)
+        {
+            WireFormatInfo info = (WireFormatInfo)o;
+
+            info.BeforeMarshall(wireFormat);
+
+            int rc = base.TightMarshal1(wireFormat, o, bs);
+            bs.WriteBoolean(info.MarshalledProperties!=null);
+            rc += info.MarshalledProperties==null ? 0 : info.MarshalledProperties.Length+4;
+
+            return rc + 12;
+        }
+
+        // 
+        // Write a object instance to data output stream
+        //
+        public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter
dataOut, BooleanStream bs)
+        {
+            base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+            WireFormatInfo info = (WireFormatInfo)o;
+            dataOut.Write(info.Magic, 0, 8);
+            dataOut.Write(info.Version);
+            if(bs.ReadBoolean()) {
+                dataOut.Write(info.MarshalledProperties.Length);
+                dataOut.Write(info.MarshalledProperties);
+            }
+
+            info.AfterMarshall(wireFormat);
+        }
+
+        // 
+        // Un-marshal an object instance from the data input stream
+        // 
+        public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader
dataIn) 
+        {
+            base.LooseUnmarshal(wireFormat, o, dataIn);
+
+            WireFormatInfo info = (WireFormatInfo)o;
+
+            info.BeforeUnmarshall(wireFormat);
+
+            info.Magic = ReadBytes(dataIn, 8);
+            info.Version = dataIn.ReadInt32();
+            info.MarshalledProperties = ReadBytes(dataIn, dataIn.ReadBoolean());
+
+            info.AfterUnmarshall(wireFormat);
+        }
+
+        // 
+        // Write a object instance to data output stream
+        //
+        public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter
dataOut)
+        {
+
+            WireFormatInfo info = (WireFormatInfo)o;
+
+            info.BeforeMarshall(wireFormat);
+
+            base.LooseMarshal(wireFormat, o, dataOut);
+            dataOut.Write(info.Magic, 0, 8);
+            dataOut.Write(info.Version);
+            dataOut.Write(info.MarshalledProperties!=null);
+            if(info.MarshalledProperties!=null) {
+               dataOut.Write(info.MarshalledProperties.Length);
+               dataOut.Write(info.MarshalledProperties);
+            }
+
+            info.AfterMarshall(wireFormat);
+        }
+    }
+}

Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/WireFormatInfoMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/XATransactionIdMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/XATransactionIdMarshaller.cs?rev=1133445&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/XATransactionIdMarshaller.cs
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/XATransactionIdMarshaller.cs
Wed Jun  8 15:50:39 2011
@@ -0,0 +1,139 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/*
+ *
+ *  Marshaler code for OpenWire format for XATransactionId
+ *
+ *  NOTE!: This file is auto generated - do not modify!
+ *         if you need to make a change, please see the Java Classes
+ *         in the nms-activemq-openwire-generator module
+ *
+ */
+
+using System;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V8
+{
+    /// <summary>
+    ///  Marshalling code for Open Wire Format for XATransactionId
+    /// </summary>
+    class XATransactionIdMarshaller : TransactionIdMarshaller
+    {
+        /// <summery>
+        ///  Creates an instance of the Object that this marshaller handles.
+        /// </summery>
+        public override DataStructure CreateObject() 
+        {
+            return new XATransactionId();
+        }
+
+        /// <summery>
+        ///  Returns the type code for the Object that this Marshaller handles..
+        /// </summery>
+        public override byte GetDataStructureType() 
+        {
+            return XATransactionId.ID_XATRANSACTIONID;
+        }
+
+        // 
+        // Un-marshal an object instance from the data input stream
+        // 
+        public override void TightUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader
dataIn, BooleanStream bs) 
+        {
+            base.TightUnmarshal(wireFormat, o, dataIn, bs);
+
+            XATransactionId info = (XATransactionId)o;
+            info.FormatId = dataIn.ReadInt32();
+            info.GlobalTransactionId = ReadBytes(dataIn, bs.ReadBoolean());
+            info.BranchQualifier = ReadBytes(dataIn, bs.ReadBoolean());
+        }
+
+        //
+        // Write the booleans that this object uses to a BooleanStream
+        //
+        public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream
bs)
+        {
+            XATransactionId info = (XATransactionId)o;
+
+            int rc = base.TightMarshal1(wireFormat, o, bs);
+            bs.WriteBoolean(info.GlobalTransactionId!=null);
+            rc += info.GlobalTransactionId==null ? 0 : info.GlobalTransactionId.Length+4;
+            bs.WriteBoolean(info.BranchQualifier!=null);
+            rc += info.BranchQualifier==null ? 0 : info.BranchQualifier.Length+4;
+
+            return rc + 4;
+        }
+
+        // 
+        // Write a object instance to data output stream
+        //
+        public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter
dataOut, BooleanStream bs)
+        {
+            base.TightMarshal2(wireFormat, o, dataOut, bs);
+
+            XATransactionId info = (XATransactionId)o;
+            dataOut.Write(info.FormatId);
+            if(bs.ReadBoolean()) {
+                dataOut.Write(info.GlobalTransactionId.Length);
+                dataOut.Write(info.GlobalTransactionId);
+            }
+            if(bs.ReadBoolean()) {
+                dataOut.Write(info.BranchQualifier.Length);
+                dataOut.Write(info.BranchQualifier);
+            }
+        }
+
+        // 
+        // Un-marshal an object instance from the data input stream
+        // 
+        public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader
dataIn) 
+        {
+            base.LooseUnmarshal(wireFormat, o, dataIn);
+
+            XATransactionId info = (XATransactionId)o;
+            info.FormatId = dataIn.ReadInt32();
+            info.GlobalTransactionId = ReadBytes(dataIn, dataIn.ReadBoolean());
+            info.BranchQualifier = ReadBytes(dataIn, dataIn.ReadBoolean());
+        }
+
+        // 
+        // Write a object instance to data output stream
+        //
+        public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter
dataOut)
+        {
+
+            XATransactionId info = (XATransactionId)o;
+
+            base.LooseMarshal(wireFormat, o, dataOut);
+            dataOut.Write(info.FormatId);
+            dataOut.Write(info.GlobalTransactionId!=null);
+            if(info.GlobalTransactionId!=null) {
+               dataOut.Write(info.GlobalTransactionId.Length);
+               dataOut.Write(info.GlobalTransactionId);
+            }
+            dataOut.Write(info.BranchQualifier!=null);
+            if(info.BranchQualifier!=null) {
+               dataOut.Write(info.BranchQualifier.Length);
+               dataOut.Write(info.BranchQualifier);
+            }
+        }
+    }
+}

Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/XATransactionIdMarshaller.cs
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message