activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r799407 [4/29] - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp: ./ Commands/ OpenWire/ OpenWire/V1/ OpenWire/V2/ OpenWire/V3/ OpenWire/V4/ OpenWire/V5/ State/ Transport/
Date Thu, 30 Jul 2009 19:06:44 GMT
Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerAck.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerAck.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerAck.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerAck.cs Thu Jul 30 19:06:34 2009
@@ -1,79 +1,105 @@
-/*
- * 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.
- */
-
-using System;
-using Apache.NMS.ActiveMQ.State;
-
-namespace Apache.NMS.ActiveMQ.Commands
-{
-	/// <summary>
-	/// A ProducerAck command is sent by a broker to a producer to let it know it has
-	/// received and processed messages that it has produced. The producer will be
-	/// flow controlled if it does not receive ProducerAck commands back from the
-	/// broker.
-	/// </summary>
-	public class ProducerAck : BaseCommand
-	{
-		protected ProducerId myProducerId;
-		protected int mySize;
-
-		public ProducerAck()
-		{
-		}
-
-		public ProducerAck(ProducerId producerId, int size)
-		{
-			this.myProducerId = producerId;
-			this.mySize = size;
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processProducerAck(this);
-		}
-
-		/// <summary>
-		/// The producer id that this ack message is destined for.
-		/// </summary>
-		public ProducerId ProducerId
-		{
-			get
-			{
-				return myProducerId;
-			}
-			set
-			{
-				myProducerId = value;
-			}
-		}
-
-		/// <summary>
-		/// The number of bytes that are being acked.
-		/// </summary>
-		public int Size
-		{
-			get
-			{
-				return mySize;
-			}
-			set
-			{
-				mySize = value;
-			}
-		}
-	}
-}
+/*
+ * 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.
+ */
+
+using System;
+using System.Collections;
+
+using Apache.NMS.ActiveMQ.State;
+
+namespace Apache.NMS.ActiveMQ.Commands
+{
+    /*
+     *
+     *  Command code for OpenWire format for ProducerAck
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class ProducerAck : BaseCommand
+    {
+        public const byte ID_PRODUCERACK = 19;
+
+        ProducerId producerId;
+        int size;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_PRODUCERACK;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "ProducerId=" + ProducerId + 
+                "Size=" + Size + 
+                "]";
+        }
+
+        public ProducerId ProducerId
+        {
+            get { return producerId; }
+            set { this.producerId = value; }
+        }
+
+        public int Size
+        {
+            get { return size; }
+            set { this.size = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isProducerAck() query.
+        /// </summery>
+        ///
+        public override bool IsProducerAck
+        {
+            get
+            {
+                return true;
+            }
+        }
+
+        ///
+        /// <summery>
+        ///  Allows a Visitor to visit this command and return a response to the
+        ///  command based on the command type being visited.  The command will call
+        ///  the proper processXXX method in the visitor.
+        /// </summery>
+        ///
+        public override Response visit(ICommandVisitor visitor)
+        {
+            return visitor.processProducerAck( this );
+        }
+
+    };
+}
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerId.cs Thu Jul 30 19:06:34 2009
@@ -14,102 +14,134 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
-
 
+using System;
+using System.Collections;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ ProducerId Command
-	/// </summary>
-	public class ProducerId : BaseDataStructure, DataStructure
-	{
-		public const byte ID_ProducerId = 123;
-
-		string connectionId;
-		long value;
-		long sessionId;
-
-		private SessionId parentId;
-
-		public SessionId ParentId
-		{
-			get
-			{
-				if(parentId == null)
-				{
-					parentId = new SessionId(this);
-				}
-				return parentId;
-			}
-		}
-
-		public override int GetHashCode()
-		{
-			int answer = 0;
-			answer = (answer * 37) + HashCode(ConnectionId);
-			answer = (answer * 37) + HashCode(Value);
-			answer = (answer * 37) + HashCode(SessionId);
-			return answer;
-		}
-
-		public override bool Equals(object that)
-		{
-			if(that is ProducerId)
-			{
-				return Equals((ProducerId) that);
-			}
-			return false;
-		}
-
-		public virtual bool Equals(ProducerId that)
-		{
-			if(!Equals(this.ConnectionId, that.ConnectionId))
-				return false;
-			if(!Equals(this.Value, that.Value))
-				return false;
-			if(!Equals(this.SessionId, that.SessionId))
-				return false;
-			return true;
-		}
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ConnectionId=" + ConnectionId
-				+ " Value=" + Value
-				+ " SessionId=" + SessionId
-				+ " ]";
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ProducerId;
-		}
-
-		// Properties
-
-		public string ConnectionId
-		{
-			get { return connectionId; }
-			set { this.connectionId = value; }
-		}
-
-		public long Value
-		{
-			get { return value; }
-			set { this.value = value; }
-		}
-
-		public long SessionId
-		{
-			get { return sessionId; }
-			set { this.sessionId = value; }
-		}
-	}
+    /*
+     *
+     *  Command code for OpenWire format for ProducerId
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class ProducerId : BaseDataStructure
+    {
+        public const byte ID_PRODUCERID = 123;
+
+        private SessionId parentId;
+
+        string connectionId;
+        long value;
+        long sessionId;
+
+        public ProducerId()
+        {
+        }
+
+        public ProducerId( SessionId sessionId, long consumerId )
+        {
+            this.connectionId = sessionId.ConnectionId;
+            this.sessionId = sessionId.Value;
+            this.value = consumerId;
+        }
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_PRODUCERID;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "ConnectionId=" + ConnectionId + 
+                "Value=" + Value + 
+                "SessionId=" + SessionId + 
+                "]";
+        }
+
+        public SessionId ParentId
+        {
+            get
+            {
+                 if( this.parentId == null ) {
+                     this.parentId = new SessionId( this );
+                 }
+                 return this.parentId;
+            }
+        }
+
+        public string ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }
+        }
+
+        public long Value
+        {
+            get { return value; }
+            set { this.value = value; }
+        }
+
+        public long SessionId
+        {
+            get { return sessionId; }
+            set { this.sessionId = value; }
+        }
+
+        public override int GetHashCode()
+        {
+            int answer = 0;
+
+            answer = (answer * 37) + HashCode(ConnectionId);
+            answer = (answer * 37) + HashCode(Value);
+            answer = (answer * 37) + HashCode(SessionId);
+
+            return answer;
+        }
+
+        public override bool Equals(object that)
+        {
+            if(that is ProducerId)
+            {
+                return Equals((ProducerId) that);
+            }
+            return false;
+        }
+
+        public virtual bool Equals(ProducerId that)
+        {
+            if(!Equals(this.ConnectionId, that.ConnectionId))
+            {
+                return false;
+            }
+            if(!Equals(this.Value, that.Value))
+            {
+                return false;
+            }
+            if(!Equals(this.SessionId, that.SessionId))
+            {
+                return false;
+            }
+
+            return true;
+        }
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ProducerInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,75 +14,116 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
+using System;
+using System.Collections;
 
 using Apache.NMS.ActiveMQ.State;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ ProducerInfo Command
-	/// </summary>
-	public class ProducerInfo : BaseCommand
-	{
-		public const byte ID_ProducerInfo = 6;
-
-		ProducerId producerId;
-		ActiveMQDestination destination;
-		BrokerId[] brokerPath;
-		bool dispatchAsync;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ProducerId=" + ProducerId
-				+ " Destination=" + Destination
-				+ " BrokerPath=" + BrokerPath
-				+ " DispatchAsync=" + DispatchAsync
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ProducerInfo;
-		}
-
-
-		// Properties
-
-		public ProducerId ProducerId
-		{
-			get { return producerId; }
-			set { this.producerId = value; }
-		}
-
-		public ActiveMQDestination Destination
-		{
-			get { return destination; }
-			set { this.destination = value; }
-		}
-
-		public BrokerId[] BrokerPath
-		{
-			get { return brokerPath; }
-			set { this.brokerPath = value; }
-		}
-
-		public bool DispatchAsync
-		{
-			get { return dispatchAsync; }
-			set { this.dispatchAsync = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processAddProducer(this);
-		}
-	}
+    /*
+     *
+     *  Command code for OpenWire format for ProducerInfo
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class ProducerInfo : BaseCommand
+    {
+        public const byte ID_PRODUCERINFO = 6;
+
+        ProducerId producerId;
+        ActiveMQDestination destination;
+        BrokerId[] brokerPath;
+        bool dispatchAsync;
+        int windowSize;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_PRODUCERINFO;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "ProducerId=" + ProducerId + 
+                "Destination=" + Destination + 
+                "BrokerPath=" + BrokerPath + 
+                "DispatchAsync=" + DispatchAsync + 
+                "WindowSize=" + WindowSize + 
+                "]";
+        }
+
+        public ProducerId ProducerId
+        {
+            get { return producerId; }
+            set { this.producerId = value; }
+        }
+
+        public ActiveMQDestination Destination
+        {
+            get { return destination; }
+            set { this.destination = value; }
+        }
+
+        public BrokerId[] BrokerPath
+        {
+            get { return brokerPath; }
+            set { this.brokerPath = value; }
+        }
+
+        public bool DispatchAsync
+        {
+            get { return dispatchAsync; }
+            set { this.dispatchAsync = value; }
+        }
+
+        public int WindowSize
+        {
+            get { return windowSize; }
+            set { this.windowSize = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isProducerInfo() query.
+        /// </summery>
+        ///
+        public override bool IsProducerInfo
+        {
+            get
+            {
+                return true;
+            }
+        }
+
+        ///
+        /// <summery>
+        ///  Allows a Visitor to visit this command and return a response to the
+        ///  command based on the command type being visited.  The command will call
+        ///  the proper processXXX method in the visitor.
+        /// </summery>
+        ///
+        public override Response visit(ICommandVisitor visitor)
+        {
+            return visitor.processAddProducer( this );
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/RemoveInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/RemoveInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/RemoveInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/RemoveInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,63 +14,104 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
+using System;
+using System.Collections;
 
 using Apache.NMS.ActiveMQ.State;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ RemoveInfo Command
-	/// </summary>
-	public class RemoveInfo : BaseCommand
-	{
-		public const byte ID_RemoveInfo = 12;
-
-		DataStructure objectId;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ObjectId=" + ObjectId
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_RemoveInfo;
-		}
-
-
-		// Properties
-
-		public DataStructure ObjectId
-		{
-			get { return objectId; }
-			set { this.objectId = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			switch(objectId.GetDataStructureType())
-			{
-				case ConnectionId.ID_ConnectionId:
-					return visitor.processRemoveConnection((ConnectionId) objectId);
-				case SessionId.ID_SessionId:
-					return visitor.processRemoveSession((SessionId) objectId);
-				case ConsumerId.ID_ConsumerId:
-					return visitor.processRemoveConsumer((ConsumerId) objectId);
-				case ProducerId.ID_ProducerId:
-					return visitor.processRemoveProducer((ProducerId) objectId);
-				default:
-					throw new IOException("Unknown remove command type: " + objectId.GetDataStructureType());
-			}
-		}
-	}
+    /*
+     *
+     *  Command code for OpenWire format for RemoveInfo
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class RemoveInfo : BaseCommand
+    {
+        public const byte ID_REMOVEINFO = 12;
+
+        DataStructure objectId;
+        long lastDeliveredSequenceId;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_REMOVEINFO;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "ObjectId=" + ObjectId + 
+                "LastDeliveredSequenceId=" + LastDeliveredSequenceId + 
+                "]";
+        }
+
+        public DataStructure ObjectId
+        {
+            get { return objectId; }
+            set { this.objectId = value; }
+        }
+
+        public long LastDeliveredSequenceId
+        {
+            get { return lastDeliveredSequenceId; }
+            set { this.lastDeliveredSequenceId = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isRemoveInfo() query.
+        /// </summery>
+        ///
+        public override bool IsRemoveInfo
+        {
+            get
+            {
+                return true;
+            }
+        }
+
+        ///
+        /// <summery>
+        ///  Allows a Visitor to visit this command and return a response to the
+        ///  command based on the command type being visited.  The command will call
+        ///  the proper processXXX method in the visitor.
+        /// </summery>
+        ///
+        public override Response visit(ICommandVisitor visitor)
+        {
+            switch(objectId.GetDataStructureType())
+            {
+                case ConnectionId.ID_CONNECTIONID:
+                    return visitor.processRemoveConnection((ConnectionId) objectId);
+                case SessionId.ID_SESSIONID:
+                    return visitor.processRemoveSession((SessionId) objectId);
+                case ConsumerId.ID_CONSUMERID:
+                    return visitor.processRemoveConsumer((ConsumerId) objectId);
+                case ProducerId.ID_PRODUCERID:
+                    return visitor.processRemoveProducer((ProducerId) objectId);
+                default:
+                    throw new IOException("Unknown remove command type: " + objectId.GetDataStructureType());
+            }
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/RemoveSubscriptionInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/RemoveSubscriptionInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/RemoveSubscriptionInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/RemoveSubscriptionInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,67 +14,100 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
+using System;
+using System.Collections;
 
 using Apache.NMS.ActiveMQ.State;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ RemoveSubscriptionInfo Command
-	/// </summary>
-	public class RemoveSubscriptionInfo : BaseCommand
-	{
-		public const byte ID_RemoveSubscriptionInfo = 9;
-
-		ConnectionId connectionId;
-		string subcriptionName;
-		string clientId;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ConnectionId=" + ConnectionId
-				+ " SubcriptionName=" + SubcriptionName
-				+ " ClientId=" + ClientId
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_RemoveSubscriptionInfo;
-		}
-
-
-		// Properties
-
-		public ConnectionId ConnectionId
-		{
-			get { return connectionId; }
-			set { this.connectionId = value; }
-		}
-
-		public string SubcriptionName
-		{
-			get { return subcriptionName; }
-			set { this.subcriptionName = value; }
-		}
-
-		public string ClientId
-		{
-			get { return clientId; }
-			set { this.clientId = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processRemoveSubscription(this);
-		}
-	}
+    /*
+     *
+     *  Command code for OpenWire format for RemoveSubscriptionInfo
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class RemoveSubscriptionInfo : BaseCommand
+    {
+        public const byte ID_REMOVESUBSCRIPTIONINFO = 9;
+
+        ConnectionId connectionId;
+        string subcriptionName;
+        string clientId;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_REMOVESUBSCRIPTIONINFO;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "ConnectionId=" + ConnectionId + 
+                "SubcriptionName=" + SubcriptionName + 
+                "ClientId=" + ClientId + 
+                "]";
+        }
+
+        public ConnectionId ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }
+        }
+
+        public string SubcriptionName
+        {
+            get { return subcriptionName; }
+            set { this.subcriptionName = value; }
+        }
+
+        public string ClientId
+        {
+            get { return clientId; }
+            set { this.clientId = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isRemoveSubscriptionInfo() query.
+        /// </summery>
+        ///
+        public override bool IsRemoveSubscriptionInfo
+        {
+            get
+            {
+                return true;
+            }
+        }
+
+        ///
+        /// <summery>
+        ///  Allows a Visitor to visit this command and return a response to the
+        ///  command based on the command type being visited.  The command will call
+        ///  the proper processXXX method in the visitor.
+        /// </summery>
+        ///
+        public override Response visit(ICommandVisitor visitor)
+        {
+            return visitor.processRemoveSubscriptionInfo( this );
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ReplayCommand.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ReplayCommand.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ReplayCommand.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ReplayCommand.cs Thu Jul 30 19:06:34 2009
@@ -14,60 +14,92 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
+using System;
+using System.Collections;
 
 using Apache.NMS.ActiveMQ.State;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ ReplayCommand Command
-	/// </summary>
-	public class ReplayCommand : BaseCommand
-	{
-		public const byte ID_ReplayCommand = 65;
-
-		int firstNakNumber;
-		int lastNakNumber;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " FirstNakNumber=" + FirstNakNumber
-				+ " LastNakNumber=" + LastNakNumber
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ReplayCommand;
-		}
-
-
-		// Properties
-
-		public int FirstNakNumber
-		{
-			get { return firstNakNumber; }
-			set { this.firstNakNumber = value; }
-		}
-
-		public int LastNakNumber
-		{
-			get { return lastNakNumber; }
-			set { this.lastNakNumber = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return null;
-		}
+    /*
+     *
+     *  Command code for OpenWire format for ReplayCommand
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class ReplayCommand : BaseCommand
+    {
+        public const byte ID_REPLAYCOMMAND = 65;
+
+        int firstNakNumber;
+        int lastNakNumber;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_REPLAYCOMMAND;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "FirstNakNumber=" + FirstNakNumber + 
+                "LastNakNumber=" + LastNakNumber + 
+                "]";
+        }
+
+        public int FirstNakNumber
+        {
+            get { return firstNakNumber; }
+            set { this.firstNakNumber = value; }
+        }
+
+        public int LastNakNumber
+        {
+            get { return lastNakNumber; }
+            set { this.lastNakNumber = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isReplayCommand() query.
+        /// </summery>
+        ///
+        public override bool IsReplayCommand
+        {
+            get
+            {
+                return true;
+            }
+        }
+
+        ///
+        /// <summery>
+        ///  Allows a Visitor to visit this command and return a response to the
+        ///  command based on the command type being visited.  The command will call
+        ///  the proper processXXX method in the visitor.
+        /// </summery>
+        ///
+        public override Response visit(ICommandVisitor visitor)
+        {
+            return visitor.processReplayCommand( this );
+        }
 
-	}
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Response.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Response.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Response.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Response.cs Thu Jul 30 19:06:34 2009
@@ -14,60 +14,84 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
+using System;
+using System.Collections;
 
 using Apache.NMS.ActiveMQ.State;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ Response Command
-	/// </summary>
-	public class Response : BaseCommand
-	{
-		public const byte ID_Response = 30;
-
-		int correlationId;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " CorrelationId=" + CorrelationId
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_Response;
-		}
-
-
-		// Properties
-
-		public int CorrelationId
-		{
-			get { return correlationId; }
-			set { this.correlationId = value; }
-		}
-
-		public override bool IsResponse
-		{
-			get
-			{
-				return true;
-			}
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return null;
-		}
+    /*
+     *
+     *  Command code for OpenWire format for Response
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class Response : BaseCommand
+    {
+        public const byte ID_RESPONSE = 30;
+
+        int correlationId;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_RESPONSE;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "CorrelationId=" + CorrelationId + 
+                "]";
+        }
+
+        public int CorrelationId
+        {
+            get { return correlationId; }
+            set { this.correlationId = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isResponse() query.
+        /// </summery>
+        ///
+        public override bool IsResponse
+        {
+            get
+            {
+                return true;
+            }
+        }
+
+        ///
+        /// <summery>
+        ///  Allows a Visitor to visit this command and return a response to the
+        ///  command based on the command type being visited.  The command will call
+        ///  the proper processXXX method in the visitor.
+        /// </summery>
+        ///
+        public override Response visit(ICommandVisitor visitor)
+        {
+            return visitor.processResponse( this );
+        }
 
-	}
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SessionId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SessionId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SessionId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SessionId.cs Thu Jul 30 19:06:34 2009
@@ -14,119 +14,132 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
-
 
+using System;
+using System.Collections;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ SessionId Command
-	/// </summary>
-	public class SessionId : BaseDataStructure, DataStructure
-	{
-		public const byte ID_SessionId = 121;
-
-		string connectionId;
-		long value;
-		ConnectionId parentId;
-
-		public override int GetHashCode()
-		{
-			int answer = 0;
-			answer = (answer * 37) + HashCode(ConnectionId);
-			answer = (answer * 37) + HashCode(Value);
-			return answer;
-		}
-
-		public override bool Equals(object that)
-		{
-			if(that is SessionId)
-			{
-				return Equals((SessionId) that);
-			}
-			return false;
-		}
-
-		public virtual bool Equals(SessionId that)
-		{
-			if(!Equals(this.ConnectionId, that.ConnectionId))
-				return false;
-			if(!Equals(this.Value, that.Value))
-				return false;
-			return true;
-		}
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ConnectionId=" + ConnectionId
-				+ " Value=" + Value
-				+ " ]";
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_SessionId;
-		}
-
-		// Properties
-
-		public string ConnectionId
-		{
-			get { return connectionId; }
-			set { this.connectionId = value; }
-		}
-
-		public long Value
-		{
-			get { return value; }
-			set { this.value = value; }
-		}
-
-		public ConnectionId ParentId
-		{
-			get
-			{
-				if(parentId == null)
-				{
-					parentId = new ConnectionId(this);
-				}
-				return parentId;
-			}
-		}
-
-		public SessionId()
-			: base()
-		{
-		}
-
-		public SessionId(ConnectionId connectionId, long sessionId)
-		{
-			this.connectionId = connectionId.Value;
-			this.value = sessionId;
-		}
-
-		public SessionId(SessionId id)
-		{
-			this.connectionId = id.ConnectionId;
-			this.value = id.Value;
-		}
-
-		public SessionId(ProducerId id)
-		{
-			this.connectionId = id.ConnectionId;
-            this.value = id.SessionId;
-		}
-
-		public SessionId(ConsumerId id)
-		{
-			this.connectionId = id.ConnectionId;
-			this.value = id.SessionId;
-		}
-	}
+    /*
+     *
+     *  Command code for OpenWire format for SessionId
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class SessionId : BaseDataStructure
+    {
+        public const byte ID_SESSIONID = 121;
+
+        private ConnectionId parentId;
+
+        string connectionId;
+        long value;
+
+        public SessionId()
+        {
+        }
+
+        public SessionId( ConnectionId connectionId, long sessionId )
+        {
+            this.ConnectionId = connectionId.Value;
+            this.value = sessionId;
+        }
+
+        public SessionId( ProducerId producerId )
+        {
+            this.ConnectionId = producerId.ConnectionId;
+            this.value = producerId.SessionId;
+        }
+
+        public SessionId( ConsumerId consumerId )
+        {
+            this.ConnectionId = consumerId.ConnectionId;
+            this.value = consumerId.SessionId;
+        }
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_SESSIONID;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "ConnectionId=" + ConnectionId + 
+                "Value=" + Value + 
+                "]";
+        }
+
+        public ConnectionId ParentId
+        {
+            get
+            {
+                 if( this.parentId == null ) {
+                     this.parentId = new ConnectionId( this );
+                 }
+                 return this.parentId;
+            }
+        }
+
+        public string ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }
+        }
+
+        public long Value
+        {
+            get { return value; }
+            set { this.value = value; }
+        }
+
+        public override int GetHashCode()
+        {
+            int answer = 0;
+
+            answer = (answer * 37) + HashCode(ConnectionId);
+            answer = (answer * 37) + HashCode(Value);
+
+            return answer;
+        }
+
+        public override bool Equals(object that)
+        {
+            if(that is SessionId)
+            {
+                return Equals((SessionId) that);
+            }
+            return false;
+        }
+
+        public virtual bool Equals(SessionId that)
+        {
+            if(!Equals(this.ConnectionId, that.ConnectionId))
+            {
+                return false;
+            }
+            if(!Equals(this.Value, that.Value))
+            {
+                return false;
+            }
+
+            return true;
+        }
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SessionInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SessionInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SessionInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SessionInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,61 +14,93 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
+using System;
+using System.Collections;
 
 using Apache.NMS.ActiveMQ.State;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ SessionInfo Command
-	/// </summary>
-	public class SessionInfo : BaseCommand
-	{
-		public const byte ID_SessionInfo = 4;
-
-		SessionId sessionId;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " SessionId=" + SessionId
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_SessionInfo;
-		}
-
-
-		// Properties
-
-		public SessionId SessionId
-		{
-			get { return sessionId; }
-			set { this.sessionId = value; }
-		}
-
-		public SessionInfo(ConnectionInfo connectionInfo, long sessionId)
-		{
-			this.sessionId = new SessionId(connectionInfo.ConnectionId, sessionId);
-		}
-
-		public SessionInfo()
-			: base()
-		{
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processAddSession(this);
-		}
-	}
+    /*
+     *
+     *  Command code for OpenWire format for SessionInfo
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class SessionInfo : BaseCommand
+    {
+        public const byte ID_SESSIONINFO = 4;
+
+        SessionId sessionId;
+
+        public SessionInfo()
+        {
+        }
+
+        public SessionInfo(ConnectionInfo connectionInfo, long sessionId)
+        {
+            this.sessionId = new SessionId(connectionInfo.ConnectionId, sessionId);
+        }
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_SESSIONINFO;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "SessionId=" + SessionId + 
+                "]";
+        }
+
+        public SessionId SessionId
+        {
+            get { return sessionId; }
+            set { this.sessionId = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isSessionInfo() query.
+        /// </summery>
+        ///
+        public override bool IsSessionInfo
+        {
+            get
+            {
+                return true;
+            }
+        }
+
+        ///
+        /// <summery>
+        ///  Allows a Visitor to visit this command and return a response to the
+        ///  command based on the command type being visited.  The command will call
+        ///  the proper processXXX method in the visitor.
+        /// </summery>
+        ///
+        public override Response visit(ICommandVisitor visitor)
+        {
+            return visitor.processAddSession( this );
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ShutdownInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ShutdownInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ShutdownInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ShutdownInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,52 +14,75 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
+using System;
+using System.Collections;
 
 using Apache.NMS.ActiveMQ.State;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ ShutdownInfo Command
-	/// </summary>
-	public class ShutdownInfo : BaseCommand
-	{
-		public const byte ID_ShutdownInfo = 11;
-
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ShutdownInfo;
-		}
-
-
-		// Properties
-
-		public override bool IsShutdownInfo
-		{
-			get
-			{
-				return true;
-			}
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processShutdown(this);
-		}
+    /*
+     *
+     *  Command code for OpenWire format for ShutdownInfo
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class ShutdownInfo : BaseCommand
+    {
+        public const byte ID_SHUTDOWNINFO = 11;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_SHUTDOWNINFO;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "]";
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isShutdownInfo() query.
+        /// </summery>
+        ///
+        public override bool IsShutdownInfo
+        {
+            get
+            {
+                return true;
+            }
+        }
+
+        ///
+        /// <summery>
+        ///  Allows a Visitor to visit this command and return a response to the
+        ///  command based on the command type being visited.  The command will call
+        ///  the proper processXXX method in the visitor.
+        /// </summery>
+        ///
+        public override Response visit(ICommandVisitor visitor)
+        {
+            return visitor.processShutdownInfo( this );
+        }
 
-	}
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SubscriptionInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SubscriptionInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SubscriptionInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/SubscriptionInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,72 +14,89 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
 using System;
 using System.Collections;
 
-using Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
 namespace Apache.NMS.ActiveMQ.Commands
 {
-    /// <summary>
-    ///  The ActiveMQ SubscriptionInfo Command
-    /// </summary>
-    public class SubscriptionInfo : BaseDataStructure, DataStructure
+    /*
+     *
+     *  Command code for OpenWire format for SubscriptionInfo
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class SubscriptionInfo : BaseDataStructure
     {
-        public const byte ID_SubscriptionInfo = 55;
-    			
+        public const byte ID_SUBSCRIPTIONINFO = 55;
+
         string clientId;
         ActiveMQDestination destination;
         string selector;
         string subcriptionName;
+        ActiveMQDestination subscribedDestination;
 
-		public override string ToString() {
-            return GetType().Name + "["
-                + " ClientId=" + ClientId
-                + " Destination=" + Destination
-                + " Selector=" + Selector
-                + " SubcriptionName=" + SubcriptionName
-                + " ]";
-
-		}
-
-        public override byte GetDataStructureType() {
-            return ID_SubscriptionInfo;
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_SUBSCRIPTIONINFO;
         }
 
-
-        // Properties
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "ClientId=" + ClientId + 
+                "Destination=" + Destination + 
+                "Selector=" + Selector + 
+                "SubcriptionName=" + SubcriptionName + 
+                "SubscribedDestination=" + SubscribedDestination + 
+                "]";
+        }
 
         public string ClientId
         {
             get { return clientId; }
-            set { this.clientId = value; }            
+            set { this.clientId = value; }
         }
 
         public ActiveMQDestination Destination
         {
             get { return destination; }
-            set { this.destination = value; }            
+            set { this.destination = value; }
         }
 
         public string Selector
         {
             get { return selector; }
-            set { this.selector = value; }            
+            set { this.selector = value; }
         }
 
         public string SubcriptionName
         {
             get { return subcriptionName; }
-            set { this.subcriptionName = value; }            
+            set { this.subcriptionName = value; }
+        }
+
+        public ActiveMQDestination SubscribedDestination
+        {
+            get { return subscribedDestination; }
+            set { this.subscribedDestination = value; }
         }
 
-    }
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/TransactionId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/TransactionId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/TransactionId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/TransactionId.cs Thu Jul 30 19:06:34 2009
@@ -14,58 +14,70 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
 using System;
 using System.Collections;
 
-using Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
 namespace Apache.NMS.ActiveMQ.Commands
 {
-    /// <summary>
-    ///  The ActiveMQ TransactionId Command
-    /// </summary>
-    public class TransactionId : BaseDataStructure, DataStructure
+    /*
+     *
+     *  Command code for OpenWire format for TransactionId
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class TransactionId : BaseDataStructure
     {
-        public const byte ID_TransactionId = 0;
-    			
-
-		public override int GetHashCode() {
-            int answer = 0;
-            return answer;
+        public const byte ID_TRANSACTIONID = 0;
 
-		}
-
-		public override bool Equals(object that) {
-	    	if (that is TransactionId) {
-	    	    return Equals((TransactionId) that);
-			}
-			return false;
-    	}
-
-		public virtual bool Equals(TransactionId that) {
-            return true;
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_TRANSACTIONID;
+        }
 
-		}
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "]";
+        }
 
-		public override string ToString() {
-            return GetType().Name + "["
-                + " ]";
+        public override int GetHashCode()
+        {
+            int answer = 0;
 
-		}
 
-        public override byte GetDataStructureType() {
-            return ID_TransactionId;
+            return answer;
         }
 
+        public override bool Equals(object that)
+        {
+            if(that is TransactionId)
+            {
+                return Equals((TransactionId) that);
+            }
+            return false;
+        }
 
-        // Properties
+        public virtual bool Equals(TransactionId that)
+        {
 
-    }
+            return true;
+        }
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/TransactionInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/TransactionInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/TransactionInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/TransactionInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,94 +14,129 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
+using System;
+using System.Collections;
 
 using Apache.NMS.ActiveMQ.State;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ TransactionInfo Command
-	/// </summary>
-	public class TransactionInfo : BaseCommand
-	{
-		public const byte ID_TransactionInfo = 7;
-
-		ConnectionId connectionId;
-		TransactionId transactionId;
-		byte type;
-
-		public const byte BEGIN = 0;
-		public const byte PREPARE = 1;
-		public const byte COMMIT_ONE_PHASE = 2;
-		public const byte COMMIT_TWO_PHASE = 3;
-		public const byte ROLLBACK = 4;
-		public const byte RECOVER = 5;
-		public const byte FORGET = 6;
-		public const byte END = 7;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ConnectionId=" + ConnectionId
-				+ " TransactionId=" + TransactionId
-				+ " Type=" + Type
-				+ " ]";
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_TransactionInfo;
-		}
-
-		// Properties
-
-		public ConnectionId ConnectionId
-		{
-			get { return connectionId; }
-			set { this.connectionId = value; }
-		}
-
-		public TransactionId TransactionId
-		{
-			get { return transactionId; }
-			set { this.transactionId = value; }
-		}
-
-		public byte Type
-		{
-			get { return type; }
-			set { this.type = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			switch(type)
-			{
-				case TransactionInfo.BEGIN:
-					return visitor.processBeginTransaction(this);
-				case TransactionInfo.END:
-					return visitor.processEndTransaction(this);
-				case TransactionInfo.PREPARE:
-					return visitor.processPrepareTransaction(this);
-				case TransactionInfo.COMMIT_ONE_PHASE:
-					return visitor.processCommitTransactionOnePhase(this);
-				case TransactionInfo.COMMIT_TWO_PHASE:
-					return visitor.processCommitTransactionTwoPhase(this);
-				case TransactionInfo.ROLLBACK:
-					return visitor.processRollbackTransaction(this);
-				case TransactionInfo.RECOVER:
-					return visitor.processRecoverTransactions(this);
-				case TransactionInfo.FORGET:
-					return visitor.processForgetTransaction(this);
-				default:
-					throw new IOException("Transaction info type unknown: " + type);
-			}
-		}
-	}
+    /*
+     *
+     *  Command code for OpenWire format for TransactionInfo
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class TransactionInfo : BaseCommand
+    {
+        public const byte ID_TRANSACTIONINFO = 7;
+
+        public const byte BEGIN = 0;
+        public const byte PREPARE = 1;
+        public const byte COMMIT_ONE_PHASE = 2;
+        public const byte COMMIT_TWO_PHASE = 3;
+        public const byte ROLLBACK = 4;
+        public const byte RECOVER = 5;
+        public const byte FORGET = 6;
+        public const byte END = 7;
+
+        ConnectionId connectionId;
+        TransactionId transactionId;
+        byte type;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_TRANSACTIONINFO;
+        }
+
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "ConnectionId=" + ConnectionId + 
+                "TransactionId=" + TransactionId + 
+                "Type=" + Type + 
+                "]";
+        }
+
+        public ConnectionId ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }
+        }
+
+        public TransactionId TransactionId
+        {
+            get { return transactionId; }
+            set { this.transactionId = value; }
+        }
+
+        public byte Type
+        {
+            get { return type; }
+            set { this.type = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isTransactionInfo() query.
+        /// </summery>
+        ///
+        public override bool IsTransactionInfo
+        {
+            get
+            {
+                return true;
+            }
+        }
+
+        ///
+        /// <summery>
+        ///  Allows a Visitor to visit this command and return a response to the
+        ///  command based on the command type being visited.  The command will call
+        ///  the proper processXXX method in the visitor.
+        /// </summery>
+        ///
+        public override Response visit(ICommandVisitor visitor)
+        {
+            switch(type)
+            {
+                case TransactionInfo.BEGIN:
+                    return visitor.processBeginTransaction(this);
+                case TransactionInfo.END:
+                    return visitor.processEndTransaction(this);
+                case TransactionInfo.PREPARE:
+                    return visitor.processPrepareTransaction(this);
+                case TransactionInfo.COMMIT_ONE_PHASE:
+                    return visitor.processCommitTransactionOnePhase(this);
+                case TransactionInfo.COMMIT_TWO_PHASE:
+                    return visitor.processCommitTransactionTwoPhase(this);
+                case TransactionInfo.ROLLBACK:
+                    return visitor.processRollbackTransaction(this);
+                case TransactionInfo.RECOVER:
+                    return visitor.processRecoverTransactions(this);
+                case TransactionInfo.FORGET:
+                    return visitor.processForgetTransaction(this);
+                default:
+                    throw new IOException("Transaction info type unknown: " + type);
+            }
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/WireFormatInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/WireFormatInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/WireFormatInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/WireFormatInfo.cs Thu Jul 30 19:06:34 2009
@@ -20,181 +20,194 @@
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	//
-	//  Marshalling code for Open Wire Format for WireFormatInfo
-	//
-	//
-	public class WireFormatInfo : BaseCommand, Command, MarshallAware
-	{
-		public const byte ID_WireFormatInfo = 1;
-		static private byte[] MAGIC = new byte[] {
-						'A'&0xFF,
-						'c'&0xFF,
-						't'&0xFF,
-						'i'&0xFF,
-						'v'&0xFF,
-						'e'&0xFF,
-						'M'&0xFF,
-						'Q'&0xFF };
-
-		byte[] magic = MAGIC;
-		int version;
-		byte[] marshalledProperties;
-
-		private PrimitiveMap properties;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-					+ " Magic=" + Magic
-					+ " Version=" + Version
-					+ " MarshalledProperties=" + Properties.ToString()
-					+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_WireFormatInfo;
-		}
-
-
-		// Properties
-		public byte[] Magic
-		{
-			get { return magic; }
-			set { this.magic = value; }
-		}
-
-		public bool Valid
-		{
-			get
-			{
-				if(null == magic)
-				{
-					return false;
-				}
-
-				if(magic.Length != MAGIC.Length)
-				{
-					return false;
-				}
-
-				for(int i = 0; i < magic.Length; i++)
-				{
-					if(magic[i] != MAGIC[i])
-					{
-						return false;
-					}
-				}
-
-				return true;
-			}
-		}
-
-		public int Version
-		{
-			get { return version; }
-			set { this.version = value; }
-		}
-
-		public byte[] MarshalledProperties
-		{
-			get { return marshalledProperties; }
-			set { this.marshalledProperties = value; }
-		}
-
-		public IPrimitiveMap Properties
-		{
-			get
-			{
-				if(null == properties)
-				{
-					properties = PrimitiveMap.Unmarshal(MarshalledProperties);
-				}
-
-				return properties;
-			}
-		}
-
-		public bool CacheEnabled
-		{
-			get { return true.Equals(Properties["CacheEnabled"]); }
-			set { Properties["CacheEnabled"] = value; }
-		}
-		public bool StackTraceEnabled
-		{
-			get { return true.Equals(Properties["StackTraceEnabled"]); }
-			set { Properties["StackTraceEnabled"] = value; }
-		}
-		public bool TcpNoDelayEnabled
-		{
-			get { return true.Equals(Properties["TcpNoDelayEnabled"]); }
-			set { Properties["TcpNoDelayEnabled"] = value; }
-		}
-		public bool SizePrefixDisabled
-		{
-			get { return true.Equals(Properties["SizePrefixDisabled"]); }
-			set { Properties["SizePrefixDisabled"] = value; }
-		}
-		public bool TightEncodingEnabled
-		{
-			get { return true.Equals(Properties["TightEncodingEnabled"]); }
-			set { Properties["TightEncodingEnabled"] = value; }
-		}
-		public long MaxInactivityDuration
-		{
-			get
-			{
-				object prop = Properties["MaxInactivityDuration"];
-				return (null != prop
-										? (long) prop
-										: 0);
-			}
-			set { Properties["MaxInactivityDuration"] = value; }
-		}
-		public long MaxInactivityDurationInitialDelay
-		{
-			get
-			{
-				object prop = Properties["MaxInactivityDurationInitialDelay"];
-				return (null != prop
-										? (long) prop
-										: 0);
-			}
-			set { Properties["MaxInactivityDurationInitialDelay"] = value; }
-		}
-		public int CacheSize
-		{
-			get
-			{
-				object prop = Properties["CacheSize"];
-				return (null != prop
-										? (int) prop
-										: 0);
-			}
-			set { Properties.SetInt("CacheSize", value); }
-		}
-
-		// MarshallAware interface
-		public override bool IsMarshallAware()
-		{
-			return true;
-		}
-
-		public override void BeforeMarshall(OpenWireFormat wireFormat)
-		{
-			MarshalledProperties = null;
-
-			if(properties != null)
-			{
-				MarshalledProperties = properties.Marshal();
-			}
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processWireFormat(this);
-		}
-	}
+    //
+    //  Marshalling code for Open Wire Format for WireFormatInfo
+    //
+    //
+    public class WireFormatInfo : BaseCommand, Command, MarshallAware
+    {
+        public const byte ID_WIREFORMATINFO = 1;
+        static private byte[] MAGIC = new byte[] {
+                        'A'&0xFF,
+                        'c'&0xFF,
+                        't'&0xFF,
+                        'i'&0xFF,
+                        'v'&0xFF,
+                        'e'&0xFF,
+                        'M'&0xFF,
+                        'Q'&0xFF };
+
+        byte[] magic = MAGIC;
+        int version;
+        byte[] marshalledProperties;
+
+        private PrimitiveMap properties;
+
+        public override string ToString()
+        {
+            return GetType().Name + "["
+                    + " Magic=" + Magic
+                    + " Version=" + Version
+                    + " MarshalledProperties=" + Properties.ToString()
+                    + " ]";
+
+        }
+
+        public override byte GetDataStructureType()
+        {
+            return ID_WIREFORMATINFO;
+        }
+
+
+        // Properties
+        public byte[] Magic
+        {
+            get { return magic; }
+            set { this.magic = value; }
+        }
+
+        public bool Valid
+        {
+            get
+            {
+                if(null == magic)
+                {
+                    return false;
+                }
+
+                if(magic.Length != MAGIC.Length)
+                {
+                    return false;
+                }
+
+                for(int i = 0; i < magic.Length; i++)
+                {
+                    if(magic[i] != MAGIC[i])
+                    {
+                        return false;
+                    }
+                }
+
+                return true;
+            }
+        }
+
+        public int Version
+        {
+            get { return version; }
+            set { this.version = value; }
+        }
+
+        public byte[] MarshalledProperties
+        {
+            get { return marshalledProperties; }
+            set { this.marshalledProperties = value; }
+        }
+
+        public IPrimitiveMap Properties
+        {
+            get
+            {
+                if(null == properties)
+                {
+                    properties = PrimitiveMap.Unmarshal(MarshalledProperties);
+                }
+
+                return properties;
+            }
+        }
+
+        public bool CacheEnabled
+        {
+            get { return true.Equals(Properties["CacheEnabled"]); }
+            set { Properties["CacheEnabled"] = value; }
+        }
+        public bool StackTraceEnabled
+        {
+            get { return true.Equals(Properties["StackTraceEnabled"]); }
+            set { Properties["StackTraceEnabled"] = value; }
+        }
+        public bool TcpNoDelayEnabled
+        {
+            get { return true.Equals(Properties["TcpNoDelayEnabled"]); }
+            set { Properties["TcpNoDelayEnabled"] = value; }
+        }
+        public bool SizePrefixDisabled
+        {
+            get { return true.Equals(Properties["SizePrefixDisabled"]); }
+            set { Properties["SizePrefixDisabled"] = value; }
+        }
+        public bool TightEncodingEnabled
+        {
+            get { return true.Equals(Properties["TightEncodingEnabled"]); }
+            set { Properties["TightEncodingEnabled"] = value; }
+        }
+        public long MaxInactivityDuration
+        {
+            get
+            {
+                object prop = Properties["MaxInactivityDuration"];
+                return (null != prop
+                                        ? (long) prop
+                                        : 0);
+            }
+            set { Properties["MaxInactivityDuration"] = value; }
+        }
+        public long MaxInactivityDurationInitialDelay
+        {
+            get
+            {
+                object prop = Properties["MaxInactivityDurationInitialDelay"];
+                return (null != prop
+                                        ? (long) prop
+                                        : 0);
+            }
+            set { Properties["MaxInactivityDurationInitialDelay"] = value; }
+        }
+        public int CacheSize
+        {
+            get
+            {
+                object prop = Properties["CacheSize"];
+                return (null != prop
+                                        ? (int) prop
+                                        : 0);
+            }
+            set { Properties.SetInt("CacheSize", value); }
+        }
+
+        // MarshallAware interface
+        public override bool IsMarshallAware()
+        {
+            return true;
+        }
+
+        public override void BeforeMarshall(OpenWireFormat wireFormat)
+        {
+            MarshalledProperties = null;
+
+            if(properties != null)
+            {
+                MarshalledProperties = properties.Marshal();
+            }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the IsWireFormatInfo() query.
+        /// </summery>
+        ///
+        public override bool IsWireFormatInfo
+        {
+            get
+            {
+                return true;
+            }
+        }
+
+        public override Response visit(ICommandVisitor visitor)
+        {
+            return visitor.processWireFormat(this);
+        }
+    }
 }

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/XATransactionId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/XATransactionId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/XATransactionId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/XATransactionId.cs Thu Jul 30 19:06:34 2009
@@ -14,88 +14,110 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-//
-//  NOTE!: This file is autogenerated - do not modify!
-//         if you need to make a change, please see the Groovy scripts in the
-//         activemq-core module
-//
 
 using System;
 using System.Collections;
 
-using Apache.NMS.ActiveMQ.OpenWire;
-using Apache.NMS.ActiveMQ.Commands;
-
 namespace Apache.NMS.ActiveMQ.Commands
 {
-    /// <summary>
-    ///  The ActiveMQ XATransactionId Command
-    /// </summary>
-    public class XATransactionId : TransactionId, Xid
+    /*
+     *
+     *  Command code for OpenWire format for XATransactionId
+     *
+     *  NOTE!: This file is auto generated - do not modify!
+     *         if you need to make a change, please see the Java Classes
+     *         in the nms-activemq-openwire-generator module
+     *
+     */
+    public class XATransactionId : TransactionId
     {
-        public const byte ID_XATransactionId = 112;
-    			
+        public const byte ID_XATRANSACTIONID = 112;
+
         int formatId;
         byte[] globalTransactionId;
         byte[] branchQualifier;
 
-		public override int GetHashCode() {
-            int answer = 0;
-            answer = (answer * 37) + HashCode(FormatId);
-            answer = (answer * 37) + HashCode(GlobalTransactionId);
-            answer = (answer * 37) + HashCode(BranchQualifier);
-            return answer;
-
-		}
-
-		public override bool Equals(object that) {
-	    	if (that is XATransactionId) {
-	    	    return Equals((XATransactionId) that);
-			}
-			return false;
-    	}
-
-		public virtual bool Equals(XATransactionId that) {
-            if (! Equals(this.FormatId, that.FormatId)) return false;
-            if (! Equals(this.GlobalTransactionId, that.GlobalTransactionId)) return false;
-            if (! Equals(this.BranchQualifier, that.BranchQualifier)) return false;
-            return true;
-
-		}
-
-		public override string ToString() {
-            return GetType().Name + "["
-                + " FormatId=" + FormatId
-                + " GlobalTransactionId=" + GlobalTransactionId
-                + " BranchQualifier=" + BranchQualifier
-                + " ]";
-
-		}
-
-        public override byte GetDataStructureType() {
-            return ID_XATransactionId;
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_XATRANSACTIONID;
         }
 
-
-        // Properties
+        ///
+        /// <summery>
+        ///  Returns a string containing the information for this DataStructure
+        ///  such as its type and value of its elements.
+        /// </summery>
+        ///
+        public override string ToString()
+        {
+            return GetType().Name + "[" + 
+                "FormatId=" + FormatId + 
+                "GlobalTransactionId=" + GlobalTransactionId + 
+                "BranchQualifier=" + BranchQualifier + 
+                "]";
+        }
 
         public int FormatId
         {
             get { return formatId; }
-            set { this.formatId = value; }            
+            set { this.formatId = value; }
         }
 
         public byte[] GlobalTransactionId
         {
             get { return globalTransactionId; }
-            set { this.globalTransactionId = value; }            
+            set { this.globalTransactionId = value; }
         }
 
         public byte[] BranchQualifier
         {
             get { return branchQualifier; }
-            set { this.branchQualifier = value; }            
+            set { this.branchQualifier = value; }
         }
 
-    }
+        public override int GetHashCode()
+        {
+            int answer = 0;
+
+            answer = (answer * 37) + HashCode(FormatId);
+            answer = (answer * 37) + HashCode(GlobalTransactionId);
+            answer = (answer * 37) + HashCode(BranchQualifier);
+
+            return answer;
+        }
+
+        public override bool Equals(object that)
+        {
+            if(that is XATransactionId)
+            {
+                return Equals((XATransactionId) that);
+            }
+            return false;
+        }
+
+        public virtual bool Equals(XATransactionId that)
+        {
+            if(!Equals(this.FormatId, that.FormatId))
+            {
+                return false;
+            }
+            if(!Equals(this.GlobalTransactionId, that.GlobalTransactionId))
+            {
+                return false;
+            }
+            if(!Equals(this.BranchQualifier, that.BranchQualifier))
+            {
+                return false;
+            }
+
+            return true;
+        }
+    };
 }
+



Mime
View raw message