Return-Path: Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: (qmail 38386 invoked from network); 7 Jul 2010 20:22:20 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 7 Jul 2010 20:22:20 -0000 Received: (qmail 85279 invoked by uid 500); 7 Jul 2010 20:22:20 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 85194 invoked by uid 500); 7 Jul 2010 20:22:19 -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 85179 invoked by uid 99); 7 Jul 2010 20:22:19 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 07 Jul 2010 20:22:19 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.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, 07 Jul 2010 20:22:10 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 32FA323889E5; Wed, 7 Jul 2010 20:21:16 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r961494 [3/5] - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp: Commands/ OpenWire/ OpenWire/V6/ Date: Wed, 07 Jul 2010 20:21:15 -0000 To: commits@activemq.apache.org From: tabish@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20100707202116.32FA323889E5@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/ExceptionResponseMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/ExceptionResponseMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/ExceptionResponseMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/ExceptionResponseMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -0,0 +1,117 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for ExceptionResponse + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for ExceptionResponse + /// + class ExceptionResponseMarshaller : ResponseMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ExceptionResponse(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ExceptionResponse.ID_EXCEPTIONRESPONSE; + } + + // + // 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); + + ExceptionResponse info = (ExceptionResponse)o; + info.Exception = TightUnmarshalBrokerError(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + ExceptionResponse info = (ExceptionResponse)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalBrokerError1(wireFormat, info.Exception, 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); + + ExceptionResponse info = (ExceptionResponse)o; + TightMarshalBrokerError2(wireFormat, info.Exception, 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); + + ExceptionResponse info = (ExceptionResponse)o; + info.Exception = LooseUnmarshalBrokerError(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ExceptionResponse info = (ExceptionResponse)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalBrokerError(wireFormat, info.Exception, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/ExceptionResponseMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/FlushCommandMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/FlushCommandMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/FlushCommandMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/FlushCommandMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -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 FlushCommand + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for FlushCommand + /// + class FlushCommandMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new FlushCommand(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return FlushCommand.ID_FLUSHCOMMAND; + } + + // + // 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/V6/FlushCommandMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/IntegerResponseMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/IntegerResponseMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/IntegerResponseMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/IntegerResponseMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for IntegerResponse + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for IntegerResponse + /// + class IntegerResponseMarshaller : ResponseMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new IntegerResponse(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return IntegerResponse.ID_INTEGERRESPONSE; + } + + // + // 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); + + IntegerResponse info = (IntegerResponse)o; + info.Result = 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); + + IntegerResponse info = (IntegerResponse)o; + dataOut.Write(info.Result); + } + + // + // 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); + + IntegerResponse info = (IntegerResponse)o; + info.Result = dataIn.ReadInt32(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + IntegerResponse info = (IntegerResponse)o; + + base.LooseMarshal(wireFormat, o, dataOut); + dataOut.Write(info.Result); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/IntegerResponseMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalQueueAckMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalQueueAckMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalQueueAckMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalQueueAckMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for JournalQueueAck + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for JournalQueueAck + /// + class JournalQueueAckMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new JournalQueueAck(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return JournalQueueAck.ID_JOURNALQUEUEACK; + } + + // + // 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); + + JournalQueueAck info = (JournalQueueAck)o; + info.Destination = (ActiveMQDestination) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.MessageAck = (MessageAck) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + JournalQueueAck info = (JournalQueueAck)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Destination, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageAck, 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); + + JournalQueueAck info = (JournalQueueAck)o; + TightMarshalNestedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageAck, 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); + + JournalQueueAck info = (JournalQueueAck)o; + info.Destination = (ActiveMQDestination) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.MessageAck = (MessageAck) LooseUnmarshalNestedObject(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + JournalQueueAck info = (JournalQueueAck)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.Destination, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageAck, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalQueueAckMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTopicAckMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTopicAckMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTopicAckMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTopicAckMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -0,0 +1,142 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for JournalTopicAck + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for JournalTopicAck + /// + class JournalTopicAckMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new JournalTopicAck(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return JournalTopicAck.ID_JOURNALTOPICACK; + } + + // + // 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); + + JournalTopicAck info = (JournalTopicAck)o; + info.Destination = (ActiveMQDestination) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.MessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.MessageSequenceId = TightUnmarshalLong(wireFormat, dataIn, bs); + info.SubscritionName = TightUnmarshalString(dataIn, bs); + info.ClientId = TightUnmarshalString(dataIn, bs); + info.TransactionId = (TransactionId) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + JournalTopicAck info = (JournalTopicAck)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Destination, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.MessageId, bs); + rc += TightMarshalLong1(wireFormat, info.MessageSequenceId, bs); + rc += TightMarshalString1(info.SubscritionName, bs); + rc += TightMarshalString1(info.ClientId, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.TransactionId, 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); + + JournalTopicAck info = (JournalTopicAck)o; + TightMarshalNestedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.MessageId, dataOut, bs); + TightMarshalLong2(wireFormat, info.MessageSequenceId, dataOut, bs); + TightMarshalString2(info.SubscritionName, dataOut, bs); + TightMarshalString2(info.ClientId, dataOut, bs); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.TransactionId, 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); + + JournalTopicAck info = (JournalTopicAck)o; + info.Destination = (ActiveMQDestination) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.MessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.MessageSequenceId = LooseUnmarshalLong(wireFormat, dataIn); + info.SubscritionName = LooseUnmarshalString(dataIn); + info.ClientId = LooseUnmarshalString(dataIn); + info.TransactionId = (TransactionId) LooseUnmarshalNestedObject(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + JournalTopicAck info = (JournalTopicAck)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.Destination, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageId, dataOut); + LooseMarshalLong(wireFormat, info.MessageSequenceId, dataOut); + LooseMarshalString(info.SubscritionName, dataOut); + LooseMarshalString(info.ClientId, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.TransactionId, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTopicAckMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTraceMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTraceMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTraceMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTraceMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -0,0 +1,117 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for JournalTrace + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for JournalTrace + /// + class JournalTraceMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new JournalTrace(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return JournalTrace.ID_JOURNALTRACE; + } + + // + // 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); + + JournalTrace info = (JournalTrace)o; + info.Message = TightUnmarshalString(dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + JournalTrace info = (JournalTrace)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalString1(info.Message, 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); + + JournalTrace info = (JournalTrace)o; + TightMarshalString2(info.Message, 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); + + JournalTrace info = (JournalTrace)o; + info.Message = LooseUnmarshalString(dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + JournalTrace info = (JournalTrace)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalString(info.Message, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTraceMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTransactionMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTransactionMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTransactionMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTransactionMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -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 JournalTransaction + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for JournalTransaction + /// + class JournalTransactionMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new JournalTransaction(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return JournalTransaction.ID_JOURNALTRANSACTION; + } + + // + // 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); + + JournalTransaction info = (JournalTransaction)o; + info.TransactionId = (TransactionId) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.Type = dataIn.ReadByte(); + info.WasPrepared = bs.ReadBoolean(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + JournalTransaction info = (JournalTransaction)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.TransactionId, bs); + bs.WriteBoolean(info.WasPrepared); + + 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); + + JournalTransaction info = (JournalTransaction)o; + TightMarshalNestedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs); + dataOut.Write(info.Type); + 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); + + JournalTransaction info = (JournalTransaction)o; + info.TransactionId = (TransactionId) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.Type = dataIn.ReadByte(); + info.WasPrepared = dataIn.ReadBoolean(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + JournalTransaction info = (JournalTransaction)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.TransactionId, dataOut); + dataOut.Write(info.Type); + dataOut.Write(info.WasPrepared); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/JournalTransactionMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/KeepAliveInfoMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/KeepAliveInfoMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/KeepAliveInfoMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/KeepAliveInfoMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -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 KeepAliveInfo + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for KeepAliveInfo + /// + class KeepAliveInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new KeepAliveInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return KeepAliveInfo.ID_KEEPALIVEINFO; + } + + // + // 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/V6/KeepAliveInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/LastPartialCommandMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/LastPartialCommandMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/LastPartialCommandMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/LastPartialCommandMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -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 LastPartialCommand + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for LastPartialCommand + /// + class LastPartialCommandMarshaller : PartialCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new LastPartialCommand(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return LastPartialCommand.ID_LASTPARTIALCOMMAND; + } + + // + // 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/V6/LastPartialCommandMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/LocalTransactionIdMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/LocalTransactionIdMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/LocalTransactionIdMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/LocalTransactionIdMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/* + * + * Marshaler code for OpenWire format for LocalTransactionId + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for LocalTransactionId + /// + class LocalTransactionIdMarshaller : TransactionIdMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new LocalTransactionId(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return LocalTransactionId.ID_LOCALTRANSACTIONID; + } + + // + // 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); + + LocalTransactionId info = (LocalTransactionId)o; + info.Value = TightUnmarshalLong(wireFormat, dataIn, bs); + info.ConnectionId = (ConnectionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + LocalTransactionId info = (LocalTransactionId)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalLong1(wireFormat, info.Value, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, 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); + + LocalTransactionId info = (LocalTransactionId)o; + TightMarshalLong2(wireFormat, info.Value, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, 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); + + LocalTransactionId info = (LocalTransactionId)o; + info.Value = LooseUnmarshalLong(wireFormat, dataIn); + info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + LocalTransactionId info = (LocalTransactionId)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalLong(wireFormat, info.Value, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/LocalTransactionIdMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MarshallerFactory.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MarshallerFactory.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MarshallerFactory.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MarshallerFactory.cs Wed Jul 7 20:21:12 2010 @@ -0,0 +1,109 @@ +/* + * 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. + */ +/* + * + * MarshallerFactory code for OpenWire Protocol Version 6 + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Used to create marshallers for a specific version of the OpenWire protocol. + /// Each non-abstract DataStructure object has a registered Marshaller that is + /// created and added to the OpenWireFormat objects format collection. + /// + public class MarshallerFactory : IMarshallerFactory + { + /// + /// Adds the Marshallers for this version of the OpenWire protocol to the + /// Collection of Marshallers stored in the OpenWireFormat class. + /// + public void configure(OpenWireFormat format) + { + format.clearMarshallers(); + format.addMarshaller(new ActiveMQBlobMessageMarshaller()); + format.addMarshaller(new ActiveMQBytesMessageMarshaller()); + format.addMarshaller(new ActiveMQMapMessageMarshaller()); + format.addMarshaller(new ActiveMQMessageMarshaller()); + format.addMarshaller(new ActiveMQObjectMessageMarshaller()); + format.addMarshaller(new ActiveMQQueueMarshaller()); + format.addMarshaller(new ActiveMQStreamMessageMarshaller()); + format.addMarshaller(new ActiveMQTempQueueMarshaller()); + format.addMarshaller(new ActiveMQTempTopicMarshaller()); + format.addMarshaller(new ActiveMQTextMessageMarshaller()); + format.addMarshaller(new ActiveMQTopicMarshaller()); + format.addMarshaller(new BrokerIdMarshaller()); + format.addMarshaller(new BrokerInfoMarshaller()); + format.addMarshaller(new ConnectionControlMarshaller()); + format.addMarshaller(new ConnectionErrorMarshaller()); + format.addMarshaller(new ConnectionIdMarshaller()); + format.addMarshaller(new ConnectionInfoMarshaller()); + format.addMarshaller(new ConsumerControlMarshaller()); + format.addMarshaller(new ConsumerIdMarshaller()); + format.addMarshaller(new ConsumerInfoMarshaller()); + format.addMarshaller(new ControlCommandMarshaller()); + format.addMarshaller(new DataArrayResponseMarshaller()); + format.addMarshaller(new DataResponseMarshaller()); + format.addMarshaller(new DestinationInfoMarshaller()); + format.addMarshaller(new DiscoveryEventMarshaller()); + format.addMarshaller(new ExceptionResponseMarshaller()); + format.addMarshaller(new FlushCommandMarshaller()); + format.addMarshaller(new IntegerResponseMarshaller()); + format.addMarshaller(new JournalQueueAckMarshaller()); + format.addMarshaller(new JournalTopicAckMarshaller()); + format.addMarshaller(new JournalTraceMarshaller()); + format.addMarshaller(new JournalTransactionMarshaller()); + format.addMarshaller(new KeepAliveInfoMarshaller()); + format.addMarshaller(new LastPartialCommandMarshaller()); + format.addMarshaller(new LocalTransactionIdMarshaller()); + format.addMarshaller(new MessageAckMarshaller()); + format.addMarshaller(new MessageDispatchMarshaller()); + format.addMarshaller(new MessageDispatchNotificationMarshaller()); + format.addMarshaller(new MessageIdMarshaller()); + format.addMarshaller(new MessagePullMarshaller()); + format.addMarshaller(new NetworkBridgeFilterMarshaller()); + format.addMarshaller(new PartialCommandMarshaller()); + format.addMarshaller(new ProducerAckMarshaller()); + format.addMarshaller(new ProducerIdMarshaller()); + format.addMarshaller(new ProducerInfoMarshaller()); + format.addMarshaller(new RemoveInfoMarshaller()); + format.addMarshaller(new RemoveSubscriptionInfoMarshaller()); + format.addMarshaller(new ReplayCommandMarshaller()); + format.addMarshaller(new ResponseMarshaller()); + format.addMarshaller(new SessionIdMarshaller()); + format.addMarshaller(new SessionInfoMarshaller()); + format.addMarshaller(new ShutdownInfoMarshaller()); + format.addMarshaller(new SubscriptionInfoMarshaller()); + format.addMarshaller(new TransactionInfoMarshaller()); + format.addMarshaller(new WireFormatInfoMarshaller()); + format.addMarshaller(new XATransactionIdMarshaller()); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MarshallerFactory.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageAckMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageAckMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageAckMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageAckMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -0,0 +1,145 @@ +/* + * 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 MessageAck + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for MessageAck + /// + class MessageAckMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new MessageAck(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return MessageAck.ID_MESSAGEACK; + } + + // + // 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); + + MessageAck info = (MessageAck)o; + info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.TransactionId = (TransactionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.AckType = dataIn.ReadByte(); + info.FirstMessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.LastMessageId = (MessageId) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.MessageCount = dataIn.ReadInt32(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + MessageAck info = (MessageAck)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.TransactionId, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.FirstMessageId, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.LastMessageId, bs); + + return rc + 5; + } + + // + // 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); + + MessageAck info = (MessageAck)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.TransactionId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs); + dataOut.Write(info.AckType); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.FirstMessageId, dataOut, bs); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.LastMessageId, dataOut, bs); + dataOut.Write(info.MessageCount); + } + + // + // 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); + + MessageAck info = (MessageAck)o; + info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.TransactionId = (TransactionId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.AckType = dataIn.ReadByte(); + info.FirstMessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.LastMessageId = (MessageId) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.MessageCount = dataIn.ReadInt32(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + MessageAck info = (MessageAck)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.TransactionId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut); + dataOut.Write(info.AckType); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.FirstMessageId, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.LastMessageId, dataOut); + dataOut.Write(info.MessageCount); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageAckMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageDispatchMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageDispatchMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageDispatchMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageDispatchMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -0,0 +1,131 @@ +/* + * 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 MessageDispatch + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for MessageDispatch + /// + class MessageDispatchMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new MessageDispatch(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return MessageDispatch.ID_MESSAGEDISPATCH; + } + + // + // 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); + + MessageDispatch info = (MessageDispatch)o; + info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Message = (Message) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.RedeliveryCounter = dataIn.ReadInt32(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + MessageDispatch info = (MessageDispatch)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.Message, 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); + + MessageDispatch info = (MessageDispatch)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.Message, dataOut, bs); + dataOut.Write(info.RedeliveryCounter); + } + + // + // 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); + + MessageDispatch info = (MessageDispatch)o; + info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Message = (Message) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.RedeliveryCounter = dataIn.ReadInt32(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + MessageDispatch info = (MessageDispatch)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.Message, dataOut); + dataOut.Write(info.RedeliveryCounter); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageDispatchMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageDispatchNotificationMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageDispatchNotificationMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageDispatchNotificationMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageDispatchNotificationMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -0,0 +1,132 @@ +/* + * 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 MessageDispatchNotification + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for MessageDispatchNotification + /// + class MessageDispatchNotificationMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new MessageDispatchNotification(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return MessageDispatchNotification.ID_MESSAGEDISPATCHNOTIFICATION; + } + + // + // 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); + + MessageDispatchNotification info = (MessageDispatchNotification)o; + info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.DeliverySequenceId = TightUnmarshalLong(wireFormat, 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) + { + MessageDispatchNotification info = (MessageDispatchNotification)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.DeliverySequenceId, 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); + + MessageDispatchNotification info = (MessageDispatchNotification)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + TightMarshalLong2(wireFormat, info.DeliverySequenceId, 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); + + MessageDispatchNotification info = (MessageDispatchNotification)o; + info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.DeliverySequenceId = LooseUnmarshalLong(wireFormat, 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) + { + + MessageDispatchNotification info = (MessageDispatchNotification)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut); + LooseMarshalLong(wireFormat, info.DeliverySequenceId, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.MessageId, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageDispatchNotificationMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageIdMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageIdMarshaller.cs?rev=961494&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageIdMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageIdMarshaller.cs Wed Jul 7 20:21:12 2010 @@ -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 MessageId + * + * NOTE!: This file is auto generated - do not modify! + * if you need to make a change, please see the Java Classes + * in the nms-activemq-openwire-generator module + * + */ + +using System; +using System.Collections; +using System.IO; + +using Apache.NMS.ActiveMQ.Commands; +using Apache.NMS.ActiveMQ.OpenWire; +using Apache.NMS.ActiveMQ.OpenWire.V6; + +namespace Apache.NMS.ActiveMQ.OpenWire.V6 +{ + /// + /// Marshalling code for Open Wire Format for MessageId + /// + class MessageIdMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new MessageId(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return MessageId.ID_MESSAGEID; + } + + // + // 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); + + MessageId info = (MessageId)o; + info.ProducerId = (ProducerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.ProducerSequenceId = TightUnmarshalLong(wireFormat, dataIn, bs); + info.BrokerSequenceId = TightUnmarshalLong(wireFormat, dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + MessageId info = (MessageId)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ProducerId, bs); + rc += TightMarshalLong1(wireFormat, info.ProducerSequenceId, bs); + rc += TightMarshalLong1(wireFormat, info.BrokerSequenceId, 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); + + MessageId info = (MessageId)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ProducerId, dataOut, bs); + TightMarshalLong2(wireFormat, info.ProducerSequenceId, dataOut, bs); + TightMarshalLong2(wireFormat, info.BrokerSequenceId, 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); + + MessageId info = (MessageId)o; + info.ProducerId = (ProducerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.ProducerSequenceId = LooseUnmarshalLong(wireFormat, dataIn); + info.BrokerSequenceId = LooseUnmarshalLong(wireFormat, dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + MessageId info = (MessageId)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ProducerId, dataOut); + LooseMarshalLong(wireFormat, info.ProducerSequenceId, dataOut); + LooseMarshalLong(wireFormat, info.BrokerSequenceId, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V6/MessageIdMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native