activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r367311 [1/2] - in /incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core: ./ Commands/ IO/
Date Mon, 09 Jan 2006 15:01:23 GMT
Author: jstrachan
Date: Mon Jan  9 07:00:36 2006
New Revision: 367311

URL: http://svn.apache.org/viewcvs?rev=367311&view=rev
Log:
latest generated openwire.net code which now compiles OK!

Added:
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs   (with props)
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs   (with props)
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempQueue.cs   (with props)
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs   (with props)
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DiscoveryEvent.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryTopic.cs   (with props)
Removed:
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQDestination.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempDestination.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTempTopic.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTopic.cs
Modified:
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DestinationInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ExceptionResponse.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/FlushCommand.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/IntegerResponse.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalQueueAck.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTopicAck.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTrace.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTransaction.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/KeepAliveInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/LocalTransactionId.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Message.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageAck.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageDispatch.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageId.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerId.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveSubscriptionInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Response.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionId.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ShutdownInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SubscriptionInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionId.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/WireFormatInfo.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/XATransactionId.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DataStructure.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempDestinationMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BaseCommandMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/CommandMarshallerRegistry.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/DataResponseMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ExceptionResponseMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTopicAckMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/JournalTransactionMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageAckMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageDispatchMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/MessageMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/RemoveInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionIdMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/TransactionInfoMarshaller.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Queue.cs
    incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Topic.cs

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommand.cs Mon Jan  9 07:00:36 2006
@@ -23,7 +23,7 @@
 			
 		}
 		
-         public virtual int GetCommandType()
+         public virtual byte GetCommandType()
          {
          	    return 0;
  	    }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/AbstractCommandMarshaller.cs Mon Jan  9 07:00:36 2006
@@ -23,10 +23,22 @@
         
         public virtual void BuildCommand(Command command, BinaryReader dataIn) 
         {
+        		// empty body to allow generated code to call base method
         }
         
         public virtual void WriteCommand(Command command, BinaryWriter dataOut)
         {
+        		// empty body to allow generated code to call base method
+        }
+        
+        protected virtual ActiveMQDestination ReadDestination(BinaryReader dataIn)
+        {
+        		return (ActiveMQDestination) CommandMarshallerRegistry.ReadCommand(dataIn);
+        }
+        
+        protected virtual void WriteDestination(ActiveMQDestination command, BinaryWriter dataOut)
+        {
+        		CommandMarshallerRegistry.WriteCommand(command, dataOut);
         }
         
         protected virtual BrokerId[] ReadBrokerIds(BinaryReader dataIn)

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs?rev=367311&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs Mon Jan  9 07:00:36 2006
@@ -0,0 +1,463 @@
+using System;
+using OpenWire.Core.Commands;
+
+namespace OpenWire.Core
+{
+	/// <summary>
+	/// Summary description for ActiveMQDestination.
+	/// </summary>
+	public abstract class ActiveMQDestination : AbstractCommand, Destination {
+
+    /**
+     * 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 Topic) {
+            return "Topic(" + destination.ToString() + ")";
+        }
+        else {
+            return "Queue(" + destination.ToString() + ")";
+        }
+    }
+
+    /**
+     * @param destination
+     * @return @throws JMSException
+     * @throws javax.jms.JMSException
+     */
+    public static ActiveMQDestination transformDestination(Destination destination) {
+        ActiveMQDestination result = null;
+        if (destination != null) {
+            if (destination is ActiveMQDestination) {
+                result = (ActiveMQDestination) destination;
+            }
+            else {
+                if (destination is TemporaryQueue) {
+                    result = new ActiveMQTempQueue(((Queue) destination).QueueName);
+                }
+                else if (destination is TemporaryTopic) {
+                    result = new ActiveMQTempTopic(((Topic) destination).TopicName);
+                }
+                else if (destination is Queue) {
+                    result = new ActiveMQQueue(((Queue) destination).QueueName);
+                }
+                else if (destination is Topic) {
+                    result = new ActiveMQTopic(((Topic) 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);
+
+    
+}
+
+}

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQDestination.cs
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs?rev=367311&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs Mon Jan  9 07:00:36 2006
@@ -0,0 +1,32 @@
+using System;
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+
+namespace OpenWire.Core
+{
+	/// <summary>
+	/// Summary description for ActiveMQQueue.
+	/// </summary>
+	public class ActiveMQQueue : ActiveMQDestination, Queue 
+	{
+		public const byte ID_ActiveMQQueue = 100;
+		
+		public ActiveMQQueue() : base(){}
+		public ActiveMQQueue(String name) : base(name){}
+		
+		public String QueueName
+		{
+			get {
+				return PhysicalName;
+			}
+		}
+		
+		public override int GetDestinationType() {
+			return ACTIVEMQ_QUEUE;
+		}
+
+		public override ActiveMQDestination CreateDestination(String name) {
+			return new ActiveMQQueue(name);
+		}
+	}
+}
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQQueue.cs
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempQueue.cs?rev=367311&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempQueue.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempQueue.cs Mon Jan  9 07:00:36 2006
@@ -0,0 +1,29 @@
+using System;
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+
+namespace OpenWire.Core
+{
+	/// <summary>
+	/// Summary description for ActiveMQTempQueue.
+	/// </summary>
+	public class ActiveMQTempQueue : ActiveMQDestination, TemporaryQueue
+	{
+		public const byte ID_ActiveMQTempQueue = 102;
+		
+		public ActiveMQTempQueue() : base(){}
+		public ActiveMQTempQueue(String name) : base(name){}
+		
+		public String GetQueueName() {
+			return PhysicalName;
+		}
+		
+		public override int GetDestinationType() {
+			return ACTIVEMQ_QUEUE;
+		}
+
+		public override ActiveMQDestination CreateDestination(String name) {
+			return new ActiveMQTempQueue(name);
+		}
+	}
+}
\ No newline at end of file

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTempQueue.cs
------------------------------------------------------------------------------
    svn:executable = *

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs?rev=367311&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs Mon Jan  9 07:00:36 2006
@@ -0,0 +1,35 @@
+using System;
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+
+namespace OpenWire.Core
+{
+	/// <summary>
+	/// Summary description for ActiveMQTopic.
+	/// </summary>
+	public class ActiveMQTopic : ActiveMQDestination, Topic
+	{
+		public const byte ID_ActiveMQTopic = 101;
+		
+		public ActiveMQTopic(): base()	{}
+		public ActiveMQTopic(String name):base(name){}
+		
+		public String TopicName
+		{
+			get {
+				return PhysicalName;
+			}
+		}
+		
+		public override int GetDestinationType() 
+		{
+			return ACTIVEMQ_TOPIC;
+		}
+
+		public override ActiveMQDestination CreateDestination(String name) 
+		{
+			return new ActiveMQTopic(name);
+		}
+
+	}
+}

Propchange: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/ActiveMQTopic.cs
------------------------------------------------------------------------------
    svn:executable = *

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Command.cs Mon Jan  9 07:00:36 2006
@@ -5,10 +5,8 @@
 	/// <summary>
 	/// An OpenWire command
 	/// </summary>
-	public interface Command {
+	public interface Command : DataStructure {
 	
-        int GetCommandType();
-        
 	}
 }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQBytesMessage.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class ActiveMQBytesMessage : ActiveMQMessage
     {
-    			public const int ID_ActiveMQBytesMessage = 1;
+    			public const byte ID_ActiveMQBytesMessage = 24;
     			
 
 
@@ -26,7 +26,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ActiveMQBytesMessage;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMapMessage.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class ActiveMQMapMessage : ActiveMQMessage
     {
-    			public const int ID_ActiveMQMapMessage = 1;
+    			public const byte ID_ActiveMQMapMessage = 25;
     			
 
 
@@ -26,7 +26,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ActiveMQMapMessage;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQMessage.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class ActiveMQMessage : AbstractCommand
+    public class ActiveMQMessage : Message
     {
-    			public const int ID_ActiveMQMessage = 1;
+    			public const byte ID_ActiveMQMessage = 23;
     			
 
 
@@ -26,7 +26,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ActiveMQMessage;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQObjectMessage.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class ActiveMQObjectMessage : ActiveMQMessage
     {
-    			public const int ID_ActiveMQObjectMessage = 1;
+    			public const byte ID_ActiveMQObjectMessage = 26;
     			
 
 
@@ -26,7 +26,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ActiveMQObjectMessage;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQStreamMessage.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class ActiveMQStreamMessage : ActiveMQMessage
     {
-    			public const int ID_ActiveMQStreamMessage = 1;
+    			public const byte ID_ActiveMQStreamMessage = 27;
     			
 
 
@@ -26,7 +26,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ActiveMQStreamMessage;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ActiveMQTextMessage.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class ActiveMQTextMessage : ActiveMQMessage
     {
-    			public const int ID_ActiveMQTextMessage = 1;
+    			public const byte ID_ActiveMQTextMessage = 28;
     			
 
 
@@ -26,7 +26,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ActiveMQTextMessage;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BaseCommand.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class BaseCommand : AbstractCommand
     {
-    			public const int ID_BaseCommand = 1;
+    			public const byte ID_BaseCommand = 0;
     			
         short commandId;
         bool responseRequired;
@@ -28,7 +28,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_BaseCommand;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerId.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class BrokerId : AbstractCommand
     {
-    			public const int ID_BrokerId = 1;
+    			public const byte ID_BrokerId = 124;
     			
         string brokerId;
 
@@ -27,7 +27,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_BrokerId;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/BrokerInfo.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class BrokerInfo : AbstractCommand
+    public class BrokerInfo : BaseCommand
     {
-    			public const int ID_BrokerInfo = 1;
+    			public const byte ID_BrokerInfo = 2;
     			
         BrokerId brokerId;
         string brokerURL;
@@ -30,7 +30,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_BrokerInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionId.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class ConnectionId : AbstractCommand
     {
-    			public const int ID_ConnectionId = 1;
+    			public const byte ID_ConnectionId = 120;
     			
         string connectionId;
 
@@ -27,7 +27,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ConnectionId;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConnectionInfo.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class ConnectionInfo : AbstractCommand
+    public class ConnectionInfo : BaseCommand
     {
-    			public const int ID_ConnectionInfo = 1;
+    			public const byte ID_ConnectionInfo = 3;
     			
         ConnectionId connectionId;
         string clientId;
@@ -31,7 +31,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ConnectionInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerId.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class ConsumerId : AbstractCommand
     {
-    			public const int ID_ConsumerId = 1;
+    			public const byte ID_ConsumerId = 122;
     			
         string connectionId;
         long sessionId;
@@ -29,7 +29,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ConsumerId;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ConsumerInfo.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class ConsumerInfo : AbstractCommand
+    public class ConsumerInfo : BaseCommand
     {
-    			public const int ID_ConsumerInfo = 1;
+    			public const byte ID_ConsumerInfo = 5;
     			
         ConsumerId consumerId;
         bool browser;
@@ -39,7 +39,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ConsumerInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ControlCommand.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class ControlCommand : AbstractCommand
+    public class ControlCommand : BaseCommand
     {
-    			public const int ID_ControlCommand = 1;
+    			public const byte ID_ControlCommand = 14;
     			
         string command;
 
@@ -27,7 +27,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ControlCommand;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataArrayResponse.cs Mon Jan  9 07:00:36 2006
@@ -14,11 +14,11 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class DataArrayResponse : AbstractCommand
+    public class DataArrayResponse : Response
     {
-    			public const int ID_DataArrayResponse = 1;
+    			public const byte ID_DataArrayResponse = 33;
     			
-        Command[] data;
+        DataStructure[] data;
 
 
 
@@ -27,14 +27,14 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_DataArrayResponse;
         }
 
 
         // Properties
 
-        public Command[] Data
+        public DataStructure[] Data
         {
             get
             {

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DataResponse.cs Mon Jan  9 07:00:36 2006
@@ -14,11 +14,11 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class DataResponse : AbstractCommand
+    public class DataResponse : Response
     {
-    			public const int ID_DataResponse = 1;
+    			public const byte ID_DataResponse = 32;
     			
-        Command data;
+        DataStructure data;
 
 
 
@@ -27,14 +27,14 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_DataResponse;
         }
 
 
         // Properties
 
-        public Command Data
+        public DataStructure Data
         {
             get
             {

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DestinationInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DestinationInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DestinationInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DestinationInfo.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class DestinationInfo : AbstractCommand
+    public class DestinationInfo : BaseCommand
     {
-    			public const int ID_DestinationInfo = 1;
+    			public const byte ID_DestinationInfo = 8;
     			
         ConnectionId connectionId;
         ActiveMQDestination destination;
@@ -31,7 +31,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_DestinationInfo;
         }
 

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DiscoveryEvent.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DiscoveryEvent.cs?rev=367311&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DiscoveryEvent.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DiscoveryEvent.cs Mon Jan  9 07:00:36 2006
@@ -0,0 +1,63 @@
+//
+// Marshalling code for Open Wire Format for DiscoveryEvent
+//
+//
+// 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 System;
+using System.Collections;
+
+using OpenWire.Core;
+
+namespace OpenWire.Core.Commands
+{
+    public class DiscoveryEvent : AbstractCommand
+    {
+    			public const byte ID_DiscoveryEvent = 40;
+    			
+        string serviceName;
+        string brokerName;
+
+
+
+        // TODO generate Equals method
+        // TODO generate GetHashCode method
+        // TODO generate ToString method
+
+
+        public override byte GetCommandType() {
+            return ID_DiscoveryEvent;
+        }
+
+
+        // Properties
+
+        public string ServiceName
+        {
+            get
+            {
+                return serviceName;
+            }
+            set
+            {
+                serviceName = value;
+            }            
+        }
+
+        public string BrokerName
+        {
+            get
+            {
+                return brokerName;
+            }
+            set
+            {
+                brokerName = value;
+            }            
+        }
+
+    }
+}

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ExceptionResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ExceptionResponse.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ExceptionResponse.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ExceptionResponse.cs Mon Jan  9 07:00:36 2006
@@ -14,11 +14,11 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class ExceptionResponse : AbstractCommand
+    public class ExceptionResponse : Response
     {
-    			public const int ID_ExceptionResponse = 1;
+    			public const byte ID_ExceptionResponse = 31;
     			
-        string exception;
+        byte[] exception;
 
 
 
@@ -27,14 +27,14 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ExceptionResponse;
         }
 
 
         // Properties
 
-        public string Exception
+        public byte[] Exception
         {
             get
             {

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/FlushCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/FlushCommand.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/FlushCommand.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/FlushCommand.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class FlushCommand : AbstractCommand
+    public class FlushCommand : BaseCommand
     {
-    			public const int ID_FlushCommand = 1;
+    			public const byte ID_FlushCommand = 15;
     			
 
 
@@ -26,7 +26,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_FlushCommand;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/IntegerResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/IntegerResponse.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/IntegerResponse.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/IntegerResponse.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class IntegerResponse : AbstractCommand
+    public class IntegerResponse : Response
     {
-    			public const int ID_IntegerResponse = 1;
+    			public const byte ID_IntegerResponse = 34;
     			
         int result;
 
@@ -27,7 +27,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_IntegerResponse;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalQueueAck.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalQueueAck.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalQueueAck.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalQueueAck.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class JournalQueueAck : AbstractCommand
     {
-    			public const int ID_JournalQueueAck = 1;
+    			public const byte ID_JournalQueueAck = 52;
     			
         ActiveMQDestination destination;
         MessageAck messageAck;
@@ -28,7 +28,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_JournalQueueAck;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTopicAck.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTopicAck.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTopicAck.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTopicAck.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class JournalTopicAck : AbstractCommand
     {
-    			public const int ID_JournalTopicAck = 1;
+    			public const byte ID_JournalTopicAck = 50;
     			
         ActiveMQDestination destination;
         MessageId messageId;
@@ -32,7 +32,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_JournalTopicAck;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTrace.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTrace.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTrace.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTrace.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class JournalTrace : AbstractCommand
     {
-    			public const int ID_JournalTrace = 1;
+    			public const byte ID_JournalTrace = 53;
     			
         string message;
 
@@ -27,7 +27,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_JournalTrace;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTransaction.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTransaction.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTransaction.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTransaction.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class JournalTransaction : AbstractCommand
     {
-    			public const int ID_JournalTransaction = 1;
+    			public const byte ID_JournalTransaction = 54;
     			
         TransactionId transactionId;
         byte type;
@@ -29,7 +29,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_JournalTransaction;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/KeepAliveInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/KeepAliveInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/KeepAliveInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/KeepAliveInfo.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class KeepAliveInfo : AbstractCommand
     {
-    			public const int ID_KeepAliveInfo = 1;
+    			public const byte ID_KeepAliveInfo = 10;
     			
 
 
@@ -26,7 +26,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_KeepAliveInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/LocalTransactionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/LocalTransactionId.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/LocalTransactionId.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/LocalTransactionId.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class LocalTransactionId : AbstractCommand
+    public class LocalTransactionId : TransactionId
     {
-    			public const int ID_LocalTransactionId = 1;
+    			public const byte ID_LocalTransactionId = 111;
     			
         long transactionId;
         ConnectionId connectionId;
@@ -28,7 +28,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_LocalTransactionId;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Message.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Message.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Message.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Message.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class Message : AbstractCommand
+    public class Message : BaseCommand
     {
-    			public const int ID_Message = 1;
+    			public const byte ID_Message = 0;
     			
         ProducerId producerId;
         ActiveMQDestination destination;
@@ -35,7 +35,7 @@
         string type;
         byte[] content;
         byte[] marshalledProperties;
-        Command dataStructure;
+        DataStructure dataStructure;
         ConsumerId targetConsumerId;
         bool compressed;
         int redeliveryCounter;
@@ -51,7 +51,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_Message;
         }
 
@@ -262,7 +262,7 @@
             }            
         }
 
-        public Command DataStructure
+        public DataStructure DataStructure
         {
             get
             {

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageAck.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageAck.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageAck.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageAck.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class MessageAck : AbstractCommand
+    public class MessageAck : BaseCommand
     {
-    			public const int ID_MessageAck = 1;
+    			public const byte ID_MessageAck = 22;
     			
         ActiveMQDestination destination;
         TransactionId transactionId;
@@ -33,7 +33,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_MessageAck;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageDispatch.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageDispatch.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageDispatch.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageDispatch.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class MessageDispatch : AbstractCommand
+    public class MessageDispatch : BaseCommand
     {
-    			public const int ID_MessageDispatch = 1;
+    			public const byte ID_MessageDispatch = 21;
     			
         ConsumerId consumerId;
         ActiveMQDestination destination;
@@ -30,7 +30,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_MessageDispatch;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageId.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageId.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageId.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class MessageId : AbstractCommand
     {
-    			public const int ID_MessageId = 1;
+    			public const byte ID_MessageId = 110;
     			
         ProducerId producerId;
         long producerSequenceId;
@@ -29,7 +29,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_MessageId;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerId.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerId.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerId.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class ProducerId : AbstractCommand
     {
-    			public const int ID_ProducerId = 1;
+    			public const byte ID_ProducerId = 123;
     			
         string connectionId;
         long producerId;
@@ -29,7 +29,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ProducerId;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerInfo.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class ProducerInfo : AbstractCommand
+    public class ProducerInfo : BaseCommand
     {
-    			public const int ID_ProducerInfo = 1;
+    			public const byte ID_ProducerInfo = 6;
     			
         ProducerId producerId;
         ActiveMQDestination destination;
@@ -29,7 +29,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ProducerInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveInfo.cs Mon Jan  9 07:00:36 2006
@@ -14,11 +14,11 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class RemoveInfo : AbstractCommand
+    public class RemoveInfo : BaseCommand
     {
-    			public const int ID_RemoveInfo = 1;
+    			public const byte ID_RemoveInfo = 12;
     			
-        Command objectId;
+        DataStructure objectId;
 
 
 
@@ -27,14 +27,14 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_RemoveInfo;
         }
 
 
         // Properties
 
-        public Command ObjectId
+        public DataStructure ObjectId
         {
             get
             {

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveSubscriptionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveSubscriptionInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveSubscriptionInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveSubscriptionInfo.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class RemoveSubscriptionInfo : AbstractCommand
+    public class RemoveSubscriptionInfo : BaseCommand
     {
-    			public const int ID_RemoveSubscriptionInfo = 1;
+    			public const byte ID_RemoveSubscriptionInfo = 0;
     			
         ConnectionId connectionId;
         string subcriptionName;
@@ -29,7 +29,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_RemoveSubscriptionInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Response.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Response.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Response.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Response.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class Response : AbstractCommand
+    public class Response : BaseCommand
     {
-    			public const int ID_Response = 1;
+    			public const byte ID_Response = 30;
     			
         short correlationId;
 
@@ -27,7 +27,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_Response;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionId.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionId.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionId.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class SessionId : AbstractCommand
     {
-    			public const int ID_SessionId = 1;
+    			public const byte ID_SessionId = 121;
     			
         string connectionId;
         long sessionId;
@@ -28,7 +28,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_SessionId;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionInfo.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class SessionInfo : AbstractCommand
+    public class SessionInfo : BaseCommand
     {
-    			public const int ID_SessionInfo = 1;
+    			public const byte ID_SessionInfo = 4;
     			
         SessionId sessionId;
 
@@ -27,7 +27,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_SessionInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ShutdownInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ShutdownInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ShutdownInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ShutdownInfo.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class ShutdownInfo : AbstractCommand
+    public class ShutdownInfo : BaseCommand
     {
-    			public const int ID_ShutdownInfo = 1;
+    			public const byte ID_ShutdownInfo = 11;
     			
 
 
@@ -26,7 +26,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_ShutdownInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SubscriptionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SubscriptionInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SubscriptionInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SubscriptionInfo.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class SubscriptionInfo : AbstractCommand
     {
-    			public const int ID_SubscriptionInfo = 1;
+    			public const byte ID_SubscriptionInfo = 55;
     			
         string clientId;
         ActiveMQDestination destination;
@@ -30,7 +30,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_SubscriptionInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionId.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionId.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionId.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class TransactionId : AbstractCommand
     {
-    			public const int ID_TransactionId = 1;
+    			public const byte ID_TransactionId = 0;
     			
 
 
@@ -26,7 +26,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_TransactionId;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionInfo.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class TransactionInfo : AbstractCommand
+    public class TransactionInfo : BaseCommand
     {
-    			public const int ID_TransactionInfo = 1;
+    			public const byte ID_TransactionInfo = 7;
     			
         ConnectionId connectionId;
         TransactionId transactionId;
@@ -29,7 +29,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_TransactionInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/WireFormatInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/WireFormatInfo.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/WireFormatInfo.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/WireFormatInfo.cs Mon Jan  9 07:00:36 2006
@@ -16,7 +16,7 @@
 {
     public class WireFormatInfo : AbstractCommand
     {
-    			public const int ID_WireFormatInfo = 1;
+    			public const byte ID_WireFormatInfo = 1;
     			
         byte[] magic;
         int version;
@@ -29,7 +29,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_WireFormatInfo;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/XATransactionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/XATransactionId.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/XATransactionId.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/XATransactionId.cs Mon Jan  9 07:00:36 2006
@@ -14,9 +14,9 @@
 
 namespace OpenWire.Core.Commands
 {
-    public class XATransactionId : AbstractCommand
+    public class XATransactionId : TransactionId
     {
-    			public const int ID_XATransactionId = 1;
+    			public const byte ID_XATransactionId = 112;
     			
         int formatId;
         byte[] globalTransactionId;
@@ -29,7 +29,7 @@
         // TODO generate ToString method
 
 
-        public override int GetCommandType() {
+        public override byte GetCommandType() {
             return ID_XATransactionId;
         }
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DataStructure.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DataStructure.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DataStructure.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DataStructure.cs Mon Jan  9 07:00:36 2006
@@ -7,7 +7,7 @@
 	/// </summary>
 	public interface DataStructure {
 	
-        int GetCommandType();
+        byte GetCommandType();
         
 	}
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs Mon Jan  9 07:00:36 2006
@@ -13,7 +13,7 @@
 
 		public bool matches(ActiveMQMessage message) 
 		{
-			return matches(message.getJMSDestination());
+			return matches(message.Destination);
 		}
 
 		public abstract bool matches(ActiveMQDestination destination);

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempDestinationMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempDestinationMarshaller.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempDestinationMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempDestinationMarshaller.cs Mon Jan  9 07:00:36 2006
@@ -17,13 +17,9 @@
 
 namespace OpenWire.Core.IO
 {
-    public class ActiveMQTempDestinationMarshaller : AbstractCommandMarshaller
+    public abstract class ActiveMQTempDestinationMarshaller : AbstractCommandMarshaller
     {
 
-
-        public override Command CreateCommand() {
-            return new ActiveMQTempDestination();
-        }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
             base.BuildCommand(command, dataIn);

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BaseCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BaseCommandMarshaller.cs?rev=367311&r1=367310&r2=367311&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BaseCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BaseCommandMarshaller.cs Mon Jan  9 07:00:36 2006
@@ -17,13 +17,9 @@
 
 namespace OpenWire.Core.IO
 {
-    public class BaseCommandMarshaller : AbstractCommandMarshaller
+    public abstract class BaseCommandMarshaller : AbstractCommandMarshaller
     {
 
-
-        public override Command CreateCommand() {
-            return new BaseCommand();
-        }
 
         public override void BuildCommand(Command command, BinaryReader dataIn) {
             base.BuildCommand(command, dataIn);



Mime
View raw message