Return-Path: X-Original-To: apmail-activemq-commits-archive@www.apache.org Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E7CC44C13 for ; Wed, 8 Jun 2011 15:51:18 +0000 (UTC) Received: (qmail 38230 invoked by uid 500); 8 Jun 2011 15:51:18 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 38188 invoked by uid 500); 8 Jun 2011 15:51:18 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 38181 invoked by uid 99); 8 Jun 2011 15:51:18 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 08 Jun 2011 15:51:18 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 08 Jun 2011 15:51:08 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 908F42388ABA; Wed, 8 Jun 2011 15:50:45 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1133445 [5/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 -0000 To: commits@activemq.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20110608155045.908F42388ABA@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/SubscriptionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/SubscriptionInfoMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/SubscriptionInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/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.V7 +{ + /// + /// Marshalling code for Open Wire Format for SubscriptionInfo + /// + class SubscriptionInfoMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new SubscriptionInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + 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/V7/SubscriptionInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/TransactionIdMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/TransactionIdMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/TransactionIdMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/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.V7 +{ + /// + /// Marshalling code for Open Wire Format for TransactionId + /// + 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/V7/TransactionIdMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/TransactionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/TransactionInfoMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/TransactionInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/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.V7 +{ + /// + /// Marshalling code for Open Wire Format for TransactionInfo + /// + class TransactionInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new TransactionInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + 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/V7/TransactionInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/WireFormatInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/WireFormatInfoMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/WireFormatInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/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.V7 +{ + /// + /// Marshalling code for Open Wire Format for WireFormatInfo + /// + class WireFormatInfoMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new WireFormatInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + 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/V7/WireFormatInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/XATransactionIdMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/XATransactionIdMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/XATransactionIdMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V7/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.V7 +{ + /// + /// Marshalling code for Open Wire Format for XATransactionId + /// + class XATransactionIdMarshaller : TransactionIdMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new XATransactionId(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + 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/V7/XATransactionIdMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQBlobMessageMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQBlobMessageMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQBlobMessageMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQBlobMessageMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,124 @@ +/* + * 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 ActiveMQBlobMessage + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQBlobMessage + /// + class ActiveMQBlobMessageMarshaller : ActiveMQMessageMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQBlobMessage(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQBlobMessage.ID_ACTIVEMQBLOBMESSAGE; + } + + // + // 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); + + ActiveMQBlobMessage info = (ActiveMQBlobMessage)o; + info.RemoteBlobUrl = TightUnmarshalString(dataIn, bs); + info.MimeType = TightUnmarshalString(dataIn, bs); + info.DeletedByBroker = bs.ReadBoolean(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + ActiveMQBlobMessage info = (ActiveMQBlobMessage)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalString1(info.RemoteBlobUrl, bs); + rc += TightMarshalString1(info.MimeType, bs); + bs.WriteBoolean(info.DeletedByBroker); + + 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); + + ActiveMQBlobMessage info = (ActiveMQBlobMessage)o; + TightMarshalString2(info.RemoteBlobUrl, dataOut, bs); + TightMarshalString2(info.MimeType, dataOut, bs); + bs.ReadBoolean(); + } + + // + // 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); + + ActiveMQBlobMessage info = (ActiveMQBlobMessage)o; + info.RemoteBlobUrl = LooseUnmarshalString(dataIn); + info.MimeType = LooseUnmarshalString(dataIn); + info.DeletedByBroker = dataIn.ReadBoolean(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ActiveMQBlobMessage info = (ActiveMQBlobMessage)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalString(info.RemoteBlobUrl, dataOut); + LooseMarshalString(info.MimeType, dataOut); + dataOut.Write(info.DeletedByBroker); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQBlobMessageMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQBytesMessageMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQBytesMessageMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQBytesMessageMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQBytesMessageMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,100 @@ +/* + * 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 ActiveMQBytesMessage + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQBytesMessage + /// + class ActiveMQBytesMessageMarshaller : ActiveMQMessageMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQBytesMessage(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQBytesMessage.ID_ACTIVEMQBYTESMESSAGE; + } + + // + // 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/ActiveMQBytesMessageMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQDestinationMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQDestinationMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQDestinationMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQDestinationMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,99 @@ +/* + * 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 ActiveMQDestination + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQDestination + /// + abstract class ActiveMQDestinationMarshaller : 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); + + ActiveMQDestination info = (ActiveMQDestination)o; + info.PhysicalName = TightUnmarshalString(dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + ActiveMQDestination info = (ActiveMQDestination)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalString1(info.PhysicalName, 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); + + ActiveMQDestination info = (ActiveMQDestination)o; + TightMarshalString2(info.PhysicalName, 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); + + ActiveMQDestination info = (ActiveMQDestination)o; + info.PhysicalName = LooseUnmarshalString(dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ActiveMQDestination info = (ActiveMQDestination)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalString(info.PhysicalName, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQDestinationMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQMapMessageMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQMapMessageMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQMapMessageMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQMapMessageMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,100 @@ +/* + * 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 ActiveMQMapMessage + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQMapMessage + /// + class ActiveMQMapMessageMarshaller : ActiveMQMessageMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQMapMessage(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQMapMessage.ID_ACTIVEMQMAPMESSAGE; + } + + // + // 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/ActiveMQMapMessageMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQMessageMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQMessageMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQMessageMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQMessageMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -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 ActiveMQMessage + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQMessage + /// + class ActiveMQMessageMarshaller : MessageMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQMessage(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQMessage.ID_ACTIVEMQMESSAGE; + } + + // + // 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); + + ActiveMQMessage info = (ActiveMQMessage)o; + + info.BeforeUnmarshall(wireFormat); + + + info.AfterUnmarshall(wireFormat); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + ActiveMQMessage info = (ActiveMQMessage)o; + + info.BeforeMarshall(wireFormat); + + 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); + + ActiveMQMessage info = (ActiveMQMessage)o; + + 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); + + ActiveMQMessage info = (ActiveMQMessage)o; + + info.BeforeUnmarshall(wireFormat); + + + info.AfterUnmarshall(wireFormat); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ActiveMQMessage info = (ActiveMQMessage)o; + + info.BeforeMarshall(wireFormat); + + base.LooseMarshal(wireFormat, o, dataOut); + + info.AfterMarshall(wireFormat); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQMessageMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQObjectMessageMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQObjectMessageMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQObjectMessageMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQObjectMessageMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,100 @@ +/* + * 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 ActiveMQObjectMessage + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQObjectMessage + /// + class ActiveMQObjectMessageMarshaller : ActiveMQMessageMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQObjectMessage(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQObjectMessage.ID_ACTIVEMQOBJECTMESSAGE; + } + + // + // 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/ActiveMQObjectMessageMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQQueueMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQQueueMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQQueueMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQQueueMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,100 @@ +/* + * 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 ActiveMQQueue + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQQueue + /// + class ActiveMQQueueMarshaller : ActiveMQDestinationMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQQueue(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQQueue.ID_ACTIVEMQQUEUE; + } + + // + // 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/ActiveMQQueueMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQStreamMessageMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQStreamMessageMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQStreamMessageMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQStreamMessageMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,100 @@ +/* + * 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 ActiveMQStreamMessage + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQStreamMessage + /// + class ActiveMQStreamMessageMarshaller : ActiveMQMessageMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQStreamMessage(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQStreamMessage.ID_ACTIVEMQSTREAMMESSAGE; + } + + // + // 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/ActiveMQStreamMessageMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempDestinationMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempDestinationMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempDestinationMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempDestinationMarshaller.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 ActiveMQTempDestination + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQTempDestination + /// + abstract class ActiveMQTempDestinationMarshaller : ActiveMQDestinationMarshaller + { + + // + // 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/ActiveMQTempDestinationMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempQueueMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempQueueMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempQueueMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempQueueMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,100 @@ +/* + * 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 ActiveMQTempQueue + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQTempQueue + /// + class ActiveMQTempQueueMarshaller : ActiveMQTempDestinationMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQTempQueue(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQTempQueue.ID_ACTIVEMQTEMPQUEUE; + } + + // + // 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/ActiveMQTempQueueMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempTopicMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempTopicMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempTopicMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTempTopicMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,100 @@ +/* + * 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 ActiveMQTempTopic + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQTempTopic + /// + class ActiveMQTempTopicMarshaller : ActiveMQTempDestinationMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQTempTopic(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQTempTopic.ID_ACTIVEMQTEMPTOPIC; + } + + // + // 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/ActiveMQTempTopicMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTextMessageMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTextMessageMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTextMessageMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTextMessageMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,100 @@ +/* + * 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 ActiveMQTextMessage + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQTextMessage + /// + class ActiveMQTextMessageMarshaller : ActiveMQMessageMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQTextMessage(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQTextMessage.ID_ACTIVEMQTEXTMESSAGE; + } + + // + // 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/ActiveMQTextMessageMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTopicMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTopicMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTopicMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ActiveMQTopicMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,100 @@ +/* + * 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 ActiveMQTopic + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for ActiveMQTopic + /// + class ActiveMQTopicMarshaller : ActiveMQDestinationMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ActiveMQTopic(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ActiveMQTopic.ID_ACTIVEMQTOPIC; + } + + // + // 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/ActiveMQTopicMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/BaseCommandMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/BaseCommandMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/BaseCommandMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/BaseCommandMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -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 BaseCommand + * + * 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 +{ + /// + /// Marshalling code for Open Wire Format for BaseCommand + /// + abstract class BaseCommandMarshaller : 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); + + BaseCommand info = (BaseCommand)o; + info.CommandId = dataIn.ReadInt32(); + info.ResponseRequired = bs.ReadBoolean(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + BaseCommand info = (BaseCommand)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + bs.WriteBoolean(info.ResponseRequired); + + 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); + + BaseCommand info = (BaseCommand)o; + dataOut.Write(info.CommandId); + bs.ReadBoolean(); + } + + // + // 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); + + BaseCommand info = (BaseCommand)o; + info.CommandId = dataIn.ReadInt32(); + info.ResponseRequired = dataIn.ReadBoolean(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + BaseCommand info = (BaseCommand)o; + + base.LooseMarshal(wireFormat, o, dataOut); + dataOut.Write(info.CommandId); + dataOut.Write(info.ResponseRequired); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/BaseCommandMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native