You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/01/09 16:01:23 UTC
svn commit: r367311 [1/2] - in
/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core: ./ Commands/ IO/
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);