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/06 18:24:39 UTC
svn commit: r366537 [2/3] - in /incubator/activemq/trunk/openwire-dotnet: ./
src/ src/OpenWire.Core/ src/OpenWire.Core/Commands/ src/OpenWire.Core/IO/
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DestinationInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/DestinationInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,101 @@
+//
+// Marshalling code for Open Wire Format for DestinationInfo
+//
+//
+// 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 DestinationInfo : AbstractCommand
+ {
+ ConnectionId connectionId;
+ ActiveMQDestination destination;
+ byte operationType;
+ long timeout;
+ BrokerId[] brokerPath;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ConnectionId ConnectionId
+ {
+ get
+ {
+ return connectionId;
+ }
+ set
+ {
+ connectionId = value;
+ }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get
+ {
+ return destination;
+ }
+ set
+ {
+ destination = value;
+ }
+ }
+
+ public byte OperationType
+ {
+ get
+ {
+ return operationType;
+ }
+ set
+ {
+ operationType = value;
+ }
+ }
+
+ public long Timeout
+ {
+ get
+ {
+ return timeout;
+ }
+ set
+ {
+ timeout = value;
+ }
+ }
+
+ public BrokerId[] BrokerPath
+ {
+ get
+ {
+ return brokerPath;
+ }
+ set
+ {
+ brokerPath = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ExceptionResponse.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ExceptionResponse.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for ExceptionResponse
+//
+//
+// 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 ExceptionResponse : AbstractCommand
+ {
+ string exception;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public string Exception
+ {
+ get
+ {
+ return exception;
+ }
+ set
+ {
+ exception = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/FlushCommand.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/FlushCommand.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for FlushCommand
+//
+//
+// 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 FlushCommand : AbstractCommand
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/IntegerResponse.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/IntegerResponse.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for IntegerResponse
+//
+//
+// 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 IntegerResponse : AbstractCommand
+ {
+ int result;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public int Result
+ {
+ get
+ {
+ return result;
+ }
+ set
+ {
+ result = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalQueueAck.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalQueueAck.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,62 @@
+//
+// Marshalling code for Open Wire Format for JournalQueueAck
+//
+//
+// 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 JournalQueueAck : AbstractCommand
+ {
+ ActiveMQDestination destination;
+ MessageAck messageAck;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ActiveMQDestination Destination
+ {
+ get
+ {
+ return destination;
+ }
+ set
+ {
+ destination = value;
+ }
+ }
+
+ public MessageAck MessageAck
+ {
+ get
+ {
+ return messageAck;
+ }
+ set
+ {
+ messageAck = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTopicAck.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTopicAck.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,114 @@
+//
+// Marshalling code for Open Wire Format for JournalTopicAck
+//
+//
+// 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 JournalTopicAck : AbstractCommand
+ {
+ ActiveMQDestination destination;
+ MessageId messageId;
+ long messageSequenceId;
+ string subscritionName;
+ string clientId;
+ TransactionId transactionId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ActiveMQDestination Destination
+ {
+ get
+ {
+ return destination;
+ }
+ set
+ {
+ destination = value;
+ }
+ }
+
+ public MessageId MessageId
+ {
+ get
+ {
+ return messageId;
+ }
+ set
+ {
+ messageId = value;
+ }
+ }
+
+ public long MessageSequenceId
+ {
+ get
+ {
+ return messageSequenceId;
+ }
+ set
+ {
+ messageSequenceId = value;
+ }
+ }
+
+ public string SubscritionName
+ {
+ get
+ {
+ return subscritionName;
+ }
+ set
+ {
+ subscritionName = value;
+ }
+ }
+
+ public string ClientId
+ {
+ get
+ {
+ return clientId;
+ }
+ set
+ {
+ clientId = value;
+ }
+ }
+
+ public TransactionId TransactionId
+ {
+ get
+ {
+ return transactionId;
+ }
+ set
+ {
+ transactionId = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTrace.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTrace.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for JournalTrace
+//
+//
+// 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 JournalTrace : AbstractCommand
+ {
+ string message;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public string Message
+ {
+ get
+ {
+ return message;
+ }
+ set
+ {
+ message = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTransaction.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/JournalTransaction.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,75 @@
+//
+// Marshalling code for Open Wire Format for JournalTransaction
+//
+//
+// 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 JournalTransaction : AbstractCommand
+ {
+ TransactionId transactionId;
+ byte type;
+ bool wasPrepared;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public TransactionId TransactionId
+ {
+ get
+ {
+ return transactionId;
+ }
+ set
+ {
+ transactionId = value;
+ }
+ }
+
+ public byte Type
+ {
+ get
+ {
+ return type;
+ }
+ set
+ {
+ type = value;
+ }
+ }
+
+ public bool WasPrepared
+ {
+ get
+ {
+ return wasPrepared;
+ }
+ set
+ {
+ wasPrepared = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/KeepAliveInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/KeepAliveInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for KeepAliveInfo
+//
+//
+// 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 KeepAliveInfo : AbstractCommand
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/LocalTransactionId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/LocalTransactionId.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,62 @@
+//
+// Marshalling code for Open Wire Format for LocalTransactionId
+//
+//
+// 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 LocalTransactionId : AbstractCommand
+ {
+ long transactionId;
+ ConnectionId connectionId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public long TransactionId
+ {
+ get
+ {
+ return transactionId;
+ }
+ set
+ {
+ transactionId = value;
+ }
+ }
+
+ public ConnectionId ConnectionId
+ {
+ get
+ {
+ return connectionId;
+ }
+ set
+ {
+ connectionId = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Message.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Message.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,361 @@
+//
+// Marshalling code for Open Wire Format for Message
+//
+//
+// 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 Message : AbstractCommand
+ {
+ ProducerId producerId;
+ ActiveMQDestination destination;
+ TransactionId transactionId;
+ ActiveMQDestination originalDestination;
+ MessageId messageId;
+ TransactionId originalTransactionId;
+ string groupID;
+ int groupSequence;
+ string correlationId;
+ bool persistent;
+ long expiration;
+ byte priority;
+ ActiveMQDestination replyTo;
+ long timestamp;
+ string type;
+ byte[] content;
+ byte[] marshalledProperties;
+ Command dataStructure;
+ ConsumerId targetConsumerId;
+ bool compressed;
+ int redeliveryCounter;
+ BrokerId[] brokerPath;
+ long arrival;
+ string userID;
+ bool recievedByDFBridge;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ProducerId ProducerId
+ {
+ get
+ {
+ return producerId;
+ }
+ set
+ {
+ producerId = value;
+ }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get
+ {
+ return destination;
+ }
+ set
+ {
+ destination = value;
+ }
+ }
+
+ public TransactionId TransactionId
+ {
+ get
+ {
+ return transactionId;
+ }
+ set
+ {
+ transactionId = value;
+ }
+ }
+
+ public ActiveMQDestination OriginalDestination
+ {
+ get
+ {
+ return originalDestination;
+ }
+ set
+ {
+ originalDestination = value;
+ }
+ }
+
+ public MessageId MessageId
+ {
+ get
+ {
+ return messageId;
+ }
+ set
+ {
+ messageId = value;
+ }
+ }
+
+ public TransactionId OriginalTransactionId
+ {
+ get
+ {
+ return originalTransactionId;
+ }
+ set
+ {
+ originalTransactionId = value;
+ }
+ }
+
+ public string GroupID
+ {
+ get
+ {
+ return groupID;
+ }
+ set
+ {
+ groupID = value;
+ }
+ }
+
+ public int GroupSequence
+ {
+ get
+ {
+ return groupSequence;
+ }
+ set
+ {
+ groupSequence = value;
+ }
+ }
+
+ public string CorrelationId
+ {
+ get
+ {
+ return correlationId;
+ }
+ set
+ {
+ correlationId = value;
+ }
+ }
+
+ public bool Persistent
+ {
+ get
+ {
+ return persistent;
+ }
+ set
+ {
+ persistent = value;
+ }
+ }
+
+ public long Expiration
+ {
+ get
+ {
+ return expiration;
+ }
+ set
+ {
+ expiration = value;
+ }
+ }
+
+ public byte Priority
+ {
+ get
+ {
+ return priority;
+ }
+ set
+ {
+ priority = value;
+ }
+ }
+
+ public ActiveMQDestination ReplyTo
+ {
+ get
+ {
+ return replyTo;
+ }
+ set
+ {
+ replyTo = value;
+ }
+ }
+
+ public long Timestamp
+ {
+ get
+ {
+ return timestamp;
+ }
+ set
+ {
+ timestamp = value;
+ }
+ }
+
+ public string Type
+ {
+ get
+ {
+ return type;
+ }
+ set
+ {
+ type = value;
+ }
+ }
+
+ public byte[] Content
+ {
+ get
+ {
+ return content;
+ }
+ set
+ {
+ content = value;
+ }
+ }
+
+ public byte[] MarshalledProperties
+ {
+ get
+ {
+ return marshalledProperties;
+ }
+ set
+ {
+ marshalledProperties = value;
+ }
+ }
+
+ public Command DataStructure
+ {
+ get
+ {
+ return dataStructure;
+ }
+ set
+ {
+ dataStructure = value;
+ }
+ }
+
+ public ConsumerId TargetConsumerId
+ {
+ get
+ {
+ return targetConsumerId;
+ }
+ set
+ {
+ targetConsumerId = value;
+ }
+ }
+
+ public bool Compressed
+ {
+ get
+ {
+ return compressed;
+ }
+ set
+ {
+ compressed = value;
+ }
+ }
+
+ public int RedeliveryCounter
+ {
+ get
+ {
+ return redeliveryCounter;
+ }
+ set
+ {
+ redeliveryCounter = value;
+ }
+ }
+
+ public BrokerId[] BrokerPath
+ {
+ get
+ {
+ return brokerPath;
+ }
+ set
+ {
+ brokerPath = value;
+ }
+ }
+
+ public long Arrival
+ {
+ get
+ {
+ return arrival;
+ }
+ set
+ {
+ arrival = value;
+ }
+ }
+
+ public string UserID
+ {
+ get
+ {
+ return userID;
+ }
+ set
+ {
+ userID = value;
+ }
+ }
+
+ public bool RecievedByDFBridge
+ {
+ get
+ {
+ return recievedByDFBridge;
+ }
+ set
+ {
+ recievedByDFBridge = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageAck.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageAck.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,127 @@
+//
+// Marshalling code for Open Wire Format for MessageAck
+//
+//
+// 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 MessageAck : AbstractCommand
+ {
+ ActiveMQDestination destination;
+ TransactionId transactionId;
+ ConsumerId consumerId;
+ byte ackType;
+ MessageId firstMessageId;
+ MessageId lastMessageId;
+ int messageCount;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ActiveMQDestination Destination
+ {
+ get
+ {
+ return destination;
+ }
+ set
+ {
+ destination = value;
+ }
+ }
+
+ public TransactionId TransactionId
+ {
+ get
+ {
+ return transactionId;
+ }
+ set
+ {
+ transactionId = value;
+ }
+ }
+
+ public ConsumerId ConsumerId
+ {
+ get
+ {
+ return consumerId;
+ }
+ set
+ {
+ consumerId = value;
+ }
+ }
+
+ public byte AckType
+ {
+ get
+ {
+ return ackType;
+ }
+ set
+ {
+ ackType = value;
+ }
+ }
+
+ public MessageId FirstMessageId
+ {
+ get
+ {
+ return firstMessageId;
+ }
+ set
+ {
+ firstMessageId = value;
+ }
+ }
+
+ public MessageId LastMessageId
+ {
+ get
+ {
+ return lastMessageId;
+ }
+ set
+ {
+ lastMessageId = value;
+ }
+ }
+
+ public int MessageCount
+ {
+ get
+ {
+ return messageCount;
+ }
+ set
+ {
+ messageCount = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageDispatch.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageDispatch.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,88 @@
+//
+// Marshalling code for Open Wire Format for MessageDispatch
+//
+//
+// 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 MessageDispatch : AbstractCommand
+ {
+ ConsumerId consumerId;
+ ActiveMQDestination destination;
+ Message message;
+ int redeliveryCounter;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ConsumerId ConsumerId
+ {
+ get
+ {
+ return consumerId;
+ }
+ set
+ {
+ consumerId = value;
+ }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get
+ {
+ return destination;
+ }
+ set
+ {
+ destination = value;
+ }
+ }
+
+ public Message Message
+ {
+ get
+ {
+ return message;
+ }
+ set
+ {
+ message = value;
+ }
+ }
+
+ public int RedeliveryCounter
+ {
+ get
+ {
+ return redeliveryCounter;
+ }
+ set
+ {
+ redeliveryCounter = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/MessageId.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,75 @@
+//
+// Marshalling code for Open Wire Format for MessageId
+//
+//
+// 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 MessageId : AbstractCommand
+ {
+ ProducerId producerId;
+ long producerSequenceId;
+ long brokerSequenceId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ProducerId ProducerId
+ {
+ get
+ {
+ return producerId;
+ }
+ set
+ {
+ producerId = value;
+ }
+ }
+
+ public long ProducerSequenceId
+ {
+ get
+ {
+ return producerSequenceId;
+ }
+ set
+ {
+ producerSequenceId = value;
+ }
+ }
+
+ public long BrokerSequenceId
+ {
+ get
+ {
+ return brokerSequenceId;
+ }
+ set
+ {
+ brokerSequenceId = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerId.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,75 @@
+//
+// Marshalling code for Open Wire Format for ProducerId
+//
+//
+// 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 ProducerId : AbstractCommand
+ {
+ string connectionId;
+ long producerId;
+ long sessionId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public string ConnectionId
+ {
+ get
+ {
+ return connectionId;
+ }
+ set
+ {
+ connectionId = value;
+ }
+ }
+
+ public long ProducerIdValue
+ {
+ get
+ {
+ return producerId;
+ }
+ set
+ {
+ producerId = value;
+ }
+ }
+
+ public long SessionId
+ {
+ get
+ {
+ return sessionId;
+ }
+ set
+ {
+ sessionId = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ProducerInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,75 @@
+//
+// Marshalling code for Open Wire Format for ProducerInfo
+//
+//
+// 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 ProducerInfo : AbstractCommand
+ {
+ ProducerId producerId;
+ ActiveMQDestination destination;
+ BrokerId[] brokerPath;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ProducerId ProducerId
+ {
+ get
+ {
+ return producerId;
+ }
+ set
+ {
+ producerId = value;
+ }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get
+ {
+ return destination;
+ }
+ set
+ {
+ destination = value;
+ }
+ }
+
+ public BrokerId[] BrokerPath
+ {
+ get
+ {
+ return brokerPath;
+ }
+ set
+ {
+ brokerPath = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for RemoveInfo
+//
+//
+// 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 RemoveInfo : AbstractCommand
+ {
+ Command objectId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public Command ObjectId
+ {
+ get
+ {
+ return objectId;
+ }
+ set
+ {
+ objectId = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveSubscriptionInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/RemoveSubscriptionInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,75 @@
+//
+// Marshalling code for Open Wire Format for RemoveSubscriptionInfo
+//
+//
+// 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 RemoveSubscriptionInfo : AbstractCommand
+ {
+ ConnectionId connectionId;
+ string subcriptionName;
+ string clientId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ConnectionId ConnectionId
+ {
+ get
+ {
+ return connectionId;
+ }
+ set
+ {
+ connectionId = value;
+ }
+ }
+
+ public string SubcriptionName
+ {
+ get
+ {
+ return subcriptionName;
+ }
+ set
+ {
+ subcriptionName = value;
+ }
+ }
+
+ public string ClientId
+ {
+ get
+ {
+ return clientId;
+ }
+ set
+ {
+ clientId = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Response.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/Response.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for Response
+//
+//
+// 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 Response : AbstractCommand
+ {
+ short correlationId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public short CorrelationId
+ {
+ get
+ {
+ return correlationId;
+ }
+ set
+ {
+ correlationId = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionId.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,62 @@
+//
+// Marshalling code for Open Wire Format for SessionId
+//
+//
+// 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 SessionId : AbstractCommand
+ {
+ string connectionId;
+ long sessionId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public string ConnectionId
+ {
+ get
+ {
+ return connectionId;
+ }
+ set
+ {
+ connectionId = value;
+ }
+ }
+
+ public long SessionIdValue
+ {
+ get
+ {
+ return sessionId;
+ }
+ set
+ {
+ sessionId = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SessionInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for SessionInfo
+//
+//
+// 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 SessionInfo : AbstractCommand
+ {
+ SessionId sessionId;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public SessionId SessionId
+ {
+ get
+ {
+ return sessionId;
+ }
+ set
+ {
+ sessionId = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ShutdownInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/ShutdownInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for ShutdownInfo
+//
+//
+// 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 ShutdownInfo : AbstractCommand
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SubscriptionInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/SubscriptionInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,88 @@
+//
+// Marshalling code for Open Wire Format for SubscriptionInfo
+//
+//
+// 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 SubscriptionInfo : AbstractCommand
+ {
+ string clientId;
+ ActiveMQDestination destination;
+ string selector;
+ string subcriptionName;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public string ClientId
+ {
+ get
+ {
+ return clientId;
+ }
+ set
+ {
+ clientId = value;
+ }
+ }
+
+ public ActiveMQDestination Destination
+ {
+ get
+ {
+ return destination;
+ }
+ set
+ {
+ destination = value;
+ }
+ }
+
+ public string Selector
+ {
+ get
+ {
+ return selector;
+ }
+ set
+ {
+ selector = value;
+ }
+ }
+
+ public string SubcriptionName
+ {
+ get
+ {
+ return subcriptionName;
+ }
+ set
+ {
+ subcriptionName = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionId.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,36 @@
+//
+// Marshalling code for Open Wire Format for TransactionId
+//
+//
+// 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 TransactionId : AbstractCommand
+ {
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/TransactionInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,75 @@
+//
+// Marshalling code for Open Wire Format for TransactionInfo
+//
+//
+// 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 TransactionInfo : AbstractCommand
+ {
+ ConnectionId connectionId;
+ TransactionId transactionId;
+ byte type;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public ConnectionId ConnectionId
+ {
+ get
+ {
+ return connectionId;
+ }
+ set
+ {
+ connectionId = value;
+ }
+ }
+
+ public TransactionId TransactionId
+ {
+ get
+ {
+ return transactionId;
+ }
+ set
+ {
+ transactionId = value;
+ }
+ }
+
+ public byte Type
+ {
+ get
+ {
+ return type;
+ }
+ set
+ {
+ type = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/WireFormatInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/WireFormatInfo.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,75 @@
+//
+// Marshalling code for Open Wire Format for WireFormatInfo
+//
+//
+// 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 WireFormatInfo : AbstractCommand
+ {
+ byte[] magic;
+ int version;
+ int options;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public byte[] Magic
+ {
+ get
+ {
+ return magic;
+ }
+ set
+ {
+ magic = value;
+ }
+ }
+
+ public int Version
+ {
+ get
+ {
+ return version;
+ }
+ set
+ {
+ version = value;
+ }
+ }
+
+ public int Options
+ {
+ get
+ {
+ return options;
+ }
+ set
+ {
+ options = value;
+ }
+ }
+
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/XATransactionId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Commands/XATransactionId.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,75 @@
+//
+// Marshalling code for Open Wire Format for XATransactionId
+//
+//
+// 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 XATransactionId : AbstractCommand
+ {
+ int formatId;
+ byte[] globalTransactionId;
+ byte[] branchQualifier;
+
+
+
+ // TODO generate Equals method
+ // TODO generate HashCode method
+ // TODO generate ToString method
+
+
+ public override int GetCommandType() {
+ return 1;
+ }
+
+
+ // Properties
+
+
+ public int FormatId
+ {
+ get
+ {
+ return formatId;
+ }
+ set
+ {
+ formatId = value;
+ }
+ }
+
+ public byte[] GlobalTransactionId
+ {
+ get
+ {
+ return globalTransactionId;
+ }
+ set
+ {
+ globalTransactionId = value;
+ }
+ }
+
+ public byte[] BranchQualifier
+ {
+ get
+ {
+ return branchQualifier;
+ }
+ set
+ {
+ branchQualifier = value;
+ }
+ }
+
+ }
+}
Copied: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs (from r366455, incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/DestinationFilter.cs)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs&p1=incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/DestinationFilter.cs&r1=366455&r2=366537&rev=366537&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/comms-library/amqnet/DestinationFilter.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs Fri Jan 6 09:24:01 2006
@@ -1,6 +1,6 @@
using System;
-namespace ActiveMQ
+namespace OpenWire.Core
{
/// <summary>
/// Summary description for DestinationFilter.
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQBytesMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQBytesMessageMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQBytesMessageMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQBytesMessageMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQBytesMessage
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQBytesMessageMarshaller : ActiveMQMessageMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQBytesMessage();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQBytesMessage info = (ActiveMQBytesMessage) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQBytesMessage info = (ActiveMQBytesMessage) command;
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQDestinationMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQDestinationMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQDestinationMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQDestinationMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQDestination
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQDestinationMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQDestination();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQDestination info = (ActiveMQDestination) command;
+ info.setPhysicalName(dataIn.readUTF());
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQDestination info = (ActiveMQDestination) command;
+ writeUTF(info.getPhysicalName(), dataOut);
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMapMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMapMessageMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMapMessageMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMapMessageMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQMapMessage
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQMapMessageMarshaller : ActiveMQMessageMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQMapMessage();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQMapMessage info = (ActiveMQMapMessage) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQMapMessage info = (ActiveMQMapMessage) command;
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMessageMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMessageMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQMessageMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQMessage
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQMessageMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQMessage();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQMessage info = (ActiveMQMessage) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQMessage info = (ActiveMQMessage) command;
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQObjectMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQObjectMessageMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQObjectMessageMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQObjectMessageMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQObjectMessage
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQObjectMessageMarshaller : ActiveMQMessageMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQObjectMessage();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQObjectMessage info = (ActiveMQObjectMessage) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQObjectMessage info = (ActiveMQObjectMessage) command;
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQQueueMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQQueueMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQQueueMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQQueueMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQQueue
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQQueueMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQQueue();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQQueue info = (ActiveMQQueue) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQQueue info = (ActiveMQQueue) command;
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQStreamMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQStreamMessageMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQStreamMessageMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQStreamMessageMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQStreamMessage
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQStreamMessageMarshaller : ActiveMQMessageMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQStreamMessage();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQStreamMessage info = (ActiveMQStreamMessage) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQStreamMessage info = (ActiveMQStreamMessage) command;
+
+ }
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempDestinationMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempDestinationMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQTempDestination
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQTempDestinationMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQTempDestination();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQTempDestination info = (ActiveMQTempDestination) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQTempDestination info = (ActiveMQTempDestination) command;
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempQueueMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempQueueMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempQueueMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempQueueMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQTempQueue
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQTempQueueMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQTempQueue();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQTempQueue info = (ActiveMQTempQueue) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQTempQueue info = (ActiveMQTempQueue) command;
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempTopicMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempTopicMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempTopicMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTempTopicMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQTempTopic
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQTempTopicMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQTempTopic();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQTempTopic info = (ActiveMQTempTopic) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQTempTopic info = (ActiveMQTempTopic) command;
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTextMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTextMessageMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTextMessageMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTextMessageMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQTextMessage
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQTextMessageMarshaller : ActiveMQMessageMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQTextMessage();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQTextMessage info = (ActiveMQTextMessage) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQTextMessage info = (ActiveMQTextMessage) command;
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTopicMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTopicMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTopicMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ActiveMQTopicMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,39 @@
+//
+// Marshalling code for Open Wire Format for ActiveMQTopic
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ActiveMQTopicMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ActiveMQTopic();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ActiveMQTopic info = (ActiveMQTopic) command;
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ActiveMQTopic info = (ActiveMQTopic) command;
+
+ }
+ }
+}
Added: 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=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BaseCommandMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BaseCommandMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,43 @@
+//
+// Marshalling code for Open Wire Format for BaseCommand
+//
+//
+// NOTE!: This file is autogenerated - do not modify!
+// if you need to make a change, please see the Groovy scripts in the
+// activemq-openwire module
+//
+
+using System;
+using System.Collections;
+using System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class BaseCommandMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new BaseCommand();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ BaseCommand info = (BaseCommand) command;
+ info.setCommandId(dataIn.readShort());
+ info.setResponseRequired(dataIn.readBoolean());
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ BaseCommand info = (BaseCommand) command;
+ dataOut.writeShort(info.getCommandId());
+ dataOut.writeBoolean(info.isResponseRequired());
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BrokerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BrokerIdMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BrokerIdMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BrokerIdMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for BrokerId
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class BrokerIdMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new BrokerId();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ BrokerId info = (BrokerId) command;
+ info.setBrokerId(dataIn.readUTF());
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ BrokerId info = (BrokerId) command;
+ writeUTF(info.getBrokerId(), dataOut);
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BrokerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BrokerInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BrokerInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/BrokerInfoMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,47 @@
+//
+// Marshalling code for Open Wire Format for BrokerInfo
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class BrokerInfoMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new BrokerInfo();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ BrokerInfo info = (BrokerInfo) command;
+ info.setBrokerId((org.apache.activemq.command.BrokerId) readObject(dataIn));
+ info.setBrokerURL(dataIn.readUTF());
+ info.setPeerBrokerInfos((org.apache.activemq.command.BrokerInfo[]) readObject(dataIn));
+ info.setBrokerName(dataIn.readUTF());
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ BrokerInfo info = (BrokerInfo) command;
+ writeObject(info.getBrokerId(), dataOut);
+ writeUTF(info.getBrokerURL(), dataOut);
+ writeObject(info.getPeerBrokerInfos(), dataOut);
+ writeUTF(info.getBrokerName(), dataOut);
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConnectionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConnectionIdMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConnectionIdMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConnectionIdMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,41 @@
+//
+// Marshalling code for Open Wire Format for ConnectionId
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ConnectionIdMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ConnectionId();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ConnectionId info = (ConnectionId) command;
+ info.setConnectionId(dataIn.readUTF());
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ConnectionId info = (ConnectionId) command;
+ writeUTF(info.getConnectionId(), dataOut);
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConnectionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConnectionInfoMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConnectionInfoMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConnectionInfoMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,49 @@
+//
+// Marshalling code for Open Wire Format for ConnectionInfo
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ConnectionInfoMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ConnectionInfo();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ConnectionInfo info = (ConnectionInfo) command;
+ info.setConnectionId((org.apache.activemq.command.ConnectionId) readObject(dataIn));
+ info.setClientId(dataIn.readUTF());
+ info.setPassword(dataIn.readUTF());
+ info.setUserName(dataIn.readUTF());
+ info.setBrokerPath((org.apache.activemq.command.BrokerId[]) readObject(dataIn));
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ConnectionInfo info = (ConnectionInfo) command;
+ writeObject(info.getConnectionId(), dataOut);
+ writeUTF(info.getClientId(), dataOut);
+ writeUTF(info.getPassword(), dataOut);
+ writeUTF(info.getUserName(), dataOut);
+ writeObject(info.getBrokerPath(), dataOut);
+
+ }
+ }
+}
Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerIdMarshaller.cs?rev=366537&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerIdMarshaller.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ConsumerIdMarshaller.cs Fri Jan 6 09:24:01 2006
@@ -0,0 +1,45 @@
+//
+// Marshalling code for Open Wire Format for ConsumerId
+//
+//
+// 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 System.IO;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+using OpenWire.Core.IO;
+
+namespace OpenWire.Core.IO
+{
+ public class ConsumerIdMarshaller : AbstractCommandMarshaller
+ {
+
+ public override Command CreateCommand() {
+ return new ConsumerId();
+ }
+
+ public override void BuildCommand(Command command, BinaryReader dataIn) {
+ super.buildCommand(command, dataIn);
+ ConsumerId info = (ConsumerId) command;
+ info.setConnectionId(dataIn.readUTF());
+ info.setSessionId(dataIn.readLong());
+ info.setConsumerId(dataIn.readLong());
+
+ }
+
+ public override void WriteCommand(Command command, BinaryWriter dataOut) {
+ super.writeCommand(command, dataOut);
+ ConsumerId info = (ConsumerId) command;
+ writeUTF(info.getConnectionId(), dataOut);
+ dataOut.writeLong(info.getSessionId());
+ dataOut.writeLong(info.getConsumerId());
+
+ }
+ }
+}