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 041694C72 for ; Wed, 8 Jun 2011 15:51:33 +0000 (UTC) Received: (qmail 39538 invoked by uid 500); 8 Jun 2011 15:51:32 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 39499 invoked by uid 500); 8 Jun 2011 15:51:32 -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 39492 invoked by uid 99); 8 Jun 2011 15:51:32 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 08 Jun 2011 15:51:32 +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:29 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 9A5C62388B1B; 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 [6/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.9A5C62388B1B@eris.apache.org> Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/BrokerIdMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/BrokerIdMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/BrokerIdMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/BrokerIdMarshaller.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 BrokerId + * + * 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 BrokerId + ///

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

+ class BrokerInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new BrokerInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return BrokerInfo.ID_BROKERINFO; + } + + // + // 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); + + BrokerInfo info = (BrokerInfo)o; + info.BrokerId = (BrokerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.BrokerURL = TightUnmarshalString(dataIn, bs); + + if (bs.ReadBoolean()) { + short size = dataIn.ReadInt16(); + BrokerInfo[] value = new BrokerInfo[size]; + for( int i=0; i < size; i++ ) { + value[i] = (BrokerInfo) TightUnmarshalNestedObject(wireFormat,dataIn, bs); + } + info.PeerBrokerInfos = value; + } + else { + info.PeerBrokerInfos = null; + } + info.BrokerName = TightUnmarshalString(dataIn, bs); + info.SlaveBroker = bs.ReadBoolean(); + info.MasterBroker = bs.ReadBoolean(); + info.FaultTolerantConfiguration = bs.ReadBoolean(); + info.DuplexConnection = bs.ReadBoolean(); + info.NetworkConnection = bs.ReadBoolean(); + info.ConnectionId = TightUnmarshalLong(wireFormat, dataIn, bs); + info.BrokerUploadUrl = TightUnmarshalString(dataIn, bs); + info.NetworkProperties = TightUnmarshalString(dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + BrokerInfo info = (BrokerInfo)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.BrokerId, bs); + rc += TightMarshalString1(info.BrokerURL, bs); + rc += TightMarshalObjectArray1(wireFormat, info.PeerBrokerInfos, bs); + rc += TightMarshalString1(info.BrokerName, bs); + bs.WriteBoolean(info.SlaveBroker); + bs.WriteBoolean(info.MasterBroker); + bs.WriteBoolean(info.FaultTolerantConfiguration); + bs.WriteBoolean(info.DuplexConnection); + bs.WriteBoolean(info.NetworkConnection); + rc += TightMarshalLong1(wireFormat, info.ConnectionId, bs); + rc += TightMarshalString1(info.BrokerUploadUrl, bs); + rc += TightMarshalString1(info.NetworkProperties, 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); + + BrokerInfo info = (BrokerInfo)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.BrokerId, dataOut, bs); + TightMarshalString2(info.BrokerURL, dataOut, bs); + TightMarshalObjectArray2(wireFormat, info.PeerBrokerInfos, dataOut, bs); + TightMarshalString2(info.BrokerName, dataOut, bs); + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + TightMarshalLong2(wireFormat, info.ConnectionId, dataOut, bs); + TightMarshalString2(info.BrokerUploadUrl, dataOut, bs); + TightMarshalString2(info.NetworkProperties, 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); + + BrokerInfo info = (BrokerInfo)o; + info.BrokerId = (BrokerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.BrokerURL = LooseUnmarshalString(dataIn); + + if (dataIn.ReadBoolean()) { + short size = dataIn.ReadInt16(); + BrokerInfo[] value = new BrokerInfo[size]; + for( int i=0; i < size; i++ ) { + value[i] = (BrokerInfo) LooseUnmarshalNestedObject(wireFormat,dataIn); + } + info.PeerBrokerInfos = value; + } + else { + info.PeerBrokerInfos = null; + } + info.BrokerName = LooseUnmarshalString(dataIn); + info.SlaveBroker = dataIn.ReadBoolean(); + info.MasterBroker = dataIn.ReadBoolean(); + info.FaultTolerantConfiguration = dataIn.ReadBoolean(); + info.DuplexConnection = dataIn.ReadBoolean(); + info.NetworkConnection = dataIn.ReadBoolean(); + info.ConnectionId = LooseUnmarshalLong(wireFormat, dataIn); + info.BrokerUploadUrl = LooseUnmarshalString(dataIn); + info.NetworkProperties = LooseUnmarshalString(dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + BrokerInfo info = (BrokerInfo)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.BrokerId, dataOut); + LooseMarshalString(info.BrokerURL, dataOut); + LooseMarshalObjectArray(wireFormat, info.PeerBrokerInfos, dataOut); + LooseMarshalString(info.BrokerName, dataOut); + dataOut.Write(info.SlaveBroker); + dataOut.Write(info.MasterBroker); + dataOut.Write(info.FaultTolerantConfiguration); + dataOut.Write(info.DuplexConnection); + dataOut.Write(info.NetworkConnection); + LooseMarshalLong(wireFormat, info.ConnectionId, dataOut); + LooseMarshalString(info.BrokerUploadUrl, dataOut); + LooseMarshalString(info.NetworkProperties, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/BrokerInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConnectionControlMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConnectionControlMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConnectionControlMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConnectionControlMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,149 @@ +/* + * 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 ConnectionControl + * + * 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 ConnectionControl + ///

+ class ConnectionControlMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ConnectionControl(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ConnectionControl.ID_CONNECTIONCONTROL; + } + + // + // 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); + + ConnectionControl info = (ConnectionControl)o; + info.Close = bs.ReadBoolean(); + info.Exit = bs.ReadBoolean(); + info.FaultTolerant = bs.ReadBoolean(); + info.Resume = bs.ReadBoolean(); + info.Suspend = bs.ReadBoolean(); + info.ConnectedBrokers = TightUnmarshalString(dataIn, bs); + info.ReconnectTo = TightUnmarshalString(dataIn, bs); + info.RebalanceConnection = bs.ReadBoolean(); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + ConnectionControl info = (ConnectionControl)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + bs.WriteBoolean(info.Close); + bs.WriteBoolean(info.Exit); + bs.WriteBoolean(info.FaultTolerant); + bs.WriteBoolean(info.Resume); + bs.WriteBoolean(info.Suspend); + rc += TightMarshalString1(info.ConnectedBrokers, bs); + rc += TightMarshalString1(info.ReconnectTo, bs); + bs.WriteBoolean(info.RebalanceConnection); + + 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); + + ConnectionControl info = (ConnectionControl)o; + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + TightMarshalString2(info.ConnectedBrokers, dataOut, bs); + TightMarshalString2(info.ReconnectTo, dataOut, bs); + bs.ReadBoolean(); + } + + // + // Un-marshal an object instance from the data input stream + // + public override void LooseUnmarshal(OpenWireFormat wireFormat, Object o, BinaryReader dataIn) + { + base.LooseUnmarshal(wireFormat, o, dataIn); + + ConnectionControl info = (ConnectionControl)o; + info.Close = dataIn.ReadBoolean(); + info.Exit = dataIn.ReadBoolean(); + info.FaultTolerant = dataIn.ReadBoolean(); + info.Resume = dataIn.ReadBoolean(); + info.Suspend = dataIn.ReadBoolean(); + info.ConnectedBrokers = LooseUnmarshalString(dataIn); + info.ReconnectTo = LooseUnmarshalString(dataIn); + info.RebalanceConnection = dataIn.ReadBoolean(); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ConnectionControl info = (ConnectionControl)o; + + base.LooseMarshal(wireFormat, o, dataOut); + dataOut.Write(info.Close); + dataOut.Write(info.Exit); + dataOut.Write(info.FaultTolerant); + dataOut.Write(info.Resume); + dataOut.Write(info.Suspend); + LooseMarshalString(info.ConnectedBrokers, dataOut); + LooseMarshalString(info.ReconnectTo, dataOut); + dataOut.Write(info.RebalanceConnection); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConnectionControlMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConnectionErrorMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConnectionErrorMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConnectionErrorMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConnectionErrorMarshaller.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 ConnectionError + * + * 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 ConnectionError + ///

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

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

+ class ConnectionInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ConnectionInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ConnectionInfo.ID_CONNECTIONINFO; + } + + // + // 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); + + ConnectionInfo info = (ConnectionInfo)o; + info.ConnectionId = (ConnectionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.ClientId = TightUnmarshalString(dataIn, bs); + info.Password = TightUnmarshalString(dataIn, bs); + info.UserName = TightUnmarshalString(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.BrokerMasterConnector = bs.ReadBoolean(); + info.Manageable = bs.ReadBoolean(); + info.ClientMaster = bs.ReadBoolean(); + info.FaultTolerant = bs.ReadBoolean(); + info.FailoverReconnect = bs.ReadBoolean(); + info.ClientIp = TightUnmarshalString(dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + ConnectionInfo info = (ConnectionInfo)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs); + rc += TightMarshalString1(info.ClientId, bs); + rc += TightMarshalString1(info.Password, bs); + rc += TightMarshalString1(info.UserName, bs); + rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs); + bs.WriteBoolean(info.BrokerMasterConnector); + bs.WriteBoolean(info.Manageable); + bs.WriteBoolean(info.ClientMaster); + bs.WriteBoolean(info.FaultTolerant); + bs.WriteBoolean(info.FailoverReconnect); + rc += TightMarshalString1(info.ClientIp, 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); + + ConnectionInfo info = (ConnectionInfo)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs); + TightMarshalString2(info.ClientId, dataOut, bs); + TightMarshalString2(info.Password, dataOut, bs); + TightMarshalString2(info.UserName, dataOut, bs); + TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs); + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + TightMarshalString2(info.ClientIp, 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); + + ConnectionInfo info = (ConnectionInfo)o; + info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.ClientId = LooseUnmarshalString(dataIn); + info.Password = LooseUnmarshalString(dataIn); + info.UserName = LooseUnmarshalString(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.BrokerMasterConnector = dataIn.ReadBoolean(); + info.Manageable = dataIn.ReadBoolean(); + info.ClientMaster = dataIn.ReadBoolean(); + info.FaultTolerant = dataIn.ReadBoolean(); + info.FailoverReconnect = dataIn.ReadBoolean(); + info.ClientIp = LooseUnmarshalString(dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ConnectionInfo info = (ConnectionInfo)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut); + LooseMarshalString(info.ClientId, dataOut); + LooseMarshalString(info.Password, dataOut); + LooseMarshalString(info.UserName, dataOut); + LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut); + dataOut.Write(info.BrokerMasterConnector); + dataOut.Write(info.Manageable); + dataOut.Write(info.ClientMaster); + dataOut.Write(info.FaultTolerant); + dataOut.Write(info.FailoverReconnect); + LooseMarshalString(info.ClientIp, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConnectionInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConsumerControlMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConsumerControlMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConsumerControlMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConsumerControlMarshaller.cs Wed Jun 8 15:50:39 2011 @@ -0,0 +1,143 @@ +/* + * 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 ConsumerControl + * + * 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 ConsumerControl + ///

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

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

+ class ConsumerInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new ConsumerInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return ConsumerInfo.ID_CONSUMERINFO; + } + + // + // 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); + + ConsumerInfo info = (ConsumerInfo)o; + info.ConsumerId = (ConsumerId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Browser = bs.ReadBoolean(); + info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.PrefetchSize = dataIn.ReadInt32(); + info.MaximumPendingMessageLimit = dataIn.ReadInt32(); + info.DispatchAsync = bs.ReadBoolean(); + info.Selector = TightUnmarshalString(dataIn, bs); + info.SubscriptionName = TightUnmarshalString(dataIn, bs); + info.NoLocal = bs.ReadBoolean(); + info.Exclusive = bs.ReadBoolean(); + info.Retroactive = bs.ReadBoolean(); + info.Priority = dataIn.ReadByte(); + + 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.AdditionalPredicate = (BooleanExpression) TightUnmarshalNestedObject(wireFormat, dataIn, bs); + info.NetworkSubscription = bs.ReadBoolean(); + info.OptimizedAcknowledge = bs.ReadBoolean(); + info.NoRangeAcks = bs.ReadBoolean(); + + if (bs.ReadBoolean()) { + short size = dataIn.ReadInt16(); + ConsumerId[] value = new ConsumerId[size]; + for( int i=0; i < size; i++ ) { + value[i] = (ConsumerId) TightUnmarshalNestedObject(wireFormat,dataIn, bs); + } + info.NetworkConsumerPath = value; + } + else { + info.NetworkConsumerPath = null; + } + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + ConsumerInfo info = (ConsumerInfo)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConsumerId, bs); + bs.WriteBoolean(info.Browser); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs); + bs.WriteBoolean(info.DispatchAsync); + rc += TightMarshalString1(info.Selector, bs); + rc += TightMarshalString1(info.SubscriptionName, bs); + bs.WriteBoolean(info.NoLocal); + bs.WriteBoolean(info.Exclusive); + bs.WriteBoolean(info.Retroactive); + rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs); + rc += TightMarshalNestedObject1(wireFormat, (DataStructure)info.AdditionalPredicate, bs); + bs.WriteBoolean(info.NetworkSubscription); + bs.WriteBoolean(info.OptimizedAcknowledge); + bs.WriteBoolean(info.NoRangeAcks); + rc += TightMarshalObjectArray1(wireFormat, info.NetworkConsumerPath, 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); + + ConsumerInfo info = (ConsumerInfo)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConsumerId, dataOut, bs); + bs.ReadBoolean(); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + dataOut.Write(info.PrefetchSize); + dataOut.Write(info.MaximumPendingMessageLimit); + bs.ReadBoolean(); + TightMarshalString2(info.Selector, dataOut, bs); + TightMarshalString2(info.SubscriptionName, dataOut, bs); + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + dataOut.Write(info.Priority); + TightMarshalObjectArray2(wireFormat, info.BrokerPath, dataOut, bs); + TightMarshalNestedObject2(wireFormat, (DataStructure)info.AdditionalPredicate, dataOut, bs); + bs.ReadBoolean(); + bs.ReadBoolean(); + bs.ReadBoolean(); + TightMarshalObjectArray2(wireFormat, info.NetworkConsumerPath, 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); + + ConsumerInfo info = (ConsumerInfo)o; + info.ConsumerId = (ConsumerId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Browser = dataIn.ReadBoolean(); + info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.PrefetchSize = dataIn.ReadInt32(); + info.MaximumPendingMessageLimit = dataIn.ReadInt32(); + info.DispatchAsync = dataIn.ReadBoolean(); + info.Selector = LooseUnmarshalString(dataIn); + info.SubscriptionName = LooseUnmarshalString(dataIn); + info.NoLocal = dataIn.ReadBoolean(); + info.Exclusive = dataIn.ReadBoolean(); + info.Retroactive = dataIn.ReadBoolean(); + info.Priority = dataIn.ReadByte(); + + 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.AdditionalPredicate = (BooleanExpression) LooseUnmarshalNestedObject(wireFormat, dataIn); + info.NetworkSubscription = dataIn.ReadBoolean(); + info.OptimizedAcknowledge = dataIn.ReadBoolean(); + info.NoRangeAcks = dataIn.ReadBoolean(); + + if (dataIn.ReadBoolean()) { + short size = dataIn.ReadInt16(); + ConsumerId[] value = new ConsumerId[size]; + for( int i=0; i < size; i++ ) { + value[i] = (ConsumerId) LooseUnmarshalNestedObject(wireFormat,dataIn); + } + info.NetworkConsumerPath = value; + } + else { + info.NetworkConsumerPath = null; + } + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + ConsumerInfo info = (ConsumerInfo)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConsumerId, dataOut); + dataOut.Write(info.Browser); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut); + dataOut.Write(info.PrefetchSize); + dataOut.Write(info.MaximumPendingMessageLimit); + dataOut.Write(info.DispatchAsync); + LooseMarshalString(info.Selector, dataOut); + LooseMarshalString(info.SubscriptionName, dataOut); + dataOut.Write(info.NoLocal); + dataOut.Write(info.Exclusive); + dataOut.Write(info.Retroactive); + dataOut.Write(info.Priority); + LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut); + LooseMarshalNestedObject(wireFormat, (DataStructure)info.AdditionalPredicate, dataOut); + dataOut.Write(info.NetworkSubscription); + dataOut.Write(info.OptimizedAcknowledge); + dataOut.Write(info.NoRangeAcks); + LooseMarshalObjectArray(wireFormat, info.NetworkConsumerPath, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ConsumerInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ControlCommandMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ControlCommandMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ControlCommandMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/ControlCommandMarshaller.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 ControlCommand + * + * 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 ControlCommand + ///

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

+ class DataArrayResponseMarshaller : ResponseMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new DataArrayResponse(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return DataArrayResponse.ID_DATAARRAYRESPONSE; + } + + // + // 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); + + DataArrayResponse info = (DataArrayResponse)o; + + if (bs.ReadBoolean()) { + short size = dataIn.ReadInt16(); + DataStructure[] value = new DataStructure[size]; + for( int i=0; i < size; i++ ) { + value[i] = (DataStructure) TightUnmarshalNestedObject(wireFormat,dataIn, bs); + } + info.Data = value; + } + else { + info.Data = null; + } + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + DataArrayResponse info = (DataArrayResponse)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalObjectArray1(wireFormat, info.Data, 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); + + DataArrayResponse info = (DataArrayResponse)o; + TightMarshalObjectArray2(wireFormat, info.Data, 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); + + DataArrayResponse info = (DataArrayResponse)o; + + if (dataIn.ReadBoolean()) { + short size = dataIn.ReadInt16(); + DataStructure[] value = new DataStructure[size]; + for( int i=0; i < size; i++ ) { + value[i] = (DataStructure) LooseUnmarshalNestedObject(wireFormat,dataIn); + } + info.Data = value; + } + else { + info.Data = null; + } + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + DataArrayResponse info = (DataArrayResponse)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalObjectArray(wireFormat, info.Data, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DataArrayResponseMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DataResponseMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DataResponseMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DataResponseMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DataResponseMarshaller.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 DataResponse + * + * 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 DataResponse + ///

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

+ class DestinationInfoMarshaller : BaseCommandMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new DestinationInfo(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return DestinationInfo.ID_DESTINATIONINFO; + } + + // + // 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); + + DestinationInfo info = (DestinationInfo)o; + info.ConnectionId = (ConnectionId) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.Destination = (ActiveMQDestination) TightUnmarshalCachedObject(wireFormat, dataIn, bs); + info.OperationType = dataIn.ReadByte(); + info.Timeout = TightUnmarshalLong(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; + } + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + DestinationInfo info = (DestinationInfo)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.ConnectionId, bs); + rc += TightMarshalCachedObject1(wireFormat, (DataStructure)info.Destination, bs); + rc += TightMarshalLong1(wireFormat, info.Timeout, bs); + rc += TightMarshalObjectArray1(wireFormat, info.BrokerPath, bs); + + return rc + 1; + } + + // + // Write a object instance to data output stream + // + public override void TightMarshal2(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut, BooleanStream bs) + { + base.TightMarshal2(wireFormat, o, dataOut, bs); + + DestinationInfo info = (DestinationInfo)o; + TightMarshalCachedObject2(wireFormat, (DataStructure)info.ConnectionId, dataOut, bs); + TightMarshalCachedObject2(wireFormat, (DataStructure)info.Destination, dataOut, bs); + dataOut.Write(info.OperationType); + TightMarshalLong2(wireFormat, info.Timeout, dataOut, bs); + TightMarshalObjectArray2(wireFormat, info.BrokerPath, 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); + + DestinationInfo info = (DestinationInfo)o; + info.ConnectionId = (ConnectionId) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.Destination = (ActiveMQDestination) LooseUnmarshalCachedObject(wireFormat, dataIn); + info.OperationType = dataIn.ReadByte(); + info.Timeout = LooseUnmarshalLong(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; + } + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + DestinationInfo info = (DestinationInfo)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.ConnectionId, dataOut); + LooseMarshalCachedObject(wireFormat, (DataStructure)info.Destination, dataOut); + dataOut.Write(info.OperationType); + LooseMarshalLong(wireFormat, info.Timeout, dataOut); + LooseMarshalObjectArray(wireFormat, info.BrokerPath, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DestinationInfoMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native Added: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DiscoveryEventMarshaller.cs URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DiscoveryEventMarshaller.cs?rev=1133445&view=auto ============================================================================== --- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DiscoveryEventMarshaller.cs (added) +++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DiscoveryEventMarshaller.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 DiscoveryEvent + * + * 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 DiscoveryEvent + ///

+ class DiscoveryEventMarshaller : BaseDataStreamMarshaller + { + /// + /// Creates an instance of the Object that this marshaller handles. + /// + public override DataStructure CreateObject() + { + return new DiscoveryEvent(); + } + + /// + /// Returns the type code for the Object that this Marshaller handles.. + /// + public override byte GetDataStructureType() + { + return DiscoveryEvent.ID_DISCOVERYEVENT; + } + + // + // 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); + + DiscoveryEvent info = (DiscoveryEvent)o; + info.ServiceName = TightUnmarshalString(dataIn, bs); + info.BrokerName = TightUnmarshalString(dataIn, bs); + } + + // + // Write the booleans that this object uses to a BooleanStream + // + public override int TightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) + { + DiscoveryEvent info = (DiscoveryEvent)o; + + int rc = base.TightMarshal1(wireFormat, o, bs); + rc += TightMarshalString1(info.ServiceName, bs); + rc += TightMarshalString1(info.BrokerName, 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); + + DiscoveryEvent info = (DiscoveryEvent)o; + TightMarshalString2(info.ServiceName, dataOut, bs); + TightMarshalString2(info.BrokerName, 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); + + DiscoveryEvent info = (DiscoveryEvent)o; + info.ServiceName = LooseUnmarshalString(dataIn); + info.BrokerName = LooseUnmarshalString(dataIn); + } + + // + // Write a object instance to data output stream + // + public override void LooseMarshal(OpenWireFormat wireFormat, Object o, BinaryWriter dataOut) + { + + DiscoveryEvent info = (DiscoveryEvent)o; + + base.LooseMarshal(wireFormat, o, dataOut); + LooseMarshalString(info.ServiceName, dataOut); + LooseMarshalString(info.BrokerName, dataOut); + } + } +} Propchange: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/OpenWire/V8/DiscoveryEventMarshaller.cs ------------------------------------------------------------------------------ svn:eol-style = native