[prev in list] [next in list] [prev in thread] [next in thread]
List: activemq-commits
Subject: svn commit: r799407 [28/29] - in
From: tabish () apache ! org
Date: 2009-07-30 19:06:44
Message-ID: 20090730190700.372842388A13 () eris ! apache ! org
[Download RAW message or body]
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/RemoveSubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/s \
rc/main/csharp/OpenWire/V5/RemoveSubscriptionInfoMarshaller.cs?rev=799407&view=auto \
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/RemoveSubscriptionInfoMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/RemoveSubscriptionInfoMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,127 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for RemoveSubscriptionInfo
+ *
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for RemoveSubscriptionInfo
+ /// </summary>
+ class RemoveSubscriptionInfoMarshaller : BaseCommandMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new RemoveSubscriptionInfo();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return RemoveSubscriptionInfo.ID_REMOVESUBSCRIPTIONINFO;
+ }
+
+ //
+ // 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);
+
+ RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o;
+ info.ConnectionId = (ConnectionId) \
TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.SubcriptionName \
= TightUnmarshalString(dataIn, bs); + info.ClientId = \
TightUnmarshalString(dataIn, bs); + }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, \
BooleanStream bs) + {
+ RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o;
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+ rc += TightMarshalCachedObject1(wireFormat, \
(DataStructure)info.ConnectionId, bs); + rc += \
TightMarshalString1(info.SubcriptionName, bs); + rc += \
TightMarshalString1(info.ClientId, 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);
+
+ RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o;
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, \
dataOut, bs); + TightMarshalString2(info.SubcriptionName, dataOut, bs);
+ TightMarshalString2(info.ClientId, 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);
+
+ RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o;
+ info.ConnectionId = (ConnectionId) \
LooseUnmarshalCachedObject(wireFormat, dataIn); + info.SubcriptionName = \
LooseUnmarshalString(dataIn); + info.ClientId = \
LooseUnmarshalString(dataIn); + }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, \
BinaryWriter dataOut) + {
+
+ RemoveSubscriptionInfo info = (RemoveSubscriptionInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, \
dataOut); + LooseMarshalString(info.SubcriptionName, dataOut);
+ LooseMarshalString(info.ClientId, dataOut);
+ }
+ }
+}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ReplayCommandMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ReplayCommandMarshaller.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ReplayCommandMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ReplayCommandMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,119 @@
+/*
+ * 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 ReplayCommand
+ *
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ReplayCommand
+ /// </summary>
+ class ReplayCommandMarshaller : BaseCommandMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ReplayCommand();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ReplayCommand.ID_REPLAYCOMMAND;
+ }
+
+ //
+ // 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);
+
+ ReplayCommand info = (ReplayCommand)o;
+ info.FirstNakNumber = dataIn.ReadInt32();
+ info.LastNakNumber = dataIn.ReadInt32();
+ }
+
+ //
+ // 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 + 8;
+ }
+
+ //
+ // 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);
+
+ ReplayCommand info = (ReplayCommand)o;
+ dataOut.Write(info.FirstNakNumber);
+ dataOut.Write(info.LastNakNumber);
+ }
+
+ //
+ // 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);
+
+ ReplayCommand info = (ReplayCommand)o;
+ info.FirstNakNumber = dataIn.ReadInt32();
+ info.LastNakNumber = dataIn.ReadInt32();
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, \
BinaryWriter dataOut) + {
+
+ ReplayCommand info = (ReplayCommand)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.FirstNakNumber);
+ dataOut.Write(info.LastNakNumber);
+ }
+ }
+}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ResponseMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ResponseMarshaller.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ResponseMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ResponseMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/*
+ *
+ * Marshaler code for OpenWire format for Response
+ *
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for Response
+ /// </summary>
+ class ResponseMarshaller : BaseCommandMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new Response();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return Response.ID_RESPONSE;
+ }
+
+ //
+ // 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);
+
+ Response info = (Response)o;
+ info.CorrelationId = dataIn.ReadInt32();
+ }
+
+ //
+ // 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 + 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);
+
+ Response info = (Response)o;
+ dataOut.Write(info.CorrelationId);
+ }
+
+ //
+ // 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);
+
+ Response info = (Response)o;
+ info.CorrelationId = dataIn.ReadInt32();
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, \
BinaryWriter dataOut) + {
+
+ Response info = (Response)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ dataOut.Write(info.CorrelationId);
+ }
+ }
+}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionIdMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionIdMarshaller.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionIdMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionIdMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,122 @@
+/*
+ * 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 SessionId
+ *
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for SessionId
+ /// </summary>
+ class SessionIdMarshaller : BaseDataStreamMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new SessionId();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return SessionId.ID_SESSIONID;
+ }
+
+ //
+ // 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);
+
+ SessionId info = (SessionId)o;
+ info.ConnectionId = TightUnmarshalString(dataIn, bs);
+ info.Value = TightUnmarshalLong(wireFormat, dataIn, bs);
+ }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, \
BooleanStream bs) + {
+ SessionId info = (SessionId)o;
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+ rc += TightMarshalString1(info.ConnectionId, bs);
+ rc += TightMarshalLong1(wireFormat, info.Value, 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);
+
+ SessionId info = (SessionId)o;
+ TightMarshalString2(info.ConnectionId, dataOut, bs);
+ TightMarshalLong2(wireFormat, info.Value, 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);
+
+ SessionId info = (SessionId)o;
+ info.ConnectionId = LooseUnmarshalString(dataIn);
+ info.Value = LooseUnmarshalLong(wireFormat, dataIn);
+ }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, \
BinaryWriter dataOut) + {
+
+ SessionId info = (SessionId)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalString(info.ConnectionId, dataOut);
+ LooseMarshalLong(wireFormat, info.Value, dataOut);
+ }
+ }
+}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionInfoMarshaller.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionInfoMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SessionInfoMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,117 @@
+/*
+ * 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 SessionInfo
+ *
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for SessionInfo
+ /// </summary>
+ class SessionInfoMarshaller : BaseCommandMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new SessionInfo();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return SessionInfo.ID_SESSIONINFO;
+ }
+
+ //
+ // 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);
+
+ SessionInfo info = (SessionInfo)o;
+ info.SessionId = (SessionId) TightUnmarshalCachedObject(wireFormat, \
dataIn, bs); + }
+
+ //
+ // Write the booleans that this object uses to a BooleanStream
+ //
+ public override int TightMarshal1(OpenWireFormat wireFormat, Object o, \
BooleanStream bs) + {
+ SessionInfo info = (SessionInfo)o;
+
+ int rc = base.TightMarshal1(wireFormat, o, bs);
+ rc += TightMarshalCachedObject1(wireFormat, \
(DataStructure)info.SessionId, 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);
+
+ SessionInfo info = (SessionInfo)o;
+ TightMarshalCachedObject2(wireFormat, (DataStructure)info.SessionId, \
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);
+
+ SessionInfo info = (SessionInfo)o;
+ info.SessionId = (SessionId) LooseUnmarshalCachedObject(wireFormat, \
dataIn); + }
+
+ //
+ // Write a object instance to data output stream
+ //
+ public override void LooseMarshal(OpenWireFormat wireFormat, Object o, \
BinaryWriter dataOut) + {
+
+ SessionInfo info = (SessionInfo)o;
+
+ base.LooseMarshal(wireFormat, o, dataOut);
+ LooseMarshalCachedObject(wireFormat, (DataStructure)info.SessionId, \
dataOut); + }
+ }
+}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ShutdownInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ShutdownInfoMarshaller.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ShutdownInfoMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/ShutdownInfoMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,103 @@
+/*
+ * 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 ShutdownInfo
+ *
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <summary>
+ /// Marshalling code for Open Wire Format for ShutdownInfo
+ /// </summary>
+ class ShutdownInfoMarshaller : BaseCommandMarshaller
+ {
+ /// <summery>
+ /// Creates an instance of the Object that this marshaller handles.
+ /// </summery>
+ public override DataStructure CreateObject()
+ {
+ return new ShutdownInfo();
+ }
+
+ /// <summery>
+ /// Returns the type code for the Object that this Marshaller handles..
+ /// </summery>
+ public override byte GetDataStructureType()
+ {
+ return ShutdownInfo.ID_SHUTDOWNINFO;
+ }
+
+ //
+ // 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);
+ }
+ }
+}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SubscriptionInfoMarshaller.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SubscriptionInfoMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/SubscriptionInfoMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,137 @@
+/*
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <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); + }
+ }
+}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionIdMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionIdMarshaller.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionIdMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionIdMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,88 @@
+/*
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <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);
+ }
+ }
+}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionInfoMarshaller.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionInfoMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/TransactionInfoMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,126 @@
+/*
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <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);
+ }
+ }
+}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/WireFormatInfoMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/WireFormatInfoMarshaller.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/WireFormatInfoMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/WireFormatInfoMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,151 @@
+/*
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <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);
+ }
+ }
+}
Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/XATransactionIdMarshaller.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/XATransactionIdMarshaller.cs?rev=799407&view=auto
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/XATransactionIdMarshaller.cs \
(added)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V5/XATransactionIdMarshaller.cs \
Thu Jul 30 19:06:34 2009 @@ -0,0 +1,142 @@
+/*
+ * 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.Collections;
+using System.IO;
+
+using Apache.NMS.ActiveMQ.Commands;
+using Apache.NMS.ActiveMQ.OpenWire;
+using Apache.NMS.ActiveMQ.OpenWire.V5;
+
+namespace Apache.NMS.ActiveMQ.OpenWire.V5
+{
+ /// <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);
+ }
+ }
+ }
+}
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic