activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r386440 [1/4] - in /incubator/activemq/trunk/activemq-dotnet: ./ src/main/csharp/ src/main/csharp/ActiveMQ/Commands/ src/main/csharp/ActiveMQ/OpenWire/ src/test/csharp/ src/test/csharp/ActiveMQ/OpenWire/ src/test/csharp/NMS/
Date Thu, 16 Mar 2006 19:45:16 GMT
Author: jstrachan
Date: Thu Mar 16 11:45:13 2006
New Revision: 386440

URL: http://svn.apache.org/viewcvs?rev=386440&view=rev
Log:
updated the C# client to get it compiling and most of the tests working with the latest generated OpenWire code; particularly after the change of Command.CommandId from short to int

Added:
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BaseDataStructure.cs
Modified:
    incubator/activemq/trunk/activemq-dotnet/activemq-dotnet.csproj
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/AbstractCommand.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ActiveMQDestination.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BaseCommand.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BrokerId.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Command.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionId.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerId.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/DiscoveryEvent.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalQueueAck.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTopicAck.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTrace.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTransaction.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/KeepAliveInfo.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/MessageId.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/NetworkBridgeFilter.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/PartialCommand.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ProducerId.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/SessionId.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/SubscriptionInfo.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/TransactionId.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/WireFormatInfo.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs
    incubator/activemq/trunk/activemq-dotnet/src/main/csharp/CommonAssemblyInfo.cs
    incubator/activemq/trunk/activemq-dotnet/src/test/csharp/ActiveMQ/OpenWire/EndianTest.cs
    incubator/activemq/trunk/activemq-dotnet/src/test/csharp/CommonAssemblyInfo.cs
    incubator/activemq/trunk/activemq-dotnet/src/test/csharp/NMS/JMSPropertyTest.cs

Modified: incubator/activemq/trunk/activemq-dotnet/activemq-dotnet.csproj
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/activemq-dotnet.csproj?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/activemq-dotnet.csproj (original)
+++ incubator/activemq/trunk/activemq-dotnet/activemq-dotnet.csproj Thu Mar 16 11:45:13 2006
@@ -49,6 +49,7 @@
         <Compile Include="src\main\csharp\ActiveMQ\Commands\ActiveMQTextMessage.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\ActiveMQTopic.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\BaseCommand.cs"/>
+        <Compile Include="src\main\csharp\ActiveMQ\Commands\BaseDataStructure.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\BooleanExpression.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\BrokerError.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\BrokerId.cs"/>
@@ -74,6 +75,7 @@
         <Compile Include="src\main\csharp\ActiveMQ\Commands\JournalTrace.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\JournalTransaction.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\KeepAliveInfo.cs"/>
+        <Compile Include="src\main\csharp\ActiveMQ\Commands\LastPartialCommand.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\LocalTransactionId.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\MarshallAware.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\Message.cs"/>
@@ -83,6 +85,7 @@
         <Compile Include="src\main\csharp\ActiveMQ\Commands\MessageId.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\MessageReference.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\NetworkBridgeFilter.cs"/>
+        <Compile Include="src\main\csharp\ActiveMQ\Commands\PartialCommand.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\ProducerId.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\ProducerInfo.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\Commands\RemoveInfo.cs"/>
@@ -149,6 +152,7 @@
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\JournalTraceMarshaller.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\JournalTransactionMarshaller.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\KeepAliveInfoMarshaller.cs"/>
+        <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\LastPartialCommandMarshaller.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\LocalTransactionIdMarshaller.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\MarshallerFactory.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\MessageAckMarshaller.cs"/>
@@ -157,6 +161,7 @@
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\MessageIdMarshaller.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\MessageMarshaller.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\NetworkBridgeFilterMarshaller.cs"/>
+        <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\PartialCommandMarshaller.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\ProducerIdMarshaller.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\ProducerInfoMarshaller.cs"/>
         <Compile Include="src\main\csharp\ActiveMQ\OpenWire\V1\RemoveInfoMarshaller.cs"/>

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/AbstractCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/AbstractCommand.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/AbstractCommand.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/AbstractCommand.cs Thu Mar 16 11:45:13 2006
@@ -20,13 +20,12 @@
 
 namespace ActiveMQ.Commands
 {
-	
-	/// <summary>
-	/// Summary description for AbstractCommand.
-	/// </summary>
-	public abstract class AbstractCommand : Command
+    
+    /// <summary>
+    /// Summary description for AbstractCommand.
+    /// </summary>
+    public abstract class AbstractCommand
     {
-        private short commandId;
         private bool responseRequired;
         
         
@@ -48,122 +47,14 @@
         
         // Properties
         
-        public short CommandId
-        {
-            get { return commandId; }
-            set { this.commandId = value; }
-        }
-        
         public bool ResponseRequired
         {
             get { return responseRequired; }
             set { this.responseRequired = value; }
         }
         
-        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;
-        }
+
         
-        // Helper methods
-        public int HashCode(object value)
-        {
-            if (value != null)
-            {
-                return value.GetHashCode();
-            }
-            else
-            {
-                return -1;
-            }
-        }
-		
-		public virtual void BeforeMarshall(OpenWireFormat wireFormat)
-		{
-		}
-		
-		public virtual void AfterMarshall(OpenWireFormat wireFormat)
-		{
-		}
-		
-		public virtual void BeforeUnmarshall(OpenWireFormat wireFormat)
-		{
-		}
-		
-		public virtual void AfterUnmarshall(OpenWireFormat wireFormat)
-		{
-		}
-		
-		public virtual void SetMarshalledForm(OpenWireFormat wireFormat, byte[] data)
-		{
-		}
-		
-		public virtual byte[] GetMarshalledForm(OpenWireFormat wireFormat)
-		{
-			return null;
-		}
-		
     }
 }
 

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ActiveMQDestination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ActiveMQDestination.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ActiveMQDestination.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ActiveMQDestination.cs Thu Mar 16 11:45:13 2006
@@ -1,527 +1,522 @@
-/*
- * Copyright 2006 The Apache Software Foundation or its licensors, as
- * applicable.
- *
- * Licensed 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 NMS;
-using System;
-namespace ActiveMQ.Commands
-{
-	
-	/// <summary>
-	/// Summary description for ActiveMQDestination.
-	/// </summary>
-	public abstract class ActiveMQDestination : AbstractCommand, IDestination
-    {
-        
-        /**
-         * Topic Destination object
-         */
-        public const int ACTIVEMQ_TOPIC = 1;
-        /**
-         * Temporary Topic Destination object
-         */
-        public const int ACTIVEMQ_TEMPORARY_TOPIC = 2;
-        
-        /**
-         * Queue Destination object
-         */
-        public const int ACTIVEMQ_QUEUE = 3;
-        /**
-         * Temporary Queue Destination object
-         */
-        public const int ACTIVEMQ_TEMPORARY_QUEUE = 4;
-        
-        /**
-         * prefix for Advisory message destinations
-         */
-        public const String ADVISORY_PREFIX = "ActiveMQ.Advisory.";
-        
-        /**
-         * prefix for consumer advisory destinations
-         */
-        public const String CONSUMER_ADVISORY_PREFIX = ADVISORY_PREFIX + "Consumers.";
-        
-        /**
-         * prefix for producer advisory destinations
-         */
-        public const String PRODUCER_ADVISORY_PREFIX = ADVISORY_PREFIX + "Producers.";
-        
-        /**
-         * prefix for connection advisory destinations
-         */
-        public const String CONNECTION_ADVISORY_PREFIX = ADVISORY_PREFIX + "Connections.";
-        
-        /**
-         * The default target for ordered destinations
-         */
-        public const String DEFAULT_ORDERED_TARGET = "coordinator";
-        
-        private const int NULL_DESTINATION = 10;
-        
-        private const String TEMP_PREFIX = "{TD{";
-        private const String TEMP_POSTFIX = "}TD}";
-        private const String COMPOSITE_SEPARATOR = ",";
-        private const String QUEUE_PREFIX = "queue://";
-        private const String TOPIC_PREFIX = "topic://";
-        
-        
-        private String physicalName = "";
-        
-        // Cached transient data
-        private bool exclusive;
-        private bool ordered;
-        private bool advisory;
-        private String orderedTarget = DEFAULT_ORDERED_TARGET;
-        
-        
-        /**
-         * The Default Constructor
-         */
-        protected ActiveMQDestination()
-        {
-        }
-        
-        /**
-         * Construct the Destination with a defined physical name;
-         *
-         * @param name
-         */
-        protected ActiveMQDestination(String name)
-        {
-            this.physicalName = name;
-            this.advisory = name != null && name.StartsWith(ADVISORY_PREFIX);
-        }
-        
-        
-        
-        /**
-         * @return Returns the advisory.
-         */
-        public bool IsAdvisory()
-        {
-            return advisory;
-        }
-        /**
-         * @param advisory The advisory to set.
-         */
-        public void SetAdvisory(bool advisory)
-        {
-            this.advisory = advisory;
-        }
-        
-        /**
-         * @return true if this is a destination for Consumer advisories
-         */
-        public bool IsConsumerAdvisory()
-        {
-            return IsAdvisory() && physicalName.StartsWith(CONSUMER_ADVISORY_PREFIX);
-        }
-        
-        /**
-         * @return true if this is a destination for Producer advisories
-         */
-        public bool IsProducerAdvisory()
-        {
-            return IsAdvisory() && physicalName.StartsWith(PRODUCER_ADVISORY_PREFIX);
-        }
-        
-        /**
-         * @return true if this is a destination for Connection advisories
-         */
-        public bool IsConnectionAdvisory()
-        {
-            return IsAdvisory() && physicalName.StartsWith(CONNECTION_ADVISORY_PREFIX);
-        }
-        
-        /**
-         * @return Returns the exclusive.
-         */
-        public bool IsExclusive()
-        {
-            return exclusive;
-        }
-        /**
-         * @param exclusive The exclusive to set.
-         */
-        public void SetExclusive(bool exclusive)
-        {
-            this.exclusive = exclusive;
-        }
-        /**
-         * @return Returns the ordered.
-         */
-        public bool IsOrdered()
-        {
-            return ordered;
-        }
-        /**
-         * @param ordered The ordered to set.
-         */
-        public void SetOrdered(bool ordered)
-        {
-            this.ordered = ordered;
-        }
-        /**
-         * @return Returns the orderedTarget.
-         */
-        public String GetOrderedTarget()
-        {
-            return orderedTarget;
-        }
-        /**
-         * @param orderedTarget The orderedTarget to set.
-         */
-        public void SetOrderedTarget(String orderedTarget)
-        {
-            this.orderedTarget = orderedTarget;
-        }
-        /**
-         * A helper method to return a descriptive string for the topic or queue
-         * @param destination
-         *
-         * @return a descriptive string for this queue or topic
-         */
-        public static String Inspect(ActiveMQDestination destination)
-        {
-            if (destination is ITopic)
-            {
-                return "Topic(" + destination.ToString() + ")";
-            }
-            else
-            {
-                return "Queue(" + destination.ToString() + ")";
-            }
-        }
-        
-        /**
-         * @param destination
-         * @return @throws JMSException
-         * @throws javax.jms.JMSException
-         */
-        public static ActiveMQDestination Transform(IDestination destination)
-        {
-            ActiveMQDestination result = null;
-            if (destination != null)
-            {
-                if (destination is ActiveMQDestination)
-                {
-                    result = (ActiveMQDestination) destination;
-                }
-                else
-                {
-                    if (destination is ITemporaryQueue)
-                    {
-                        result = new ActiveMQTempQueue(((IQueue) destination).QueueName);
-                    }
-                    else if (destination is ITemporaryTopic)
-                    {
-                        result = new ActiveMQTempTopic(((ITopic) destination).TopicName);
-                    }
-                    else if (destination is IQueue)
-                    {
-                        result = new ActiveMQQueue(((IQueue) destination).QueueName);
-                    }
-                    else if (destination is ITopic)
-                    {
-                        result = new ActiveMQTopic(((ITopic) destination).TopicName);
-                    }
-                }
-            }
-            return result;
-        }
-        
-        /**
-         * Create a Destination
-         * @param type
-         * @param pyhsicalName
-         * @return
-         */
-        public static ActiveMQDestination CreateDestination(int type, String pyhsicalName)
-        {
-            ActiveMQDestination result = null;
-            if (type == ACTIVEMQ_TOPIC)
-            {
-                result = new ActiveMQTopic(pyhsicalName);
-            }
-            else if (type == ACTIVEMQ_TEMPORARY_TOPIC)
-            {
-                result = new ActiveMQTempTopic(pyhsicalName);
-            }
-            else if (type == ACTIVEMQ_QUEUE)
-            {
-                result = new ActiveMQQueue(pyhsicalName);
-            }
-            else
-            {
-                result = new ActiveMQTempQueue(pyhsicalName);
-            }
-            return result;
-        }
-        
-        /**
-         * Create a temporary name from the clientId
-         *
-         * @param clientId
-         * @return
-         */
-        public static String CreateTemporaryName(String clientId)
-        {
-            return TEMP_PREFIX + clientId + TEMP_POSTFIX;
-        }
-        
-        /**
-         * From a temporary destination find the clientId of the Connection that created it
-         *
-         * @param destination
-         * @return the clientId or null if not a temporary destination
-         */
-        public static String GetClientId(ActiveMQDestination destination)
-        {
-            String answer = null;
-            if (destination != null && destination.IsTemporary())
-            {
-                String name = destination.PhysicalName;
-                int start = name.IndexOf(TEMP_PREFIX);
-                if (start >= 0)
-                {
-                    start += TEMP_PREFIX.Length;
-                    int stop = name.LastIndexOf(TEMP_POSTFIX);
-                    if (stop > start && stop < name.Length)
-                    {
-                        answer = name.Substring(start, stop);
-                    }
-                }
-            }
-            return answer;
-        }
-        
-        
-        /**
-         * @param o object to compare
-         * @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o
-         */
-        public int CompareTo(Object o)
-        {
-            if (o is ActiveMQDestination)
-            {
-                return CompareTo((ActiveMQDestination) o);
-            }
-            return -1;
-        }
-        
-        /**
-         * Lets sort by name first then lets sort topics greater than queues
-         *
-         * @param that another destination to compare against
-         * @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o
-         */
-        public int CompareTo(ActiveMQDestination that)
-        {
-            int answer = 0;
-            if (physicalName != that.physicalName)
-            {
-                if (physicalName == null)
-                {
-                    return -1;
-                }
-                else if (that.physicalName == null)
-                {
-                    return 1;
-                }
-                answer = physicalName.CompareTo(that.physicalName);
-            }
-            if (answer == 0)
-            {
-                if (IsTopic())
-                {
-                    if (that.IsQueue())
-                    {
-                        return 1;
-                    }
-                }
-                else
-                {
-                    if (that.IsTopic())
-                    {
-                        return -1;
-                    }
-                }
-            }
-            return answer;
-        }
-        
-        
-        /**
-         * @return Returns the Destination type
-         */
-        
-        public abstract int GetDestinationType();
-        
-        
-        public String PhysicalName
-        {
-            get { return this.physicalName; }
-            set { this.physicalName = value; }
-        }
-        
-        /**
-         * Returns true if a temporary Destination
-         *
-         * @return true/false
-         */
-        
-        public bool IsTemporary()
-        {
-            return GetDestinationType() == ACTIVEMQ_TEMPORARY_TOPIC
-                || GetDestinationType() == ACTIVEMQ_TEMPORARY_QUEUE;
-        }
-        
-        /**
-         * Returns true if a Topic Destination
-         *
-         * @return true/false
-         */
-        
-        public bool IsTopic()
-        {
-            return GetDestinationType() == ACTIVEMQ_TOPIC
-                || GetDestinationType() == ACTIVEMQ_TEMPORARY_TOPIC;
-        }
-        
-        /**
-         * Returns true if a Queue Destination
-         *
-         * @return true/false
-         */
-        public bool IsQueue()
-        {
-            return !IsTopic();
-        }
-        
-        /**
-         * Returns true if this destination represents a collection of
-         * destinations; allowing a set of destinations to be published to or subscribed
-         * from in one JMS operation.
-         * <p/>
-         * If this destination is a composite then you can call {@link #getChildDestinations()}
-         * to return the list of child destinations.
-         *
-         * @return true if this destination represents a collection of child destinations.
-         */
-        public bool IsComposite()
-        {
-            return physicalName.IndexOf(COMPOSITE_SEPARATOR) > 0;
-        }
-        
-        /*
-         * Returns a list of child destinations if this destination represents a composite
-         * destination.
-         *
-         * @return
-         */
-        /*public List GetChildDestinations() {
-         List answer = new ArrayList();
-         StringTokenizer iter = new StringTokenizer(physicalName, COMPOSITE_SEPARATOR);
-         while (iter.hasMoreTokens()) {
-         String name = iter.nextToken();
-         Destination child = null;
-         if (name.StartsWith(QUEUE_PREFIX)) {
-         child = new ActiveMQQueue(name.Substring(QUEUE_PREFIX.Length));
-         }
-         else if (name.StartsWith(TOPIC_PREFIX)) {
-         child = new ActiveMQTopic(name.Substring(TOPIC_PREFIX.Length));
-         }
-         else {
-         child = createDestination(name);
-         }
-         answer.add(child);
-         }
-         if (answer.size() == 1) {
-         // lets put ourselves inside the collection
-         // as we are not really a composite destination
-         answer.set(0, this);
-         }
-         return answer;
-         }*/
-        
-        /**
-         * @return string representation of this instance
-         */
-        
-        public override String ToString()
-        {
-            return this.physicalName;
-        }
-        
-        /**
-         * @return hashCode for this instance
-         */
-        public override int GetHashCode()
-        {
-            int answer = 37;
-            
-            if (this.physicalName != null)
-            {
-                answer = physicalName.GetHashCode();
-            }
-            if (IsTopic())
-            {
-                answer ^= 0xfabfab;
-            }
-            return answer;
-        }
-        
-        /**
-         * if the object passed in is equivalent, return true
-         *
-         * @param obj the object to compare
-         * @return true if this instance and obj are equivalent
-         */
-        public override bool Equals(Object obj)
-        {
-            bool result = this == obj;
-            if (!result && obj != null && obj is ActiveMQDestination)
-            {
-                ActiveMQDestination other = (ActiveMQDestination) obj;
-                result = this.GetDestinationType() == other.GetDestinationType()
-                    && this.physicalName.Equals(other.physicalName);
-            }
-            return result;
-        }
-        
-        
-        /**
-         * @return true if the destination matches multiple possible destinations
-         */
-        public bool IsWildcard()
-        {
-            if (physicalName != null)
-            {
-                return physicalName.IndexOf(DestinationFilter.ANY_CHILD) >= 0
-                    || physicalName.IndexOf(DestinationFilter.ANY_DESCENDENT) >= 0;
-            }
-            return false;
-        }
-        
-        
-        /**
-         * Factory method to create a child destination if this destination is a composite
-         * @param name
-         * @return the created Destination
-         */
-        public abstract ActiveMQDestination CreateDestination(String name);
-    }
-}
-
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 NMS;
+using System;
+namespace ActiveMQ.Commands
+{
+    
+    /// <summary>
+    /// Summary description for ActiveMQDestination.
+    /// </summary>
+    public abstract class ActiveMQDestination : BaseDataStructure, IDestination
+    {
+        
+        /**
+         * Topic Destination object
+         */
+        public const int ACTIVEMQ_TOPIC = 1;
+        /**
+         * Temporary Topic Destination object
+         */
+        public const int ACTIVEMQ_TEMPORARY_TOPIC = 2;
+        
+        /**
+         * Queue Destination object
+         */
+        public const int ACTIVEMQ_QUEUE = 3;
+        /**
+         * Temporary Queue Destination object
+         */
+        public const int ACTIVEMQ_TEMPORARY_QUEUE = 4;
+        
+        /**
+         * prefix for Advisory message destinations
+         */
+        public const String ADVISORY_PREFIX = "ActiveMQ.Advisory.";
+        
+        /**
+         * prefix for consumer advisory destinations
+         */
+        public const String CONSUMER_ADVISORY_PREFIX = ADVISORY_PREFIX + "Consumers.";
+        
+        /**
+         * prefix for producer advisory destinations
+         */
+        public const String PRODUCER_ADVISORY_PREFIX = ADVISORY_PREFIX + "Producers.";
+        
+        /**
+         * prefix for connection advisory destinations
+         */
+        public const String CONNECTION_ADVISORY_PREFIX = ADVISORY_PREFIX + "Connections.";
+        
+        /**
+         * The default target for ordered destinations
+         */
+        public const String DEFAULT_ORDERED_TARGET = "coordinator";
+        
+        private const String TEMP_PREFIX = "{TD{";
+        private const String TEMP_POSTFIX = "}TD}";
+        private const String COMPOSITE_SEPARATOR = ",";
+        
+        private String physicalName = "";
+        
+        // Cached transient data
+        private bool exclusive;
+        private bool ordered;
+        private bool advisory;
+        private String orderedTarget = DEFAULT_ORDERED_TARGET;
+        
+        
+        /**
+         * The Default Constructor
+         */
+        protected ActiveMQDestination()
+        {
+        }
+        
+        /**
+         * Construct the Destination with a defined physical name;
+         *
+         * @param name
+         */
+        protected ActiveMQDestination(String name)
+        {
+            this.physicalName = name;
+            this.advisory = name != null && name.StartsWith(ADVISORY_PREFIX);
+        }
+        
+        
+        
+        /**
+         * @return Returns the advisory.
+         */
+        public bool IsAdvisory()
+        {
+            return advisory;
+        }
+        /**
+         * @param advisory The advisory to set.
+         */
+        public void SetAdvisory(bool advisory)
+        {
+            this.advisory = advisory;
+        }
+        
+        /**
+         * @return true if this is a destination for Consumer advisories
+         */
+        public bool IsConsumerAdvisory()
+        {
+            return IsAdvisory() && physicalName.StartsWith(CONSUMER_ADVISORY_PREFIX);
+        }
+        
+        /**
+         * @return true if this is a destination for Producer advisories
+         */
+        public bool IsProducerAdvisory()
+        {
+            return IsAdvisory() && physicalName.StartsWith(PRODUCER_ADVISORY_PREFIX);
+        }
+        
+        /**
+         * @return true if this is a destination for Connection advisories
+         */
+        public bool IsConnectionAdvisory()
+        {
+            return IsAdvisory() && physicalName.StartsWith(CONNECTION_ADVISORY_PREFIX);
+        }
+        
+        /**
+         * @return Returns the exclusive.
+         */
+        public bool IsExclusive()
+        {
+            return exclusive;
+        }
+        /**
+         * @param exclusive The exclusive to set.
+         */
+        public void SetExclusive(bool exclusive)
+        {
+            this.exclusive = exclusive;
+        }
+        /**
+         * @return Returns the ordered.
+         */
+        public bool IsOrdered()
+        {
+            return ordered;
+        }
+        /**
+         * @param ordered The ordered to set.
+         */
+        public void SetOrdered(bool ordered)
+        {
+            this.ordered = ordered;
+        }
+        /**
+         * @return Returns the orderedTarget.
+         */
+        public String GetOrderedTarget()
+        {
+            return orderedTarget;
+        }
+        /**
+         * @param orderedTarget The orderedTarget to set.
+         */
+        public void SetOrderedTarget(String orderedTarget)
+        {
+            this.orderedTarget = orderedTarget;
+        }
+        /**
+         * A helper method to return a descriptive string for the topic or queue
+         * @param destination
+         *
+         * @return a descriptive string for this queue or topic
+         */
+        public static String Inspect(ActiveMQDestination destination)
+        {
+            if (destination is ITopic)
+            {
+                return "Topic(" + destination.ToString() + ")";
+            }
+            else
+            {
+                return "Queue(" + destination.ToString() + ")";
+            }
+        }
+        
+        /**
+         * @param destination
+         * @return @throws JMSException
+         * @throws javax.jms.JMSException
+         */
+        public static ActiveMQDestination Transform(IDestination destination)
+        {
+            ActiveMQDestination result = null;
+            if (destination != null)
+            {
+                if (destination is ActiveMQDestination)
+                {
+                    result = (ActiveMQDestination) destination;
+                }
+                else
+                {
+                    if (destination is ITemporaryQueue)
+                    {
+                        result = new ActiveMQTempQueue(((IQueue) destination).QueueName);
+                    }
+                    else if (destination is ITemporaryTopic)
+                    {
+                        result = new ActiveMQTempTopic(((ITopic) destination).TopicName);
+                    }
+                    else if (destination is IQueue)
+                    {
+                        result = new ActiveMQQueue(((IQueue) destination).QueueName);
+                    }
+                    else if (destination is ITopic)
+                    {
+                        result = new ActiveMQTopic(((ITopic) destination).TopicName);
+                    }
+                }
+            }
+            return result;
+        }
+        
+        /**
+         * Create a Destination
+         * @param type
+         * @param pyhsicalName
+         * @return
+         */
+        public static ActiveMQDestination CreateDestination(int type, String pyhsicalName)
+        {
+            ActiveMQDestination result = null;
+            if (type == ACTIVEMQ_TOPIC)
+            {
+                result = new ActiveMQTopic(pyhsicalName);
+            }
+            else if (type == ACTIVEMQ_TEMPORARY_TOPIC)
+            {
+                result = new ActiveMQTempTopic(pyhsicalName);
+            }
+            else if (type == ACTIVEMQ_QUEUE)
+            {
+                result = new ActiveMQQueue(pyhsicalName);
+            }
+            else
+            {
+                result = new ActiveMQTempQueue(pyhsicalName);
+            }
+            return result;
+        }
+        
+        /**
+         * Create a temporary name from the clientId
+         *
+         * @param clientId
+         * @return
+         */
+        public static String CreateTemporaryName(String clientId)
+        {
+            return TEMP_PREFIX + clientId + TEMP_POSTFIX;
+        }
+        
+        /**
+         * From a temporary destination find the clientId of the Connection that created it
+         *
+         * @param destination
+         * @return the clientId or null if not a temporary destination
+         */
+        public static String GetClientId(ActiveMQDestination destination)
+        {
+            String answer = null;
+            if (destination != null && destination.IsTemporary())
+            {
+                String name = destination.PhysicalName;
+                int start = name.IndexOf(TEMP_PREFIX);
+                if (start >= 0)
+                {
+                    start += TEMP_PREFIX.Length;
+                    int stop = name.LastIndexOf(TEMP_POSTFIX);
+                    if (stop > start && stop < name.Length)
+                    {
+                        answer = name.Substring(start, stop);
+                    }
+                }
+            }
+            return answer;
+        }
+        
+        
+        /**
+         * @param o object to compare
+         * @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o
+         */
+        public int CompareTo(Object o)
+        {
+            if (o is ActiveMQDestination)
+            {
+                return CompareTo((ActiveMQDestination) o);
+            }
+            return -1;
+        }
+        
+        /**
+         * Lets sort by name first then lets sort topics greater than queues
+         *
+         * @param that another destination to compare against
+         * @return 1 if this is less than o else 0 if they are equal or -1 if this is less than o
+         */
+        public int CompareTo(ActiveMQDestination that)
+        {
+            int answer = 0;
+            if (physicalName != that.physicalName)
+            {
+                if (physicalName == null)
+                {
+                    return -1;
+                }
+                else if (that.physicalName == null)
+                {
+                    return 1;
+                }
+                answer = physicalName.CompareTo(that.physicalName);
+            }
+            if (answer == 0)
+            {
+                if (IsTopic())
+                {
+                    if (that.IsQueue())
+                    {
+                        return 1;
+                    }
+                }
+                else
+                {
+                    if (that.IsTopic())
+                    {
+                        return -1;
+                    }
+                }
+            }
+            return answer;
+        }
+        
+        
+        /**
+         * @return Returns the Destination type
+         */
+        
+        public abstract int GetDestinationType();
+        
+        
+        public String PhysicalName
+        {
+            get { return this.physicalName; }
+            set { this.physicalName = value; }
+        }
+        
+        /**
+         * Returns true if a temporary Destination
+         *
+         * @return true/false
+         */
+        
+        public bool IsTemporary()
+        {
+            return GetDestinationType() == ACTIVEMQ_TEMPORARY_TOPIC
+                || GetDestinationType() == ACTIVEMQ_TEMPORARY_QUEUE;
+        }
+        
+        /**
+         * Returns true if a Topic Destination
+         *
+         * @return true/false
+         */
+        
+        public bool IsTopic()
+        {
+            return GetDestinationType() == ACTIVEMQ_TOPIC
+                || GetDestinationType() == ACTIVEMQ_TEMPORARY_TOPIC;
+        }
+        
+        /**
+         * Returns true if a Queue Destination
+         *
+         * @return true/false
+         */
+        public bool IsQueue()
+        {
+            return !IsTopic();
+        }
+        
+        /**
+         * Returns true if this destination represents a collection of
+         * destinations; allowing a set of destinations to be published to or subscribed
+         * from in one JMS operation.
+         * <p/>
+         * If this destination is a composite then you can call {@link #getChildDestinations()}
+         * to return the list of child destinations.
+         *
+         * @return true if this destination represents a collection of child destinations.
+         */
+        public bool IsComposite()
+        {
+            return physicalName.IndexOf(COMPOSITE_SEPARATOR) > 0;
+        }
+        
+        /*
+         * Returns a list of child destinations if this destination represents a composite
+         * destination.
+         *
+         * @return
+         */
+        /*public List GetChildDestinations() {
+         List answer = new ArrayList();
+         StringTokenizer iter = new StringTokenizer(physicalName, COMPOSITE_SEPARATOR);
+         while (iter.hasMoreTokens()) {
+         String name = iter.nextToken();
+         Destination child = null;
+         if (name.StartsWith(QUEUE_PREFIX)) {
+         child = new ActiveMQQueue(name.Substring(QUEUE_PREFIX.Length));
+         }
+         else if (name.StartsWith(TOPIC_PREFIX)) {
+         child = new ActiveMQTopic(name.Substring(TOPIC_PREFIX.Length));
+         }
+         else {
+         child = createDestination(name);
+         }
+         answer.add(child);
+         }
+         if (answer.size() == 1) {
+         // lets put ourselves inside the collection
+         // as we are not really a composite destination
+         answer.set(0, this);
+         }
+         return answer;
+         }*/
+        
+        /**
+         * @return string representation of this instance
+         */
+        
+        public override String ToString()
+        {
+            return this.physicalName;
+        }
+        
+        /**
+         * @return hashCode for this instance
+         */
+        public override int GetHashCode()
+        {
+            int answer = 37;
+            
+            if (this.physicalName != null)
+            {
+                answer = physicalName.GetHashCode();
+            }
+            if (IsTopic())
+            {
+                answer ^= 0xfabfab;
+            }
+            return answer;
+        }
+        
+        /**
+         * if the object passed in is equivalent, return true
+         *
+         * @param obj the object to compare
+         * @return true if this instance and obj are equivalent
+         */
+        public override bool Equals(Object obj)
+        {
+            bool result = this == obj;
+            if (!result && obj != null && obj is ActiveMQDestination)
+            {
+                ActiveMQDestination other = (ActiveMQDestination) obj;
+                result = this.GetDestinationType() == other.GetDestinationType()
+                    && this.physicalName.Equals(other.physicalName);
+            }
+            return result;
+        }
+        
+        
+        /**
+         * @return true if the destination matches multiple possible destinations
+         */
+        public bool IsWildcard()
+        {
+            if (physicalName != null)
+            {
+                return physicalName.IndexOf(DestinationFilter.ANY_CHILD) >= 0
+                    || physicalName.IndexOf(DestinationFilter.ANY_DESCENDENT) >= 0;
+            }
+            return false;
+        }
+        
+        
+        /**
+         * Factory method to create a child destination if this destination is a composite
+         * @param name
+         * @return the created Destination
+         */
+        public abstract ActiveMQDestination CreateDestination(String name);
+    }
+}
+

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BaseCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BaseCommand.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BaseCommand.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BaseCommand.cs Thu Mar 16 11:45:13 2006
@@ -1,49 +1,122 @@
-//
-// Marshalling code for Open Wire Format for BaseCommand
-//
-//
-// NOTE!: This file is autogenerated - do not modify!
-//        if you need to make a change, please see the Groovy scripts in the
-//        activemq-openwire module
-//
-
-using ActiveMQ.Commands;
-using System;
-
-
-
-namespace ActiveMQ.Commands
-{
-	public abstract class BaseCommand : AbstractCommand
-    {
-        
-        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;
-        }
-        
-        
-    }
-}
-
+//
+// Marshalling code for Open Wire Format for BaseCommand
+//
+//
+// NOTE!: This file is autogenerated - do not modify!
+//        if you need to make a change, please see the Groovy scripts in the
+//        activemq-openwire module
+//
+
+using ActiveMQ.OpenWire;
+using System;
+
+
+
+namespace ActiveMQ.Commands
+{
+    public abstract class BaseCommand : BaseDataStructure, Command
+    {
+        private int commandId;
+        
+        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;
+        }
+        
+    }
+}
+

Added: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BaseDataStructure.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BaseDataStructure.cs?rev=386440&view=auto
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BaseDataStructure.cs (added)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BaseDataStructure.cs Thu Mar 16 11:45:13 2006
@@ -0,0 +1,86 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed 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 ActiveMQ.Commands;
+using System;
+using ActiveMQ.OpenWire;
+
+namespace ActiveMQ.Commands
+{
+    
+    /// <summary>
+    /// Base class for all DataStructure implementations
+    /// </summary>
+    public abstract class BaseDataStructure : DataStructure
+    {
+        private bool responseRequired;
+        
+        public virtual byte GetDataStructureType()
+        {
+            return 0;
+        }
+        
+        public bool ResponseRequired
+        {
+            get { return responseRequired; }
+            set { this.responseRequired = value; }
+        }
+        
+        public virtual bool IsMarshallAware()
+        {
+            return false;
+        }
+        
+        
+        public virtual void BeforeMarshall(OpenWireFormat wireFormat)
+        {
+        }
+        
+        public virtual void AfterMarshall(OpenWireFormat wireFormat)
+        {
+        }
+        
+        public virtual void BeforeUnmarshall(OpenWireFormat wireFormat)
+        {
+        }
+        
+        public virtual void AfterUnmarshall(OpenWireFormat wireFormat)
+        {
+        }
+        
+        public virtual void SetMarshalledForm(OpenWireFormat wireFormat, byte[] data)
+        {
+        }
+        
+        public virtual byte[] GetMarshalledForm(OpenWireFormat wireFormat)
+        {
+            return null;
+        }
+        
+        // Helper methods
+        public int HashCode(object value)
+        {
+            if (value != null)
+            {
+                return value.GetHashCode();
+            }
+            else
+            {
+                return -1;
+            }
+        }
+    }
+}

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BrokerId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BrokerId.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BrokerId.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/BrokerId.cs Thu Mar 16 11:45:13 2006
@@ -1 +1 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ BrokerId Command
	/// 
 </summary>
    public class BrokerId : AbstractCommand, 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; }         
    
        }

    }
}
\ No newline at end of file
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace 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; }       
      
        }

    }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Command.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Command.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Command.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/Command.cs Thu Mar 16 11:45:13 2006
@@ -18,13 +18,13 @@
 
 namespace ActiveMQ.Commands
 {
-	
-	/// <summary>
-	/// An OpenWire command
-	/// </summary>
-	public interface Command : DataStructure
+    
+    /// <summary>
+    /// An OpenWire command
+    /// </summary>
+    public interface Command : DataStructure
     {
-        short CommandId
+        int CommandId
         {
             get;
             set;

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionId.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionId.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConnectionId.cs Thu Mar 16 11:45:13 2006
@@ -1 +1 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ ConnectionId Command
	
 /// </summary>
    public class ConnectionId : AbstractCommand, 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 { th
 is.value = value; }            
        }

    }
}
\ No newline at end of file
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace 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; }            
        }

    }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerId.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerId.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/ConsumerId.cs Thu Mar 16 11:45:13 2006
@@ -1 +1 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ ConsumerId Command
	//
 / </summary>
    public class ConsumerId : AbstractCommand, DataStructure
    {
        public const byte ID_ConsumerId = 122;
    			
        string connectionId;
        long sessionId;
        long 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;

		}
	

		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; }            
        }

    }
}
\ No newline at end of file
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace 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;

		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() {
            retu
 rn 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; }            
        }

    }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/DiscoveryEvent.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/DiscoveryEvent.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/DiscoveryEvent.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/DiscoveryEvent.cs Thu Mar 16 11:45:13 2006
@@ -1 +1 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ DiscoveryEvent Command
 
	/// </summary>
    public class DiscoveryEvent : AbstractCommand, DataStructure
    {
        public const byte ID_DiscoveryEvent = 40;
    			
        string serviceName;
        string brokerName;

		public override string ToString() {
            return GetType().Name + "["
                + " ServiceName=" + ServiceName
                + " BrokerName=" + BrokerName
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_DiscoveryEvent;
        }


        // Properties

        public string ServiceName
        {
            get { return serviceName; }
            set { this.serviceName = value; }            
        }

        public string BrokerName
        {
            get { return brokerName; }
            set { this.brokerName = value; }            
        }

    }
}
\ No newline at end of file
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ DiscoveryEvent Command
 
	/// </summary>
    public class DiscoveryEvent : BaseDataStructure, DataStructure
    {
        public const byte ID_DiscoveryEvent = 40;
    			
        string serviceName;
        string brokerName;

		public override string ToString() {
            return GetType().Name + "["
                + " ServiceName=" + ServiceName
                + " BrokerName=" + BrokerName
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_DiscoveryEvent;
        }


        // Properties

        public string ServiceName
        {
            get { return serviceName; }
            set { this.serviceName = value; }            
        }

        public string BrokerName
        {
            get { return brokerName; }
            set { this.brokerName = value; }            
        }

    }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalQueueAck.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalQueueAck.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalQueueAck.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalQueueAck.cs Thu Mar 16 11:45:13 2006
@@ -1 +1 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ JournalQueueAck Comman
 d
	/// </summary>
    public class JournalQueueAck : AbstractCommand, DataStructure
    {
        public const byte ID_JournalQueueAck = 52;
    			
        ActiveMQDestination destination;
        MessageAck messageAck;

		public override string ToString() {
            return GetType().Name + "["
                + " Destination=" + Destination
                + " MessageAck=" + MessageAck
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_JournalQueueAck;
        }


        // Properties

        public ActiveMQDestination Destination
        {
            get { return destination; }
            set { this.destination = value; }            
        }

        public MessageAck MessageAck
        {
            get { return messageAck; }
            set { this.messageAck = value; }            
        }

    }
}
\ No newline at end of file
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ JournalQueueAck Comman
 d
	/// </summary>
    public class JournalQueueAck : BaseDataStructure, DataStructure
    {
        public const byte ID_JournalQueueAck = 52;
    			
        ActiveMQDestination destination;
        MessageAck messageAck;

		public override string ToString() {
            return GetType().Name + "["
                + " Destination=" + Destination
                + " MessageAck=" + MessageAck
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_JournalQueueAck;
        }


        // Properties

        public ActiveMQDestination Destination
        {
            get { return destination; }
            set { this.destination = value; }            
        }

        public MessageAck MessageAck
        {
            get { return messageAck; }
            set { this.messageAck = value; }            
        }

    }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTopicAck.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTopicAck.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTopicAck.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTopicAck.cs Thu Mar 16 11:45:13 2006
@@ -1 +1 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ JournalTopicAck Comman
 d
	/// </summary>
    public class JournalTopicAck : AbstractCommand, DataStructure
    {
        public const byte ID_JournalTopicAck = 50;
    			
        ActiveMQDestination destination;
        MessageId messageId;
        long messageSequenceId;
        string subscritionName;
        string clientId;
        TransactionId transactionId;

		public override string ToString() {
            return GetType().Name + "["
                + " Destination=" + Destination
                + " MessageId=" + MessageId
                + " MessageSequenceId=" + MessageSequenceId
                + " SubscritionName=" + SubscritionName
                + " ClientId=" + ClientId
                + " TransactionId=" + TransactionId
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_JournalTopicAck;
        }


        // Properties

        public ActiveMQDestination Destination
        {
            get { return destination; }
     
        set { this.destination = value; }            
        }

        public MessageId MessageId
        {
            get { return messageId; }
            set { this.messageId = value; }            
        }

        public long MessageSequenceId
        {
            get { return messageSequenceId; }
            set { this.messageSequenceId = value; }            
        }

        public string SubscritionName
        {
            get { return subscritionName; }
            set { this.subscritionName = value; }            
        }

        public string ClientId
        {
            get { return clientId; }
            set { this.clientId = value; }            
        }

        public TransactionId TransactionId
        {
            get { return transactionId; }
            set { this.transactionId = value; }            
        }

    }
}
\ No newline at end of file
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ JournalTopicAck Comman
 d
	/// </summary>
    public class JournalTopicAck : BaseDataStructure, DataStructure
    {
        public const byte ID_JournalTopicAck = 50;
    			
        ActiveMQDestination destination;
        MessageId messageId;
        long messageSequenceId;
        string subscritionName;
        string clientId;
        TransactionId transactionId;

		public override string ToString() {
            return GetType().Name + "["
                + " Destination=" + Destination
                + " MessageId=" + MessageId
                + " MessageSequenceId=" + MessageSequenceId
                + " SubscritionName=" + SubscritionName
                + " ClientId=" + ClientId
                + " TransactionId=" + TransactionId
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_JournalTopicAck;
        }


        // Properties

        public ActiveMQDestination Destination
        {
            get { return destination; }
   
          set { this.destination = value; }            
        }

        public MessageId MessageId
        {
            get { return messageId; }
            set { this.messageId = value; }            
        }

        public long MessageSequenceId
        {
            get { return messageSequenceId; }
            set { this.messageSequenceId = value; }            
        }

        public string SubscritionName
        {
            get { return subscritionName; }
            set { this.subscritionName = value; }            
        }

        public string ClientId
        {
            get { return clientId; }
            set { this.clientId = value; }            
        }

        public TransactionId TransactionId
        {
            get { return transactionId; }
            set { this.transactionId = value; }            
        }

    }
}
\ No newline at end of file

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTrace.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTrace.cs?rev=386440&r1=386439&r2=386440&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTrace.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Commands/JournalTrace.cs Thu Mar 16 11:45:13 2006
@@ -1 +1 @@
-/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ JournalTrace Command
	
 /// </summary>
    public class JournalTrace : AbstractCommand, DataStructure
    {
        public const byte ID_JournalTrace = 53;
    			
        string message;

		public override string ToString() {
            return GetType().Name + "["
                + " Message=" + Message
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_JournalTrace;
        }


        // Properties

        public string Message
        {
            get { return message; }
            set { this.message = value; }            
        }

    }
}
\ No newline at end of file
+/*
* Copyright 2006 The Apache Software Foundation or its licensors, as
* applicable.
*
* Licensed 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.
*/

//
//  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 ActiveMQ.OpenWire;
using ActiveMQ.Commands;

namespace ActiveMQ.Commands
{
	/// <summary>
    ///  The ActiveMQ JournalTrace Command
	
 /// </summary>
    public class JournalTrace : BaseDataStructure, DataStructure
    {
        public const byte ID_JournalTrace = 53;
    			
        string message;

		public override string ToString() {
            return GetType().Name + "["
                + " Message=" + Message
                + " ]";

		}
	


        public override byte GetDataStructureType() {
            return ID_JournalTrace;
        }


        // Properties

        public string Message
        {
            get { return message; }
            set { this.message = value; }            
        }

    }
}
\ No newline at end of file



Mime
View raw message