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 01C664CB3 for ; Wed, 8 Jun 2011 15:51:42 +0000 (UTC) Received: (qmail 40405 invoked by uid 500); 8 Jun 2011 15:51:41 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 40369 invoked by uid 500); 8 Jun 2011 15:51:41 -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 40362 invoked by uid 99); 8 Jun 2011 15:51:41 -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:41 +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:32 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id A00B52388C02; 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 [8/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.A00B52388C02@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/MessageMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/MessageMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/MessageMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/MessageMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,296 @@ +/* + * 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 Message + * + * 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 Message + ///

+ abstract class MessageMarshaller : BaseCommandMarshaller + { + + // + // 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); + + Message info = (Message)o; + info.ProducerId = (ProducerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.TransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.OriginalDestination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.OriginalTransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.GroupID = TightUnmarshalString(dataIn, bs); + info.GroupSequence = dataIn.ReadInt32(); + info.CorrelationId = TightUnmarshalString(dataIn, bs); + info.Persistent = bs.ReadBoolean(); + info.Expiration = TightUnmarshalLong(wireFormat, dataIn, bs); + info.Priority = dataIn.ReadByte(); + info.ReplyTo = (ActiveMQDestination) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.Timestamp = TightUnmarshalLong(wireFormat, dataIn, bs); + info.Type = TightUnmarshalString(dataIn, bs); + info.Content = ReadBytes(dataIn, bs.ReadBoolean()); + info.MarshalledProperties = ReadBytes(dataIn, bs.ReadBoolean()); + info.DataStructure = (DataStructure) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.TargetConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Compressed = bs.ReadBoolean(); + info.RedeliveryCounter = dataIn.ReadInt32(); + + if (bs.ReadBoolean()) { + short size = dataIn.ReadInt16(); + BrokerId[] value = new BrokerId[size]; + for( int i=0; i < size; i++ ) { + value[i] = (BrokerId) TightUnmarshalNestedObject(wireFormat,dataIn, bs); + } + info.BrokerPath = value; + } + else { + info.BrokerPath = null; + } + info.Arrival = TightUnmarshalLong(wireFormat, dataIn, bs); + info.UserID = TightUnmarshalString(dataIn, bs); + info.RecievedByDFBridge = bs.ReadBoolean(); + info.Droppable = bs.ReadBoolean(); + + if (bs.ReadBoolean()) { + short size = dataIn.ReadInt16(); + BrokerId[] value = new BrokerId[size]; + for( int i=0; i < size; i++ ) { + value[i] = (BrokerId) TightUnmarshalNestedObject(wireFormat,dataIn, bs); + } + info.Cluster = value; + } + else { + info.Cluster = null; + } + info.BrokerInTime = TightUnmarshalLong(wireFormat, dataIn, bs); + info.BrokerOutTime = TightUnmarshalLong(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + Message info = (Message)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalDestination, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.OriginalTransactionId, bs); + rc += TightMarshalString1(info.GroupID, bs); + rc += TightMarshalString1(info.CorrelationId, bs); + bs.WriteBoolean(info.Persistent); + rc += TightMarshalLong1(wireFormat, info.Expiration, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.ReplyTo, bs); + rc += TightMarshalLong1(wireFormat, info.Timestamp, bs); + rc += TightMarshalString1(info.Type, bs); + bs.WriteBoolean(info.Content!=null); + rc += info.Content==null ? 0 : info.Content.Length+4; + bs.WriteBoolean(info.MarshalledProperties!=null); + rc += info.MarshalledProperties==null ? 0 : info.MarshalledProperties.Length+4; + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.DataStructure, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TargetConsumerId, bs); + bs.WriteBoolean(info.Compressed); + rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs); + rc += TightMarshalLong1(wireFormat, info.Arrival, bs); + rc += TightMarshalString1(info.UserID, bs); + bs.WriteBoolean(info.RecievedByDFBridge); + bs.WriteBoolean(info.Droppable); + rc += TightMarshalObjectArray1(wireFormat, info.Cluster, bs); + rc += TightMarshalLong1(wireFormat, info.BrokerInTime, bs); + rc += TightMarshalLong1(wireFormat, info.BrokerOutTime, bs); + + return rc + 9; + } + + // + // 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); + + Message info = (Message)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalDestination, dataOut, bs); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.OriginalTransactionId, dataOut, bs); + TightMarshalString2(info.GroupID, dataOut, bs); + dataOut.Write(info.GroupSequence); + TightMarshalString2(info.CorrelationId, dataOut, bs); + bs.ReadBoolean(); + TightMarshalLong2(wireFormat, info.Expiration, dataOut, bs); + dataOut.Write(info.Priority); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.ReplyTo, dataOut, bs); + TightMarshalLong2(wireFormat, info.Timestamp, dataOut, bs); + TightMarshalString2(info.Type, dataOut, bs); + if(bs.ReadBoolean()) { + dataOut.Write(info.Content.Length); + dataOut.Write(info.Content); + } + if(bs.ReadBoolean()) { + dataOut.Write(info.MarshalledProperties.Length); + dataOut.Write(info.MarshalledProperties); + } + TightMarshalNestedObject2(wireFormat, (DataStructure)info.DataStructure, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.TargetConsumerId, dataOut, bs); + bs.ReadBoolean(); + dataOut.Write(info.RedeliveryCounter); + TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs); + TightMarshalLong2(wireFormat, info.Arrival, dataOut, bs); + TightMarshalString2(info.UserID, dataOut, bs); + bs.ReadBoolean(); + bs.ReadBoolean(); + TightMarshalObjectArray2(wireFormat, info.Cluster, dataOut, bs); + TightMarshalLong2(wireFormat, info.BrokerInTime, dataOut, bs); + TightMarshalLong2(wireFormat, info.BrokerOutTime, 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); + + Message info = (Message)o; + info.ProducerId = (ProducerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.OriginalDestination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.MessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.OriginalTransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.GroupID = LooseUnmarshalString(dataIn); + info.GroupSequence = dataIn.ReadInt32(); + info.CorrelationId = LooseUnmarshalString(dataIn); + info.Persistent = dataIn.ReadBoolean(); + info.Expiration = LooseUnmarshalLong(wireFormat, dataIn); + info.Priority = dataIn.ReadByte(); + info.ReplyTo = (ActiveMQDestination) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.Timestamp = LooseUnmarshalLong(wireFormat, dataIn); + info.Type = LooseUnmarshalString(dataIn); + info.Content = ReadBytes(dataIn, dataIn.ReadBoolean()); + info.MarshalledProperties = ReadBytes(dataIn, dataIn.ReadBoolean()); + info.DataStructure = (DataStructure) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.TargetConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Compressed = dataIn.ReadBoolean(); + info.RedeliveryCounter = dataIn.ReadInt32(); + + if (dataIn.ReadBoolean()) { + short size = dataIn.ReadInt16(); + BrokerId[] value = new BrokerId[size]; + for( int i=0; i < size; i++ ) { + value[i] = (BrokerId) LooseUnmarshalNestedObject(wireFormat,dataIn); + } + info.BrokerPath = value; + } + else { + info.BrokerPath = null; + } + info.Arrival = LooseUnmarshalLong(wireFormat, dataIn); + info.UserID = LooseUnmarshalString(dataIn); + info.RecievedByDFBridge = dataIn.ReadBoolean(); + info.Droppable = dataIn.ReadBoolean(); + + if (dataIn.ReadBoolean()) { + short size = dataIn.ReadInt16(); + BrokerId[] value = new BrokerId[size]; + for( int i=0; i < size; i++ ) { + value[i] = (BrokerId) LooseUnmarshalNestedObject(wireFormat,dataIn); + } + info.Cluster = value; + } + else { + info.Cluster = null; + } + info.BrokerInTime = LooseUnmarshalLong(wireFormat, dataIn); + info.BrokerOutTime = LooseUnmarshalLong(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + Message info = (Message)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ProducerId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.OriginalDestination, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.OriginalTransactionId, dataOut); + LooseMarshalString(info.GroupID, dataOut); + dataOut.Write(info.GroupSequence); + LooseMarshalString(info.CorrelationId, dataOut); + dataOut.Write(info.Persistent); + LooseMarshalLong(wireFormat, info.Expiration, dataOut); + dataOut.Write(info.Priority); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.ReplyTo, dataOut); + LooseMarshalLong(wireFormat, info.Timestamp, dataOut); + LooseMarshalString(info.Type, dataOut); + dataOut.Write(info.Content!=null); + if(info.Content!=null) { + dataOut.Write(info.Content.Length); + dataOut.Write(info.Content); + } + dataOut.Write(info.MarshalledProperties!=null); + if(info.MarshalledProperties!=null) { + dataOut.Write(info.MarshalledProperties.Length); + dataOut.Write(info.MarshalledProperties); + } + LooseMarshalNestedObject(wireFormat, (DataStructure)info.DataStructure, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.TargetConsumerId, dataOut); + dataOut.Write(info.Compressed); + dataOut.Write(info.RedeliveryCounter); + LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut); + LooseMarshalLong(wireFormat, info.Arrival, dataOut); + LooseMarshalString(info.UserID, dataOut); + dataOut.Write(info.RecievedByDFBridge); + dataOut.Write(info.Droppable); + LooseMarshalObjectArray(wireFormat, info.Cluster, dataOut); + LooseMarshalLong(wireFormat, info.BrokerInTime, dataOut); + LooseMarshalLong(wireFormat, info.BrokerOutTime, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/MessageMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/MessagePullMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/MessagePullMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/MessagePullMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/MessagePullMarshaller.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 MessagePull + * + * 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 MessagePull + ///

+ class MessagePullMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new MessagePull(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return MessagePull.ID_MESSAGEPULL; + } + + // + // 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); + + MessagePull info = (MessagePull)o; + info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Timeout = TightUnmarshalLong(wireFormat, dataIn, bs); + info.CorrelationId = TightUnmarshalString(dataIn, bs); + info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + MessagePull info = (MessagePull)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs); + rc += TightMarshalLong1(wireFormat, info.Timeout, bs); + rc += TightMarshalString1(info.CorrelationId, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, 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); + + MessagePull info = (MessagePull)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + TightMarshalLong2(wireFormat, info.Timeout, dataOut, bs); + TightMarshalString2(info.CorrelationId, dataOut, bs); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, 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); + + MessagePull info = (MessagePull)o; + info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Timeout = LooseUnmarshalLong(wireFormat, dataIn); + info.CorrelationId = LooseUnmarshalString(dataIn); + info.MessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + MessagePull info = (MessagePull)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut); + LooseMarshalLong(wireFormat, info.Timeout, dataOut); + LooseMarshalString(info.CorrelationId, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageId, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/MessagePullMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/NetworkBridgeFilterMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/NetworkBridgeFilterMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/NetworkBridgeFilterMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/NetworkBridgeFilterMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,118 @@ +/* + * 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 NetworkBridgeFilter + * + * 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 NetworkBridgeFilter + ///

+ class NetworkBridgeFilterMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new NetworkBridgeFilter(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return NetworkBridgeFilter.ID_NETWORKBRIDGEFILTER; + } + + // + // 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); + + NetworkBridgeFilter info = (NetworkBridgeFilter)o; + info.NetworkTTL = dataIn.ReadInt32(); + info.NetworkBrokerId = (BrokerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + NetworkBridgeFilter info = (NetworkBridgeFilter)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.NetworkBrokerId, 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); + + NetworkBridgeFilter info = (NetworkBridgeFilter)o; + dataOut.Write(info.NetworkTTL); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.NetworkBrokerId, 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); + + NetworkBridgeFilter info = (NetworkBridgeFilter)o; + info.NetworkTTL = dataIn.ReadInt32(); + info.NetworkBrokerId = (BrokerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + NetworkBridgeFilter info = (NetworkBridgeFilter)o; + + base.LooseMarshal(wireFormat, o, dataOut); + dataOut.Write(info.NetworkTTL); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.NetworkBrokerId, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/NetworkBridgeFilterMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/PartialCommandMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/PartialCommandMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/PartialCommandMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/PartialCommandMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -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 PartialCommand + * + * 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 PartialCommand + ///

+ class PartialCommandMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new PartialCommand(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return PartialCommand.ID_PARTIALCOMMAND; + } + + // + // 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); + + PartialCommand info = (PartialCommand)o; + info.CommandId = dataIn.ReadInt32(); + info.Data = ReadBytes(dataIn, bs.ReadBoolean()); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + PartialCommand info = (PartialCommand)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + bs.WriteBoolean(info.Data!=null); + rc += info.Data==null ? 0 : info.Data.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); + + PartialCommand info = (PartialCommand)o; + dataOut.Write(info.CommandId); + if(bs.ReadBoolean()) { + dataOut.Write(info.Data.Length); + dataOut.Write(info.Data); + } + } + + // + // 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); + + PartialCommand info = (PartialCommand)o; + info.CommandId = dataIn.ReadInt32(); + info.Data = ReadBytes(dataIn, dataIn.ReadBoolean()); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + PartialCommand info = (PartialCommand)o; + + base.LooseMarshal(wireFormat, o, dataOut); + dataOut.Write(info.CommandId); + dataOut.Write(info.Data!=null); + if(info.Data!=null) { + dataOut.Write(info.Data.Length); + dataOut.Write(info.Data); + } + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/PartialCommandMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerAckMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerAckMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerAckMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerAckMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,118 @@ +/* + * 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 ProducerAck + * + * 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 ProducerAck + ///

+ class ProducerAckMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ProducerAck(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ProducerAck.ID_PRODUCERACK; + } + + // + // 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); + + ProducerAck info = (ProducerAck)o; + info.ProducerId = (ProducerId) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.Size = dataIn.ReadInt32(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + ProducerAck info = (ProducerAck)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.ProducerId, 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); + + ProducerAck info = (ProducerAck)o; + TightMarshalNestedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs); + dataOut.Write(info.Size); + } + + // + // 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); + + ProducerAck info = (ProducerAck)o; + info.ProducerId = (ProducerId) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.Size = dataIn.ReadInt32(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ProducerAck info = (ProducerAck)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.ProducerId, dataOut); + dataOut.Write(info.Size); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerAckMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerIdMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerIdMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerIdMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerIdMarshaller.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 ProducerId + * + * 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 ProducerId + ///

+ class ProducerIdMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ProducerId(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ProducerId.ID_PRODUCERID; + } + + // + // 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); + + ProducerId info = (ProducerId)o; + info.ConnectionId = TightUnmarshalString(dataIn, bs); + info.Value = TightUnmarshalLong(wireFormat, dataIn, bs); + info.SessionId = TightUnmarshalLong(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + ProducerId info = (ProducerId)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalString1(info.ConnectionId, bs); + rc += TightMarshalLong1(wireFormat, info.Value, bs); + rc += TightMarshalLong1(wireFormat, 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); + + ProducerId info = (ProducerId)o; + TightMarshalString2(info.ConnectionId, dataOut, bs); + TightMarshalLong2(wireFormat, info.Value, dataOut, bs); + TightMarshalLong2(wireFormat, 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); + + ProducerId info = (ProducerId)o; + info.ConnectionId = LooseUnmarshalString(dataIn); + info.Value = LooseUnmarshalLong(wireFormat, dataIn); + info.SessionId = LooseUnmarshalLong(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ProducerId info = (ProducerId)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalString(info.ConnectionId, dataOut); + LooseMarshalLong(wireFormat, info.Value, dataOut); + LooseMarshalLong(wireFormat, info.SessionId, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerIdMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerInfoMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerInfoMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,155 @@ +/* + * 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 ProducerInfo + * + * 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 ProducerInfo + ///

+ class ProducerInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ProducerInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ProducerInfo.ID_PRODUCERINFO; + } + + // + // 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); + + ProducerInfo info = (ProducerInfo)o; + info.ProducerId = (ProducerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + + if (bs.ReadBoolean()) { + short size = dataIn.ReadInt16(); + BrokerId[] value = new BrokerId[size]; + for( int i=0; i < size; i++ ) { + value[i] = (BrokerId) TightUnmarshalNestedObject(wireFormat,dataIn, bs); + } + info.BrokerPath = value; + } + else { + info.BrokerPath = null; + } + info.DispatchAsync = bs.ReadBoolean(); + info.WindowSize = dataIn.ReadInt32(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + ProducerInfo info = (ProducerInfo)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs); + rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs); + bs.WriteBoolean(info.DispatchAsync); + + 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); + + ProducerInfo info = (ProducerInfo)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs); + bs.ReadBoolean(); + dataOut.Write(info.WindowSize); + } + + // + // 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); + + ProducerInfo info = (ProducerInfo)o; + info.ProducerId = (ProducerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn); + + if (dataIn.ReadBoolean()) { + short size = dataIn.ReadInt16(); + BrokerId[] value = new BrokerId[size]; + for( int i=0; i < size; i++ ) { + value[i] = (BrokerId) LooseUnmarshalNestedObject(wireFormat,dataIn); + } + info.BrokerPath = value; + } + else { + info.BrokerPath = null; + } + info.DispatchAsync = dataIn.ReadBoolean(); + info.WindowSize = dataIn.ReadInt32(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ProducerInfo info = (ProducerInfo)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ProducerId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut); + LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut); + dataOut.Write(info.DispatchAsync); + dataOut.Write(info.WindowSize); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ProducerInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/RemoveInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/RemoveInfoMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/RemoveInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/RemoveInfoMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -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 RemoveInfo + * + * 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 RemoveInfo + ///

+ class RemoveInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new RemoveInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return RemoveInfo.ID_REMOVEINFO; + } + + // + // 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); + + RemoveInfo info = (RemoveInfo)o; + info.ObjectId = (DataStructure) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.LastDeliveredSequenceId = TightUnmarshalLong(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + RemoveInfo info = (RemoveInfo)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ObjectId, bs); + rc += TightMarshalLong1(wireFormat, info.LastDeliveredSequenceId, 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); + + RemoveInfo info = (RemoveInfo)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ObjectId, dataOut, bs); + TightMarshalLong2(wireFormat, info.LastDeliveredSequenceId, 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); + + RemoveInfo info = (RemoveInfo)o; + info.ObjectId = (DataStructure) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.LastDeliveredSequenceId = LooseUnmarshalLong(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + RemoveInfo info = (RemoveInfo)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ObjectId, dataOut); + LooseMarshalLong(wireFormat, info.LastDeliveredSequenceId, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/RemoveInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/RemoveSubscriptionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/RemoveSubscriptionInfoMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/RemoveSubscriptionInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/RemoveSubscriptionInfoMarshaller.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 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.IO; + +using Apache.NMS.ActiveMQ.Commands; + +namespace Apache.NMS.ActiveMQ.OpenWire.V8 +{ + ///

+ /// Marshalling code for Open Wire Format for RemoveSubscriptionInfo + ///

+ class RemoveSubscriptionInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new RemoveSubscriptionInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + 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); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/RemoveSubscriptionInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ReplayCommandMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ReplayCommandMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ReplayCommandMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ReplayCommandMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,116 @@ +/* + * 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.IO; + +using Apache.NMS.ActiveMQ.Commands; + +namespace Apache.NMS.ActiveMQ.OpenWire.V8 +{ + ///

+ /// Marshalling code for Open Wire Format for ReplayCommand + ///

+ class ReplayCommandMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ReplayCommand(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + 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); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ReplayCommandMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ResponseMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ResponseMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ResponseMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ResponseMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,112 @@ +/* + * 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.IO; + +using Apache.NMS.ActiveMQ.Commands; + +namespace Apache.NMS.ActiveMQ.OpenWire.V8 +{ + ///

+ /// Marshalling code for Open Wire Format for Response + ///

+ class ResponseMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new Response(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + 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); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ResponseMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SessionIdMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SessionIdMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SessionIdMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SessionIdMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -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 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.IO; + +using Apache.NMS.ActiveMQ.Commands; + +namespace Apache.NMS.ActiveMQ.OpenWire.V8 +{ + ///

+ /// Marshalling code for Open Wire Format for SessionId + ///

+ class SessionIdMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new SessionId(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + 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); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SessionIdMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SessionInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SessionInfoMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SessionInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SessionInfoMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,114 @@ +/* + * 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.IO; + +using Apache.NMS.ActiveMQ.Commands; + +namespace Apache.NMS.ActiveMQ.OpenWire.V8 +{ + ///

+ /// Marshalling code for Open Wire Format for SessionInfo + ///

+ class SessionInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new SessionInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + 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); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/SessionInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ShutdownInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ShutdownInfoMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ShutdownInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ShutdownInfoMarshaller.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 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.IO; + +using Apache.NMS.ActiveMQ.Commands; + +namespace Apache.NMS.ActiveMQ.OpenWire.V8 +{ + ///

+ /// Marshalling code for Open Wire Format for ShutdownInfo + ///

+ class ShutdownInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ShutdownInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + 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); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ShutdownInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native