activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r799407 [2/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/BaseCommand.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BaseCommand.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BaseCommand.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BaseCommand.cs Thu Jul 30 19:06:34 2009
@@ -30,168 +30,337 @@
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	public abstract class BaseCommand : BaseDataStructure, Command, ICloneable
-	{
-		private int commandId;
-		private bool responseRequired;
-
-		public int CommandId
-		{
-			get { return commandId; }
-			set { this.commandId = value; }
-		}
-
-		public override int GetHashCode()
-		{
-			return (CommandId * 37) + GetDataStructureType();
-		}
-
-		public override bool Equals(Object that)
-		{
-			if(that is BaseCommand)
-			{
-				BaseCommand thatCommand = (BaseCommand) that;
-				return this.GetDataStructureType() == thatCommand.GetDataStructureType()
-					&& this.CommandId == thatCommand.CommandId;
-			}
-			return false;
-		}
-
-		public override String ToString()
-		{
-			string answer = GetDataStructureTypeAsString(GetDataStructureType());
-			if(answer.Length == 0)
-			{
-				answer = base.ToString();
-			}
-			return answer + ": id = " + CommandId;
-		}
-
-		public static String GetDataStructureTypeAsString(int type)
-		{
-			String packetTypeStr = "";
-			switch(type)
-			{
-				case ActiveMQMessage.ID_ActiveMQMessage:
-					packetTypeStr = "ACTIVEMQ_MESSAGE";
-					break;
-				case ActiveMQTextMessage.ID_ActiveMQTextMessage:
-					packetTypeStr = "ACTIVEMQ_TEXT_MESSAGE";
-					break;
-				case ActiveMQObjectMessage.ID_ActiveMQObjectMessage:
-					packetTypeStr = "ACTIVEMQ_OBJECT_MESSAGE";
-					break;
-				case ActiveMQBytesMessage.ID_ActiveMQBytesMessage:
-					packetTypeStr = "ACTIVEMQ_BYTES_MESSAGE";
-					break;
-				case ActiveMQStreamMessage.ID_ActiveMQStreamMessage:
-					packetTypeStr = "ACTIVEMQ_STREAM_MESSAGE";
-					break;
-				case ActiveMQMapMessage.ID_ActiveMQMapMessage:
-					packetTypeStr = "ACTIVEMQ_MAP_MESSAGE";
-					break;
-				case MessageAck.ID_MessageAck:
-					packetTypeStr = "ACTIVEMQ_MSG_ACK";
-					break;
-				case Response.ID_Response:
-					packetTypeStr = "RESPONSE";
-					break;
-				case ConsumerInfo.ID_ConsumerInfo:
-					packetTypeStr = "CONSUMER_INFO";
-					break;
-				case ProducerInfo.ID_ProducerInfo:
-					packetTypeStr = "PRODUCER_INFO";
-					break;
-				case TransactionInfo.ID_TransactionInfo:
-					packetTypeStr = "TRANSACTION_INFO";
-					break;
-				case BrokerInfo.ID_BrokerInfo:
-					packetTypeStr = "BROKER_INFO";
-					break;
-				case ConnectionInfo.ID_ConnectionInfo:
-					packetTypeStr = "CONNECTION_INFO";
-					break;
-				case SessionInfo.ID_SessionInfo:
-					packetTypeStr = "SESSION_INFO";
-					break;
-				case RemoveSubscriptionInfo.ID_RemoveSubscriptionInfo:
-					packetTypeStr = "DURABLE_UNSUBSCRIBE";
-					break;
-				case IntegerResponse.ID_IntegerResponse:
-					packetTypeStr = "INT_RESPONSE_RECEIPT_INFO";
-					break;
-				case WireFormatInfo.ID_WireFormatInfo:
-					packetTypeStr = "WIRE_FORMAT_INFO";
-					break;
-				case RemoveInfo.ID_RemoveInfo:
-					packetTypeStr = "REMOVE_INFO";
-					break;
-				case KeepAliveInfo.ID_KeepAliveInfo:
-					packetTypeStr = "KEEP_ALIVE";
-					break;
-			}
-			return packetTypeStr;
-		}
-
-		public virtual Response visit(ICommandVisitor visitor)
-		{
-			throw new ApplicationException("BaseCommand.Visit() not implemented");
-		}
-
-		public virtual bool IsMessage
-		{
-			get
-			{
-				return false;
-			}
-		}
-
-		public virtual bool IsShutdownInfo
-		{
-			get
-			{
-				return false;
-			}
-		}
-
-		public virtual bool IsBrokerInfo
-		{
-			get
-			{
-				return false;
-			}
-		}
-
-		public virtual bool IsResponse
-		{
-			get
-			{
-				return false;
-			}
-		}
-
-		public virtual bool ResponseRequired
-		{
-			get
-			{
-				return responseRequired;
-			}
-			set
-			{
-				responseRequired = value;
-			}
-		}
-
-		public override Object Clone()
-		{
-			// Since we are a derived class use the base's Clone()
-			// to perform the shallow copy. Since it is shallow it
-			// will include our derived class. Since we are derived,
-			// this method is an override.
-			BaseCommand o = (BaseCommand) base.Clone();
-
-			return o;
-		}
-	}
+    public abstract class BaseCommand : BaseDataStructure, Command, ICloneable
+    {
+        private int commandId;
+        private bool responseRequired;
+
+        public int CommandId
+        {
+            get { return commandId; }
+            set { this.commandId = value; }
+        }
+
+        public override int GetHashCode()
+        {
+            return (CommandId * 37) + GetDataStructureType();
+        }
+
+        public override bool Equals(Object that)
+        {
+            if(that is BaseCommand)
+            {
+                BaseCommand thatCommand = (BaseCommand) that;
+                return this.GetDataStructureType() == thatCommand.GetDataStructureType()
+                    && this.CommandId == thatCommand.CommandId;
+            }
+            return false;
+        }
+
+        public override String ToString()
+        {
+            string answer = GetDataStructureTypeAsString(GetDataStructureType());
+            if(answer.Length == 0)
+            {
+                answer = base.ToString();
+            }
+            return answer + ": id = " + CommandId;
+        }
+
+        public static String GetDataStructureTypeAsString(int type)
+        {
+            String packetTypeStr = "";
+            switch(type)
+            {
+                case ActiveMQMessage.ID_ACTIVEMQMESSAGE:
+                    packetTypeStr = "ACTIVEMQ_MESSAGE";
+                    break;
+                case ActiveMQTextMessage.ID_ACTIVEMQTEXTMESSAGE:
+                    packetTypeStr = "ACTIVEMQ_TEXT_MESSAGE";
+                    break;
+                case ActiveMQObjectMessage.ID_ACTIVEMQOBJECTMESSAGE:
+                    packetTypeStr = "ACTIVEMQ_OBJECT_MESSAGE";
+                    break;
+                case ActiveMQBytesMessage.ID_ACTIVEMQBYTESMESSAGE:
+                    packetTypeStr = "ACTIVEMQ_BYTES_MESSAGE";
+                    break;
+                case ActiveMQStreamMessage.ID_ACTIVEMQSTREAMMESSAGE:
+                    packetTypeStr = "ACTIVEMQ_STREAM_MESSAGE";
+                    break;
+                case ActiveMQMapMessage.ID_ACTIVEMQMAPMESSAGE:
+                    packetTypeStr = "ACTIVEMQ_MAP_MESSAGE";
+                    break;
+                case MessageAck.ID_MESSAGEACK:
+                    packetTypeStr = "ACTIVEMQ_MSG_ACK";
+                    break;
+                case Response.ID_RESPONSE:
+                    packetTypeStr = "RESPONSE";
+                    break;
+                case ConsumerInfo.ID_CONSUMERINFO:
+                    packetTypeStr = "CONSUMER_INFO";
+                    break;
+                case ProducerInfo.ID_PRODUCERINFO:
+                    packetTypeStr = "PRODUCER_INFO";
+                    break;
+                case TransactionInfo.ID_TRANSACTIONINFO:
+                    packetTypeStr = "TRANSACTION_INFO";
+                    break;
+                case BrokerInfo.ID_BROKERINFO:
+                    packetTypeStr = "BROKER_INFO";
+                    break;
+                case ConnectionInfo.ID_CONNECTIONINFO:
+                    packetTypeStr = "CONNECTION_INFO";
+                    break;
+                case SessionInfo.ID_SESSIONINFO:
+                    packetTypeStr = "SESSION_INFO";
+                    break;
+                case RemoveSubscriptionInfo.ID_REMOVESUBSCRIPTIONINFO:
+                    packetTypeStr = "DURABLE_UNSUBSCRIBE";
+                    break;
+                case IntegerResponse.ID_INTEGERRESPONSE:
+                    packetTypeStr = "INT_RESPONSE_RECEIPT_INFO";
+                    break;
+                case WireFormatInfo.ID_WIREFORMATINFO:
+                    packetTypeStr = "WIRE_FORMAT_INFO";
+                    break;
+                case RemoveInfo.ID_REMOVEINFO:
+                    packetTypeStr = "REMOVE_INFO";
+                    break;
+                case KeepAliveInfo.ID_KEEPALIVEINFO:
+                    packetTypeStr = "KEEP_ALIVE";
+                    break;
+            }
+            return packetTypeStr;
+        }
+
+        public virtual Response visit(ICommandVisitor visitor)
+        {
+            throw new ApplicationException("BaseCommand.Visit() not implemented");
+        }
+
+
+        public virtual bool IsBrokerInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsConnectionControl
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsConnectionInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsConnectionError
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsConsumerControl
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsConsumerInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsControlCommand
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsDestinationInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsFlushCommand
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsKeepAliveInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsMessage
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsMessageAck
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsMessageDispatch
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsMessageDispatchNotification
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsMessagePull
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsProducerAck
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsProducerInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsRemoveInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsRemoveSubscriptionInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsReplayCommand
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsResponse
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsSessionInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsShutdownInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsTransactionInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool IsWireFormatInfo
+        {
+            get
+            {
+                return false;
+            }
+        }
+
+        public virtual bool ResponseRequired
+        {
+            get
+            {
+                return responseRequired;
+            }
+            set
+            {
+                responseRequired = value;
+            }
+        }
+
+        public override Object Clone()
+        {
+            // Since we are a derived class use the base's Clone()
+            // to perform the shallow copy. Since it is shallow it
+            // will include our derived class. Since we are derived,
+            // this method is an override.
+            BaseCommand o = (BaseCommand) base.Clone();
+
+            return o;
+        }
+    }
 }
 

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerId.cs Thu Jul 30 19:06:34 2009
@@ -14,86 +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;
 
 namespace Apache.NMS.ActiveMQ.Commands
 {
-	/// <summary>
-	///  The ActiveMQ BrokerId Command
-	/// </summary>
-	public class BrokerId : BaseDataStructure, DataStructure
-	{
-		public const byte ID_BrokerId = 124;
-
-		string value;
-
-		public override int GetHashCode()
-		{
-			int answer = 0;
-			answer = (answer * 37) + HashCode(Value);
-			return answer;
-
-		}
-
-		public override bool Equals(object that)
-		{
-			if(that is BrokerId)
-			{
-				return Equals((BrokerId) that);
-			}
-			return false;
-		}
-
-		public virtual bool Equals(BrokerId that)
-		{
-			if(!Equals(this.Value, that.Value))
-				return false;
-			return true;
-
-		}
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " Value=" + Value
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_BrokerId;
-		}
-
-
-		// Properties
-
-		public string Value
-		{
-			get { return value; }
-			set { this.value = value; }
-		}
-
-		public override Object Clone()
-		{
-			// Since we are a derived class use the base's Clone()
-			// to perform the shallow copy. Since it is shallow it
-			// will include our derived class. Since we are derived,
-			// this method is an override.
-			BrokerId o = (BrokerId) base.Clone();
-
-			// Now do the deep work required
-			// If any new variables are added then this routine will
-			// likely need updating
-
-			return o;
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class BrokerId : BaseDataStructure
+    {
+        public const byte ID_BROKERID = 124;
+
+        string value;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_BROKERID;
+        }
+
+        ///
+        /// <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 + "[" + 
+                "Value=" + Value + 
+                "]";
+        }
+
+        public string Value
+        {
+            get { return value; }
+            set { this.value = value; }
+        }
+
+        public override int GetHashCode()
+        {
+            int answer = 0;
+
+            answer = (answer * 37) + HashCode(Value);
+
+            return answer;
+        }
+
+        public override bool Equals(object that)
+        {
+            if(that is BrokerId)
+            {
+                return Equals((BrokerId) that);
+            }
+            return false;
+        }
+
+        public virtual bool Equals(BrokerId that)
+        {
+            if(!Equals(this.Value, that.Value))
+            {
+                return false;
+            }
+
+            return true;
+        }
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/BrokerInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,131 +14,172 @@
  * 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 BrokerInfo Command
-	/// </summary>
-	public class BrokerInfo : BaseCommand
-	{
-		public const byte ID_BrokerInfo = 2;
-
-		BrokerId brokerId;
-		string brokerURL;
-		BrokerInfo[] peerBrokerInfos;
-		string brokerName;
-		bool slaveBroker;
-		bool masterBroker;
-		bool faultTolerantConfiguration;
-		bool duplexConnection;
-		bool networkConnection;
-		long connectionId;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " BrokerId=" + BrokerId
-				+ " BrokerURL=" + BrokerURL
-				+ " PeerBrokerInfos=" + PeerBrokerInfos
-				+ " BrokerName=" + BrokerName
-				+ " SlaveBroker=" + SlaveBroker
-				+ " MasterBroker=" + MasterBroker
-				+ " FaultTolerantConfiguration=" + FaultTolerantConfiguration
-				+ " DuplexConnection=" + DuplexConnection
-				+ " NetworkConnection=" + NetworkConnection
-				+ " ConnectionId=" + ConnectionId
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_BrokerInfo;
-		}
-
-
-		// Properties
-
-		public BrokerId BrokerId
-		{
-			get { return brokerId; }
-			set { this.brokerId = value; }
-		}
-
-		public string BrokerURL
-		{
-			get { return brokerURL; }
-			set { this.brokerURL = value; }
-		}
-
-		public BrokerInfo[] PeerBrokerInfos
-		{
-			get { return peerBrokerInfos; }
-			set { this.peerBrokerInfos = value; }
-		}
-
-		public string BrokerName
-		{
-			get { return brokerName; }
-			set { this.brokerName = value; }
-		}
-
-		public bool SlaveBroker
-		{
-			get { return slaveBroker; }
-			set { this.slaveBroker = value; }
-		}
-
-		public bool MasterBroker
-		{
-			get { return masterBroker; }
-			set { this.masterBroker = value; }
-		}
-
-		public bool FaultTolerantConfiguration
-		{
-			get { return faultTolerantConfiguration; }
-			set { this.faultTolerantConfiguration = value; }
-		}
-
-		public bool DuplexConnection
-		{
-			get { return duplexConnection; }
-			set { this.duplexConnection = value; }
-		}
-
-		public bool NetworkConnection
-		{
-			get { return networkConnection; }
-			set { this.networkConnection = value; }
-		}
-
-		public long ConnectionId
-		{
-			get { return connectionId; }
-			set { this.connectionId = value; }
-		}
-
-		public override bool IsBrokerInfo
-		{
-			get
-			{
-				return true;
-			}
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processBrokerInfo(this);
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class BrokerInfo : BaseCommand
+    {
+        public const byte ID_BROKERINFO = 2;
+
+        BrokerId brokerId;
+        string brokerURL;
+        BrokerInfo[] peerBrokerInfos;
+        string brokerName;
+        bool slaveBroker;
+        bool masterBroker;
+        bool faultTolerantConfiguration;
+        bool duplexConnection;
+        bool networkConnection;
+        long connectionId;
+        string brokerUploadUrl;
+        string networkProperties;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_BROKERINFO;
+        }
+
+        ///
+        /// <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 + "[" + 
+                "BrokerId=" + BrokerId + 
+                "BrokerURL=" + BrokerURL + 
+                "PeerBrokerInfos=" + PeerBrokerInfos + 
+                "BrokerName=" + BrokerName + 
+                "SlaveBroker=" + SlaveBroker + 
+                "MasterBroker=" + MasterBroker + 
+                "FaultTolerantConfiguration=" + FaultTolerantConfiguration + 
+                "DuplexConnection=" + DuplexConnection + 
+                "NetworkConnection=" + NetworkConnection + 
+                "ConnectionId=" + ConnectionId + 
+                "BrokerUploadUrl=" + BrokerUploadUrl + 
+                "NetworkProperties=" + NetworkProperties + 
+                "]";
+        }
+
+        public BrokerId BrokerId
+        {
+            get { return brokerId; }
+            set { this.brokerId = value; }
+        }
+
+        public string BrokerURL
+        {
+            get { return brokerURL; }
+            set { this.brokerURL = value; }
+        }
+
+        public BrokerInfo[] PeerBrokerInfos
+        {
+            get { return peerBrokerInfos; }
+            set { this.peerBrokerInfos = value; }
+        }
+
+        public string BrokerName
+        {
+            get { return brokerName; }
+            set { this.brokerName = value; }
+        }
+
+        public bool SlaveBroker
+        {
+            get { return slaveBroker; }
+            set { this.slaveBroker = value; }
+        }
+
+        public bool MasterBroker
+        {
+            get { return masterBroker; }
+            set { this.masterBroker = value; }
+        }
+
+        public bool FaultTolerantConfiguration
+        {
+            get { return faultTolerantConfiguration; }
+            set { this.faultTolerantConfiguration = value; }
+        }
+
+        public bool DuplexConnection
+        {
+            get { return duplexConnection; }
+            set { this.duplexConnection = value; }
+        }
+
+        public bool NetworkConnection
+        {
+            get { return networkConnection; }
+            set { this.networkConnection = value; }
+        }
+
+        public long ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }
+        }
+
+        public string BrokerUploadUrl
+        {
+            get { return brokerUploadUrl; }
+            set { this.brokerUploadUrl = value; }
+        }
+
+        public string NetworkProperties
+        {
+            get { return networkProperties; }
+            set { this.networkProperties = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isBrokerInfo() query.
+        /// </summery>
+        ///
+        public override bool IsBrokerInfo
+        {
+            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.processBrokerInfo( this );
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Command.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Command.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Command.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/Command.cs Thu Jul 30 19:06:34 2009
@@ -22,44 +22,149 @@
 namespace Apache.NMS.ActiveMQ.Commands
 {
 
-	/// <summary>
-	/// An OpenWire command
-	/// </summary>
-	public interface Command : DataStructure, ICloneable
-	{
-		int CommandId
-		{
-			get;
-			set;
-		}
-
-		bool ResponseRequired
-		{
-			get;
-			set;
-		}
-
-		bool IsResponse
-		{
-			get;
-		}
-
-		bool IsBrokerInfo
-		{
-			get;
-		}
-
-		bool IsMessage
-		{
-			get;
-		}
-
-		bool IsShutdownInfo
-		{
-			get;
-		}
+    /// <summary>
+    /// An OpenWire command
+    /// </summary>
+    public interface Command : DataStructure, ICloneable
+    {
+        int CommandId
+        {
+            get;
+            set;
+        }
+
+        bool ResponseRequired
+        {
+            get;
+            set;
+        }
+
+        bool IsBrokerInfo
+        {
+            get;
+        }
+
+        bool IsConnectionControl
+        {
+            get;
+        }
+
+        bool IsConnectionInfo
+        {
+            get;
+        }
+
+        bool IsConnectionError
+        {
+            get;
+        }
+
+        bool IsConsumerControl
+        {
+            get;
+        }
+
+        bool IsConsumerInfo
+        {
+            get;
+        }
+
+        bool IsControlCommand
+        {
+            get;
+        }
+
+        bool IsDestinationInfo
+        {
+            get;
+        }
+
+        bool IsFlushCommand
+        {
+            get;
+        }
+
+        bool IsKeepAliveInfo
+        {
+            get;
+        }
+
+        bool IsMessage
+        {
+            get;
+        }
+
+        bool IsMessageAck
+        {
+            get;
+        }
+
+        bool IsMessageDispatch
+        {
+            get;
+        }
+
+        bool IsMessageDispatchNotification
+        {
+            get;
+        }
+
+        bool IsMessagePull
+        {
+            get;
+        }
+
+        bool IsProducerAck
+        {
+            get;
+        }
+
+        bool IsProducerInfo
+        {
+            get;
+        }
+
+        bool IsRemoveInfo
+        {
+            get;
+        }
+
+        bool IsRemoveSubscriptionInfo
+        {
+            get;
+        }
+
+        bool IsReplayCommand
+        {
+            get;
+        }
+
+        bool IsResponse
+        {
+            get;
+        }
+
+        bool IsSessionInfo
+        {
+            get;
+        }
+
+        bool IsShutdownInfo
+        {
+            get;
+        }
+
+        bool IsTransactionInfo
+        {
+            get;
+        }
+
+        bool IsWireFormatInfo
+        {
+           get;
+        }
 
-		Response visit(ICommandVisitor visitor);
-	}
+        Response visit(ICommandVisitor visitor);
+    }
 }
 

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionControl.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionControl.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionControl.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionControl.cs Thu Jul 30 19:06:34 2009
@@ -14,83 +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 ConnectionControl Command
-	/// </summary>
-	public class ConnectionControl : BaseCommand
-	{
-		public const byte ID_ConnectionControl = 18;
-
-		bool close;
-		bool exit;
-		bool faultTolerant;
-		bool resume;
-		bool suspend;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " Close=" + Close
-				+ " Exit=" + Exit
-				+ " FaultTolerant=" + FaultTolerant
-				+ " Resume=" + Resume
-				+ " Suspend=" + Suspend
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ConnectionControl;
-		}
-
-
-		// Properties
-
-		public bool Close
-		{
-			get { return close; }
-			set { this.close = value; }
-		}
-
-		public bool Exit
-		{
-			get { return exit; }
-			set { this.exit = value; }
-		}
-
-		public bool FaultTolerant
-		{
-			get { return faultTolerant; }
-			set { this.faultTolerant = value; }
-		}
-
-		public bool Resume
-		{
-			get { return resume; }
-			set { this.resume = value; }
-		}
-
-		public bool Suspend
-		{
-			get { return suspend; }
-			set { this.suspend = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processConnectionControl(this);
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class ConnectionControl : BaseCommand
+    {
+        public const byte ID_CONNECTIONCONTROL = 18;
+
+        bool close;
+        bool exit;
+        bool faultTolerant;
+        bool resume;
+        bool suspend;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_CONNECTIONCONTROL;
+        }
+
+        ///
+        /// <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 + "[" + 
+                "Close=" + Close + 
+                "Exit=" + Exit + 
+                "FaultTolerant=" + FaultTolerant + 
+                "Resume=" + Resume + 
+                "Suspend=" + Suspend + 
+                "]";
+        }
+
+        public bool Close
+        {
+            get { return close; }
+            set { this.close = value; }
+        }
+
+        public bool Exit
+        {
+            get { return exit; }
+            set { this.exit = value; }
+        }
+
+        public bool FaultTolerant
+        {
+            get { return faultTolerant; }
+            set { this.faultTolerant = value; }
+        }
+
+        public bool Resume
+        {
+            get { return resume; }
+            set { this.resume = value; }
+        }
+
+        public bool Suspend
+        {
+            get { return suspend; }
+            set { this.suspend = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isConnectionControl() query.
+        /// </summery>
+        ///
+        public override bool IsConnectionControl
+        {
+            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.processConnectionControl( this );
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionError.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionError.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionError.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionError.cs Thu Jul 30 19:06:34 2009
@@ -14,59 +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 ConnectionError Command
-	/// </summary>
-	public class ConnectionError : BaseCommand
-	{
-		public const byte ID_ConnectionError = 16;
-
-		BrokerError exception;
-		ConnectionId connectionId;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " Exception=" + Exception
-				+ " ConnectionId=" + ConnectionId
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ConnectionError;
-		}
-
-
-		// Properties
-
-		public BrokerError Exception
-		{
-			get { return exception; }
-			set { this.exception = value; }
-		}
-
-		public ConnectionId ConnectionId
-		{
-			get { return connectionId; }
-			set { this.connectionId = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processConnectionError(this);
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class ConnectionError : BaseCommand
+    {
+        public const byte ID_CONNECTIONERROR = 16;
+
+        BrokerError exception;
+        ConnectionId connectionId;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_CONNECTIONERROR;
+        }
+
+        ///
+        /// <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 + "[" + 
+                "Exception=" + Exception + 
+                "ConnectionId=" + ConnectionId + 
+                "]";
+        }
+
+        public BrokerError Exception
+        {
+            get { return exception; }
+            set { this.exception = value; }
+        }
+
+        public ConnectionId ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isConnectionError() query.
+        /// </summery>
+        ///
+        public override bool IsConnectionError
+        {
+            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.processConnectionError( this );
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionId.cs Thu Jul 30 19:06:34 2009
@@ -14,79 +14,103 @@
  * 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 ConnectionId Command
-	/// </summary>
-	public class ConnectionId : BaseDataStructure, DataStructure
-	{
-		public const byte ID_ConnectionId = 120;
-
-		string value;
-
-		public override int GetHashCode()
-		{
-			int answer = 0;
-			answer = (answer * 37) + HashCode(Value);
-			return answer;
-
-		}
-
-		public override bool Equals(object that)
-		{
-			if(that is ConnectionId)
-			{
-				return Equals((ConnectionId) that);
-			}
-			return false;
-		}
-
-		public virtual bool Equals(ConnectionId that)
-		{
-			if(!Equals(this.Value, that.Value))
-				return false;
-			return true;
-
-		}
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " Value=" + Value
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ConnectionId;
-		}
-
-
-		// Properties
-
-		public string Value
-		{
-			get { return value; }
-			set { this.value = value; }
-		}
-
-		public ConnectionId(SessionId id)
-		{
-			this.value = id.ConnectionId;
-		}
-
-		public ConnectionId()
-		{
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class ConnectionId : BaseDataStructure
+    {
+        public const byte ID_CONNECTIONID = 120;
+
+        string value;
+
+        public ConnectionId()
+        {
+        }
+
+        public ConnectionId( SessionId sessionId )
+        {
+            this.value = sessionId.ConnectionId;
+        }
+
+        public ConnectionId( ProducerId producerId )
+        {
+            this.value = producerId.ConnectionId;
+        }
+
+        public ConnectionId( ConsumerId consumerId )
+        {
+            this.value = consumerId.ConnectionId;
+        }
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_CONNECTIONID;
+        }
+
+        ///
+        /// <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 + "[" + 
+                "Value=" + Value + 
+                "]";
+        }
+
+        public string Value
+        {
+            get { return value; }
+            set { this.value = value; }
+        }
+
+        public override int GetHashCode()
+        {
+            int answer = 0;
+
+            answer = (answer * 37) + HashCode(Value);
+
+            return answer;
+        }
+
+        public override bool Equals(object that)
+        {
+            if(that is ConnectionId)
+            {
+                return Equals((ConnectionId) that);
+            }
+            return false;
+        }
+
+        public virtual bool Equals(ConnectionId that)
+        {
+            if(!Equals(this.Value, that.Value))
+            {
+                return false;
+            }
+
+            return true;
+        }
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConnectionInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,107 +14,140 @@
  * 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 ConnectionInfo Command
-	/// </summary>
-	public class ConnectionInfo : BaseCommand
-	{
-		public const byte ID_ConnectionInfo = 3;
-
-		ConnectionId connectionId;
-		string clientId;
-		string password;
-		string userName;
-		BrokerId[] brokerPath;
-		bool brokerMasterConnector;
-		bool manageable;
-		bool clientMaster = true;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ConnectionId=" + ConnectionId
-				+ " ClientId=" + ClientId
-				+ " Password=" + Password
-				+ " UserName=" + UserName
-				+ " BrokerPath=" + BrokerPath
-				+ " BrokerMasterConnector=" + BrokerMasterConnector
-				+ " Manageable=" + Manageable
-				+ " ClientMaster=" + ClientMaster
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ConnectionInfo;
-		}
-
-
-		// Properties
-
-		public ConnectionId ConnectionId
-		{
-			get { return connectionId; }
-			set { this.connectionId = value; }
-		}
-
-		public string ClientId
-		{
-			get { return clientId; }
-			set { this.clientId = value; }
-		}
-
-		public string Password
-		{
-			get { return password; }
-			set { this.password = value; }
-		}
-
-		public string UserName
-		{
-			get { return userName; }
-			set { this.userName = value; }
-		}
-
-		public BrokerId[] BrokerPath
-		{
-			get { return brokerPath; }
-			set { this.brokerPath = value; }
-		}
-
-		public bool BrokerMasterConnector
-		{
-			get { return brokerMasterConnector; }
-			set { this.brokerMasterConnector = value; }
-		}
-
-		public bool Manageable
-		{
-			get { return manageable; }
-			set { this.manageable = value; }
-		}
-
-		public bool ClientMaster
-		{
-			get { return clientMaster; }
-			set { this.clientMaster = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processAddConnection(this);
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class ConnectionInfo : BaseCommand
+    {
+        public const byte ID_CONNECTIONINFO = 3;
+
+        ConnectionId connectionId;
+        string clientId;
+        string password;
+        string userName;
+        BrokerId[] brokerPath;
+        bool brokerMasterConnector;
+        bool manageable;
+        bool clientMaster;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_CONNECTIONINFO;
+        }
+
+        ///
+        /// <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 + 
+                "ClientId=" + ClientId + 
+                "Password=" + Password + 
+                "UserName=" + UserName + 
+                "BrokerPath=" + BrokerPath + 
+                "BrokerMasterConnector=" + BrokerMasterConnector + 
+                "Manageable=" + Manageable + 
+                "ClientMaster=" + ClientMaster + 
+                "]";
+        }
+
+        public ConnectionId ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }
+        }
+
+        public string ClientId
+        {
+            get { return clientId; }
+            set { this.clientId = value; }
+        }
+
+        public string Password
+        {
+            get { return password; }
+            set { this.password = value; }
+        }
+
+        public string UserName
+        {
+            get { return userName; }
+            set { this.userName = value; }
+        }
+
+        public BrokerId[] BrokerPath
+        {
+            get { return brokerPath; }
+            set { this.brokerPath = value; }
+        }
+
+        public bool BrokerMasterConnector
+        {
+            get { return brokerMasterConnector; }
+            set { this.brokerMasterConnector = value; }
+        }
+
+        public bool Manageable
+        {
+            get { return manageable; }
+            set { this.manageable = value; }
+        }
+
+        public bool ClientMaster
+        {
+            get { return clientMaster; }
+            set { this.clientMaster = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isConnectionInfo() query.
+        /// </summery>
+        ///
+        public override bool IsConnectionInfo
+        {
+            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.processAddConnection( this );
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerControl.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerControl.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerControl.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerControl.cs Thu Jul 30 19:06:34 2009
@@ -14,91 +14,124 @@
  * 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 ConsumerControl Command
-	/// </summary>
-	public class ConsumerControl : BaseCommand
-	{
-		public const byte ID_ConsumerControl = 17;
-
-		bool close;
-		ConsumerId consumerId;
-		int prefetch;
-		bool flush;
-		bool start;
-		bool stop;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " Close=" + Close
-				+ " ConsumerId=" + ConsumerId
-				+ " Prefetch=" + Prefetch
-				+ " Flush=" + Flush
-				+ " Start=" + Start
-				+ " Stop=" + Stop
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ConsumerControl;
-		}
-
-
-		// Properties
-
-		public bool Close
-		{
-			get { return close; }
-			set { this.close = value; }
-		}
-
-		public ConsumerId ConsumerId
-		{
-			get { return consumerId; }
-			set { this.consumerId = value; }
-		}
-
-		public int Prefetch
-		{
-			get { return prefetch; }
-			set { this.prefetch = value; }
-		}
-
-		public bool Flush
-		{
-			get { return flush; }
-			set { this.flush = value; }
-		}
-
-		public bool Start
-		{
-			get { return start; }
-			set { this.start = value; }
-		}
-
-		public bool Stop
-		{
-			get { return stop; }
-			set { this.stop = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processConsumerControl(this);
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class ConsumerControl : BaseCommand
+    {
+        public const byte ID_CONSUMERCONTROL = 17;
+
+        bool close;
+        ConsumerId consumerId;
+        int prefetch;
+        bool flush;
+        bool start;
+        bool stop;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_CONSUMERCONTROL;
+        }
+
+        ///
+        /// <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 + "[" + 
+                "Close=" + Close + 
+                "ConsumerId=" + ConsumerId + 
+                "Prefetch=" + Prefetch + 
+                "Flush=" + Flush + 
+                "Start=" + Start + 
+                "Stop=" + Stop + 
+                "]";
+        }
+
+        public bool Close
+        {
+            get { return close; }
+            set { this.close = value; }
+        }
+
+        public ConsumerId ConsumerId
+        {
+            get { return consumerId; }
+            set { this.consumerId = value; }
+        }
+
+        public int Prefetch
+        {
+            get { return prefetch; }
+            set { this.prefetch = value; }
+        }
+
+        public bool Flush
+        {
+            get { return flush; }
+            set { this.flush = value; }
+        }
+
+        public bool Start
+        {
+            get { return start; }
+            set { this.start = value; }
+        }
+
+        public bool Stop
+        {
+            get { return stop; }
+            set { this.stop = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isConsumerControl() query.
+        /// </summery>
+        ///
+        public override bool IsConsumerControl
+        {
+            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.processConsumerControl( this );
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerId.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerId.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerId.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerId.cs Thu Jul 30 19:06:34 2009
@@ -14,103 +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 ConsumerId Command
-	/// </summary>
-	public class ConsumerId : BaseDataStructure, DataStructure
-	{
-		public const byte ID_ConsumerId = 122;
-
-		string connectionId;
-		long sessionId;
-		long value;
-		private SessionId _parentId;
-
-		public override int GetHashCode()
-		{
-			int answer = 0;
-			answer = (answer * 37) + HashCode(ConnectionId);
-			answer = (answer * 37) + HashCode(SessionId);
-			answer = (answer * 37) + HashCode(Value);
-			return answer;
-
-		}
-
-		public override bool Equals(object that)
-		{
-			if(that is ConsumerId)
-			{
-				return Equals((ConsumerId) that);
-			}
-			return false;
-		}
-
-		public virtual bool Equals(ConsumerId that)
-		{
-			if(!Equals(this.ConnectionId, that.ConnectionId))
-				return false;
-			if(!Equals(this.SessionId, that.SessionId))
-				return false;
-			if(!Equals(this.Value, that.Value))
-				return false;
-			return true;
-
-		}
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ConnectionId=" + ConnectionId
-				+ " SessionId=" + SessionId
-				+ " Value=" + Value
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ConsumerId;
-		}
-
-
-		// Properties
-
-		public string ConnectionId
-		{
-			get { return connectionId; }
-			set { this.connectionId = value; }
-		}
-
-		public long SessionId
-		{
-			get { return sessionId; }
-			set { this.sessionId = value; }
-		}
-
-		public long Value
-		{
-			get { return value; }
-			set { this.value = value; }
-		}
-
-		public SessionId ParentId
-		{
-			get
-			{
-				if(_parentId == null)
-				{
-					_parentId = new SessionId(this);
-				}
-				return _parentId;
-			}
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class ConsumerId : BaseDataStructure
+    {
+        public const byte ID_CONSUMERID = 122;
+
+        private SessionId parentId = null;
+
+        string connectionId;
+        long sessionId;
+        long value;
+
+        public ConsumerId()
+        {
+        }
+
+        public ConsumerId( 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_CONSUMERID;
+        }
+
+        ///
+        /// <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 + 
+                "SessionId=" + SessionId + 
+                "Value=" + Value + 
+                "]";
+        }
+
+        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 SessionId
+        {
+            get { return sessionId; }
+            set { this.sessionId = 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(SessionId);
+            answer = (answer * 37) + HashCode(Value);
+
+            return answer;
+        }
+
+        public override bool Equals(object that)
+        {
+            if(that is ConsumerId)
+            {
+                return Equals((ConsumerId) that);
+            }
+            return false;
+        }
+
+        public virtual bool Equals(ConsumerId that)
+        {
+            if(!Equals(this.ConnectionId, that.ConnectionId))
+            {
+                return false;
+            }
+            if(!Equals(this.SessionId, that.SessionId))
+            {
+                return false;
+            }
+            if(!Equals(this.Value, that.Value))
+            {
+                return false;
+            }
+
+            return true;
+        }
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ConsumerInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,187 +14,220 @@
  * 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 ConsumerInfo Command
-	/// </summary>
-	public class ConsumerInfo : BaseCommand
-	{
-		public const byte ID_ConsumerInfo = 5;
-
-		ConsumerId consumerId;
-		bool browser;
-		ActiveMQDestination destination;
-		int prefetchSize;
-		int maximumPendingMessageLimit;
-		bool dispatchAsync;
-		string selector;
-		string subscriptionName;
-		bool noLocal;
-		bool exclusive;
-		bool retroactive;
-		byte priority;
-		BrokerId[] brokerPath;
-		BooleanExpression additionalPredicate;
-		bool networkSubscription;
-		bool optimizedAcknowledge;
-		bool noRangeAcks;
-		AcknowledgementMode acknowledgementMode = AcknowledgementMode.AutoAcknowledge;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ConsumerId=" + ConsumerId
-				+ " Browser=" + Browser
-				+ " Destination=" + Destination
-				+ " PrefetchSize=" + PrefetchSize
-				+ " MaximumPendingMessageLimit=" + MaximumPendingMessageLimit
-				+ " DispatchAsync=" + DispatchAsync
-				+ " Selector=" + Selector
-				+ " SubscriptionName=" + SubscriptionName
-				+ " NoLocal=" + NoLocal
-				+ " Exclusive=" + Exclusive
-				+ " Retroactive=" + Retroactive
-				+ " Priority=" + Priority
-				+ " BrokerPath=" + BrokerPath
-				+ " AdditionalPredicate=" + AdditionalPredicate
-				+ " NetworkSubscription=" + NetworkSubscription
-				+ " OptimizedAcknowledge=" + OptimizedAcknowledge
-				+ " NoRangeAcks=" + NoRangeAcks
-				+ " AcknowledgementMode=" + AcknowledgementMode
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ConsumerInfo;
-		}
-
-
-		// Properties
-
-		public ConsumerId ConsumerId
-		{
-			get { return consumerId; }
-			set { this.consumerId = value; }
-		}
-
-		public bool Browser
-		{
-			get { return browser; }
-			set { this.browser = value; }
-		}
-
-		public ActiveMQDestination Destination
-		{
-			get { return destination; }
-			set { this.destination = value; }
-		}
-
-		public int PrefetchSize
-		{
-			get { return prefetchSize; }
-			set { this.prefetchSize = value; }
-		}
-
-		public int MaximumPendingMessageLimit
-		{
-			get { return maximumPendingMessageLimit; }
-			set { this.maximumPendingMessageLimit = value; }
-		}
-
-		public bool DispatchAsync
-		{
-			get { return dispatchAsync; }
-			set { this.dispatchAsync = value; }
-		}
-
-		public string Selector
-		{
-			get { return selector; }
-			set { this.selector = value; }
-		}
-
-		public string SubscriptionName
-		{
-			get { return subscriptionName; }
-			set { this.subscriptionName = value; }
-		}
-
-		public bool NoLocal
-		{
-			get { return noLocal; }
-			set { this.noLocal = value; }
-		}
-
-		public bool Exclusive
-		{
-			get { return exclusive; }
-			set { this.exclusive = value; }
-		}
-
-		public bool Retroactive
-		{
-			get { return retroactive; }
-			set { this.retroactive = value; }
-		}
-
-		public byte Priority
-		{
-			get { return priority; }
-			set { this.priority = value; }
-		}
-
-		public BrokerId[] BrokerPath
-		{
-			get { return brokerPath; }
-			set { this.brokerPath = value; }
-		}
-
-		public BooleanExpression AdditionalPredicate
-		{
-			get { return additionalPredicate; }
-			set { this.additionalPredicate = value; }
-		}
-
-		public bool NetworkSubscription
-		{
-			get { return networkSubscription; }
-			set { this.networkSubscription = value; }
-		}
-
-		public bool OptimizedAcknowledge
-		{
-			get { return optimizedAcknowledge; }
-			set { this.optimizedAcknowledge = value; }
-		}
-
-		public bool NoRangeAcks
-		{
-			get { return noRangeAcks; }
-			set { this.noRangeAcks = value; }
-		}
-
-		public AcknowledgementMode AcknowledgementMode
-		{
-			get { return acknowledgementMode; }
-			set { this.acknowledgementMode = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processAddConsumer(this);
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class ConsumerInfo : BaseCommand
+    {
+        public const byte ID_CONSUMERINFO = 5;
+
+        ConsumerId consumerId;
+        bool browser;
+        ActiveMQDestination destination;
+        int prefetchSize;
+        int maximumPendingMessageLimit;
+        bool dispatchAsync;
+        string selector;
+        string subscriptionName;
+        bool noLocal;
+        bool exclusive;
+        bool retroactive;
+        byte priority;
+        BrokerId[] brokerPath;
+        BooleanExpression additionalPredicate;
+        bool networkSubscription;
+        bool optimizedAcknowledge;
+        bool noRangeAcks;
+        ConsumerId[] networkConsumerPath;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_CONSUMERINFO;
+        }
+
+        ///
+        /// <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 + "[" + 
+                "ConsumerId=" + ConsumerId + 
+                "Browser=" + Browser + 
+                "Destination=" + Destination + 
+                "PrefetchSize=" + PrefetchSize + 
+                "MaximumPendingMessageLimit=" + MaximumPendingMessageLimit + 
+                "DispatchAsync=" + DispatchAsync + 
+                "Selector=" + Selector + 
+                "SubscriptionName=" + SubscriptionName + 
+                "NoLocal=" + NoLocal + 
+                "Exclusive=" + Exclusive + 
+                "Retroactive=" + Retroactive + 
+                "Priority=" + Priority + 
+                "BrokerPath=" + BrokerPath + 
+                "AdditionalPredicate=" + AdditionalPredicate + 
+                "NetworkSubscription=" + NetworkSubscription + 
+                "OptimizedAcknowledge=" + OptimizedAcknowledge + 
+                "NoRangeAcks=" + NoRangeAcks + 
+                "NetworkConsumerPath=" + NetworkConsumerPath + 
+                "]";
+        }
+
+        public ConsumerId ConsumerId
+        {
+            get { return consumerId; }
+            set { this.consumerId = value; }
+        }
+
+        public bool Browser
+        {
+            get { return browser; }
+            set { this.browser = value; }
+        }
+
+        public ActiveMQDestination Destination
+        {
+            get { return destination; }
+            set { this.destination = value; }
+        }
+
+        public int PrefetchSize
+        {
+            get { return prefetchSize; }
+            set { this.prefetchSize = value; }
+        }
+
+        public int MaximumPendingMessageLimit
+        {
+            get { return maximumPendingMessageLimit; }
+            set { this.maximumPendingMessageLimit = value; }
+        }
+
+        public bool DispatchAsync
+        {
+            get { return dispatchAsync; }
+            set { this.dispatchAsync = value; }
+        }
+
+        public string Selector
+        {
+            get { return selector; }
+            set { this.selector = value; }
+        }
+
+        public string SubscriptionName
+        {
+            get { return subscriptionName; }
+            set { this.subscriptionName = value; }
+        }
+
+        public bool NoLocal
+        {
+            get { return noLocal; }
+            set { this.noLocal = value; }
+        }
+
+        public bool Exclusive
+        {
+            get { return exclusive; }
+            set { this.exclusive = value; }
+        }
+
+        public bool Retroactive
+        {
+            get { return retroactive; }
+            set { this.retroactive = value; }
+        }
+
+        public byte Priority
+        {
+            get { return priority; }
+            set { this.priority = value; }
+        }
+
+        public BrokerId[] BrokerPath
+        {
+            get { return brokerPath; }
+            set { this.brokerPath = value; }
+        }
+
+        public BooleanExpression AdditionalPredicate
+        {
+            get { return additionalPredicate; }
+            set { this.additionalPredicate = value; }
+        }
+
+        public bool NetworkSubscription
+        {
+            get { return networkSubscription; }
+            set { this.networkSubscription = value; }
+        }
+
+        public bool OptimizedAcknowledge
+        {
+            get { return optimizedAcknowledge; }
+            set { this.optimizedAcknowledge = value; }
+        }
+
+        public bool NoRangeAcks
+        {
+            get { return noRangeAcks; }
+            set { this.noRangeAcks = value; }
+        }
+
+        public ConsumerId[] NetworkConsumerPath
+        {
+            get { return networkConsumerPath; }
+            set { this.networkConsumerPath = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isConsumerInfo() query.
+        /// </summery>
+        ///
+        public override bool IsConsumerInfo
+        {
+            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.processAddConsumer( this );
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ControlCommand.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ControlCommand.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ControlCommand.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/ControlCommand.cs Thu Jul 30 19:06:34 2009
@@ -14,51 +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 ControlCommand Command
-	/// </summary>
-	public class ControlCommand : BaseCommand
-	{
-		public const byte ID_ControlCommand = 14;
-
-		string command;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " Command=" + Command
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_ControlCommand;
-		}
-
-
-		// Properties
-
-		public string Command
-		{
-			get { return command; }
-			set { this.command = value; }
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			return visitor.processControlCommand(this);
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class ControlCommand : BaseCommand
+    {
+        public const byte ID_CONTROLCOMMAND = 14;
+
+        string command;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_CONTROLCOMMAND;
+        }
+
+        ///
+        /// <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 + "[" + 
+                "Command=" + Command + 
+                "]";
+        }
+
+        public string Command
+        {
+            get { return command; }
+            set { this.command = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isControlCommand() query.
+        /// </summery>
+        ///
+        public override bool IsControlCommand
+        {
+            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.processControlCommand( this );
+        }
+
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataArrayResponse.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataArrayResponse.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataArrayResponse.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataArrayResponse.cs Thu Jul 30 19:06:34 2009
@@ -14,48 +14,57 @@
  * 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 DataArrayResponse Command
-    /// </summary>
+    /*
+     *
+     *  Command 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
+     *
+     */
     public class DataArrayResponse : Response
     {
-        public const byte ID_DataArrayResponse = 33;
-    			
-        DataStructure[] data;
-
-		public override string ToString() {
-            return GetType().Name + "["
-                + " Data=" + Data
-                + " ]";
+        public const byte ID_DATAARRAYRESPONSE = 33;
 
-		}
+        DataStructure[] data;
 
-        public override byte GetDataStructureType() {
-            return ID_DataArrayResponse;
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_DATAARRAYRESPONSE;
         }
 
-
-        // 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 + "[" + 
+                "Data=" + Data + 
+                "]";
+        }
 
         public DataStructure[] Data
         {
             get { return data; }
-            set { this.data = value; }            
+            set { this.data = value; }
         }
 
-    }
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataResponse.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataResponse.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataResponse.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DataResponse.cs Thu Jul 30 19:06:34 2009
@@ -14,48 +14,57 @@
  * 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 DataResponse Command
-    /// </summary>
+    /*
+     *
+     *  Command 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
+     *
+     */
     public class DataResponse : Response
     {
-        public const byte ID_DataResponse = 32;
-    			
-        DataStructure data;
-
-		public override string ToString() {
-            return GetType().Name + "["
-                + " Data=" + Data
-                + " ]";
+        public const byte ID_DATARESPONSE = 32;
 
-		}
+        DataStructure data;
 
-        public override byte GetDataStructureType() {
-            return ID_DataResponse;
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_DATARESPONSE;
         }
 
-
-        // 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 + "[" + 
+                "Data=" + Data + 
+                "]";
+        }
 
         public DataStructure Data
         {
             get { return data; }
-            set { this.data = value; }            
+            set { this.data = value; }
         }
 
-    }
+    };
 }
+

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DestinationInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DestinationInfo.cs?rev=799407&r1=799406&r2=799407&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DestinationInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Commands/DestinationInfo.cs Thu Jul 30 19:06:34 2009
@@ -14,110 +14,141 @@
  * 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 DestinationInfo Command
-	/// </summary>
-	public class DestinationInfo : BaseCommand
-	{
-		public const byte ID_DestinationInfo = 8;
-
-		public const byte ADD_OPERATION_TYPE = 0;
-		public const byte REMOVE_OPERATION_TYPE = 1;
-
-		ConnectionId connectionId;
-		IDestination destination;
-		byte operationType;
-		long timeout;
-		BrokerId[] brokerPath;
-
-		public override string ToString()
-		{
-			return GetType().Name + "["
-				+ " ConnectionId=" + ConnectionId
-				+ " Destination=" + Destination
-				+ " OperationType=" + OperationType
-				+ " Timeout=" + Timeout
-				+ " BrokerPath=" + BrokerPath
-				+ " ]";
-
-		}
-
-		public override byte GetDataStructureType()
-		{
-			return ID_DestinationInfo;
-		}
-
-
-		// Properties
-
-		public ConnectionId ConnectionId
-		{
-			get { return connectionId; }
-			set { this.connectionId = value; }
-		}
-
-		public IDestination Destination
-		{
-			get { return destination; }
-			set { this.destination = value; }
-		}
-
-		public byte OperationType
-		{
-			get { return operationType; }
-			set { this.operationType = value; }
-		}
-
-		public long Timeout
-		{
-			get { return timeout; }
-			set { this.timeout = value; }
-		}
-
-		public BrokerId[] BrokerPath
-		{
-			get { return brokerPath; }
-			set { this.brokerPath = value; }
-		}
-
-		public bool IsAddOperation
-		{
-			get
-			{
-				return OperationType == ADD_OPERATION_TYPE;
-			}
-		}
-
-		public bool IsRemoveOperation
-		{
-			get
-			{
-				return OperationType == REMOVE_OPERATION_TYPE;
-			}
-		}
-
-		public override Response visit(ICommandVisitor visitor)
-		{
-			if(IsAddOperation)
-			{
-				return visitor.processAddDestination(this);
-			}
-			else if(IsRemoveOperation)
-			{
-				return visitor.processRemoveDestination(this);
-			}
-			throw new IOException("Unknown operation type: " + OperationType);
-		}
-	}
+    /*
+     *
+     *  Command 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
+     *
+     */
+    public class DestinationInfo : BaseCommand
+    {
+        public const byte ID_DESTINATIONINFO = 8;
+
+        public const byte ADD_OPERATION_TYPE = 0;
+        public const byte REMOVE_OPERATION_TYPE = 1;
+        ConnectionId connectionId;
+        ActiveMQDestination destination;
+        byte operationType;
+        long timeout;
+        BrokerId[] brokerPath;
+
+        ///
+        /// <summery>
+        ///  Get the unique identifier that this object and its own
+        ///  Marshaler share.
+        /// </summery>
+        ///
+        public override byte GetDataStructureType()
+        {
+            return ID_DESTINATIONINFO;
+        }
+
+        ///
+        /// <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 + 
+                "Destination=" + Destination + 
+                "OperationType=" + OperationType + 
+                "Timeout=" + Timeout + 
+                "BrokerPath=" + BrokerPath + 
+                "]";
+        }
+
+        public bool IsAddOperation
+        {
+            get
+            {
+                return OperationType == ADD_OPERATION_TYPE;
+            }
+        }
+
+        public bool IsRemoveOperation
+        {
+            get
+            {
+                return OperationType == REMOVE_OPERATION_TYPE;
+            }
+        }
+        public ConnectionId ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }
+        }
+
+        public ActiveMQDestination Destination
+        {
+            get { return destination; }
+            set { this.destination = value; }
+        }
+
+        public byte OperationType
+        {
+            get { return operationType; }
+            set { this.operationType = value; }
+        }
+
+        public long Timeout
+        {
+            get { return timeout; }
+            set { this.timeout = value; }
+        }
+
+        public BrokerId[] BrokerPath
+        {
+            get { return brokerPath; }
+            set { this.brokerPath = value; }
+        }
+
+        ///
+        /// <summery>
+        ///  Return an answer of true to the isDestinationInfo() query.
+        /// </summery>
+        ///
+        public override bool IsDestinationInfo
+        {
+            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)
+        {
+        if(IsAddOperation)
+        {
+            return visitor.processAddDestination(this);
+        }
+        else if(IsRemoveOperation)
+        {
+            return visitor.processRemoveDestination(this);
+        }
+        throw new IOException("Unknown operation type: " + OperationType);
+        }
+
+    };
 }
+



Mime
View raw message