activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r367566 [2/2] - in /incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core: ./ Commands/ IO/ Transport/
Date Tue, 10 Jan 2006 10:57:04 GMT
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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -37,26 +37,14 @@
 
         public ActiveMQDestination Destination
         {
-            get
-            {
-                return destination;
-            }
-            set
-            {
-                destination = value;
-            }            
+            get { return destination; }
+            set { this.destination = value; }            
         }
 
         public MessageAck MessageAck
         {
-            get
-            {
-                return messageAck;
-            }
-            set
-            {
-                messageAck = value;
-            }            
+            get { return messageAck; }
+            set { this.messageAck = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -41,74 +41,38 @@
 
         public ActiveMQDestination Destination
         {
-            get
-            {
-                return destination;
-            }
-            set
-            {
-                destination = value;
-            }            
+            get { return destination; }
+            set { this.destination = value; }            
         }
 
         public MessageId MessageId
         {
-            get
-            {
-                return messageId;
-            }
-            set
-            {
-                messageId = value;
-            }            
+            get { return messageId; }
+            set { this.messageId = value; }            
         }
 
         public long MessageSequenceId
         {
-            get
-            {
-                return messageSequenceId;
-            }
-            set
-            {
-                messageSequenceId = value;
-            }            
+            get { return messageSequenceId; }
+            set { this.messageSequenceId = value; }            
         }
 
         public string SubscritionName
         {
-            get
-            {
-                return subscritionName;
-            }
-            set
-            {
-                subscritionName = value;
-            }            
+            get { return subscritionName; }
+            set { this.subscritionName = value; }            
         }
 
         public string ClientId
         {
-            get
-            {
-                return clientId;
-            }
-            set
-            {
-                clientId = value;
-            }            
+            get { return clientId; }
+            set { this.clientId = value; }            
         }
 
         public TransactionId TransactionId
         {
-            get
-            {
-                return transactionId;
-            }
-            set
-            {
-                transactionId = value;
-            }            
+            get { return transactionId; }
+            set { this.transactionId = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -36,14 +36,8 @@
 
         public string Message
         {
-            get
-            {
-                return message;
-            }
-            set
-            {
-                message = value;
-            }            
+            get { return message; }
+            set { this.message = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -38,38 +38,20 @@
 
         public TransactionId TransactionId
         {
-            get
-            {
-                return transactionId;
-            }
-            set
-            {
-                transactionId = value;
-            }            
+            get { return transactionId; }
+            set { this.transactionId = value; }            
         }
 
         public byte Type
         {
-            get
-            {
-                return type;
-            }
-            set
-            {
-                type = value;
-            }            
+            get { return type; }
+            set { this.type = value; }            
         }
 
         public bool WasPrepared
         {
-            get
-            {
-                return wasPrepared;
-            }
-            set
-            {
-                wasPrepared = value;
-            }            
+            get { return wasPrepared; }
+            set { this.wasPrepared = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -37,26 +37,14 @@
 
         public long Value
         {
-            get
-            {
-                return value;
-            }
-            set
-            {
-                value = value;
-            }            
+            get { return value; }
+            set { this.value = value; }            
         }
 
         public ConnectionId ConnectionId
         {
-            get
-            {
-                return connectionId;
-            }
-            set
-            {
-                connectionId = value;
-            }            
+            get { return connectionId; }
+            set { this.connectionId = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -60,302 +60,152 @@
 
         public ProducerId ProducerId
         {
-            get
-            {
-                return producerId;
-            }
-            set
-            {
-                producerId = value;
-            }            
+            get { return producerId; }
+            set { this.producerId = value; }            
         }
 
         public ActiveMQDestination Destination
         {
-            get
-            {
-                return destination;
-            }
-            set
-            {
-                destination = value;
-            }            
+            get { return destination; }
+            set { this.destination = value; }            
         }
 
         public TransactionId TransactionId
         {
-            get
-            {
-                return transactionId;
-            }
-            set
-            {
-                transactionId = value;
-            }            
+            get { return transactionId; }
+            set { this.transactionId = value; }            
         }
 
         public ActiveMQDestination OriginalDestination
         {
-            get
-            {
-                return originalDestination;
-            }
-            set
-            {
-                originalDestination = value;
-            }            
+            get { return originalDestination; }
+            set { this.originalDestination = value; }            
         }
 
         public MessageId MessageId
         {
-            get
-            {
-                return messageId;
-            }
-            set
-            {
-                messageId = value;
-            }            
+            get { return messageId; }
+            set { this.messageId = value; }            
         }
 
         public TransactionId OriginalTransactionId
         {
-            get
-            {
-                return originalTransactionId;
-            }
-            set
-            {
-                originalTransactionId = value;
-            }            
+            get { return originalTransactionId; }
+            set { this.originalTransactionId = value; }            
         }
 
         public string GroupID
         {
-            get
-            {
-                return groupID;
-            }
-            set
-            {
-                groupID = value;
-            }            
+            get { return groupID; }
+            set { this.groupID = value; }            
         }
 
         public int GroupSequence
         {
-            get
-            {
-                return groupSequence;
-            }
-            set
-            {
-                groupSequence = value;
-            }            
+            get { return groupSequence; }
+            set { this.groupSequence = value; }            
         }
 
         public string CorrelationId
         {
-            get
-            {
-                return correlationId;
-            }
-            set
-            {
-                correlationId = value;
-            }            
+            get { return correlationId; }
+            set { this.correlationId = value; }            
         }
 
         public bool Persistent
         {
-            get
-            {
-                return persistent;
-            }
-            set
-            {
-                persistent = value;
-            }            
+            get { return persistent; }
+            set { this.persistent = value; }            
         }
 
         public long Expiration
         {
-            get
-            {
-                return expiration;
-            }
-            set
-            {
-                expiration = value;
-            }            
+            get { return expiration; }
+            set { this.expiration = value; }            
         }
 
         public byte Priority
         {
-            get
-            {
-                return priority;
-            }
-            set
-            {
-                priority = value;
-            }            
+            get { return priority; }
+            set { this.priority = value; }            
         }
 
         public ActiveMQDestination ReplyTo
         {
-            get
-            {
-                return replyTo;
-            }
-            set
-            {
-                replyTo = value;
-            }            
+            get { return replyTo; }
+            set { this.replyTo = value; }            
         }
 
         public long Timestamp
         {
-            get
-            {
-                return timestamp;
-            }
-            set
-            {
-                timestamp = value;
-            }            
+            get { return timestamp; }
+            set { this.timestamp = value; }            
         }
 
         public string Type
         {
-            get
-            {
-                return type;
-            }
-            set
-            {
-                type = value;
-            }            
+            get { return type; }
+            set { this.type = value; }            
         }
 
         public byte[] Content
         {
-            get
-            {
-                return content;
-            }
-            set
-            {
-                content = value;
-            }            
+            get { return content; }
+            set { this.content = value; }            
         }
 
         public byte[] MarshalledProperties
         {
-            get
-            {
-                return marshalledProperties;
-            }
-            set
-            {
-                marshalledProperties = value;
-            }            
+            get { return marshalledProperties; }
+            set { this.marshalledProperties = value; }            
         }
 
         public DataStructure DataStructure
         {
-            get
-            {
-                return dataStructure;
-            }
-            set
-            {
-                dataStructure = value;
-            }            
+            get { return dataStructure; }
+            set { this.dataStructure = value; }            
         }
 
         public ConsumerId TargetConsumerId
         {
-            get
-            {
-                return targetConsumerId;
-            }
-            set
-            {
-                targetConsumerId = value;
-            }            
+            get { return targetConsumerId; }
+            set { this.targetConsumerId = value; }            
         }
 
         public bool Compressed
         {
-            get
-            {
-                return compressed;
-            }
-            set
-            {
-                compressed = value;
-            }            
+            get { return compressed; }
+            set { this.compressed = value; }            
         }
 
         public int RedeliveryCounter
         {
-            get
-            {
-                return redeliveryCounter;
-            }
-            set
-            {
-                redeliveryCounter = value;
-            }            
+            get { return redeliveryCounter; }
+            set { this.redeliveryCounter = value; }            
         }
 
         public BrokerId[] BrokerPath
         {
-            get
-            {
-                return brokerPath;
-            }
-            set
-            {
-                brokerPath = value;
-            }            
+            get { return brokerPath; }
+            set { this.brokerPath = value; }            
         }
 
         public long Arrival
         {
-            get
-            {
-                return arrival;
-            }
-            set
-            {
-                arrival = value;
-            }            
+            get { return arrival; }
+            set { this.arrival = value; }            
         }
 
         public string UserID
         {
-            get
-            {
-                return userID;
-            }
-            set
-            {
-                userID = value;
-            }            
+            get { return userID; }
+            set { this.userID = value; }            
         }
 
         public bool RecievedByDFBridge
         {
-            get
-            {
-                return recievedByDFBridge;
-            }
-            set
-            {
-                recievedByDFBridge = value;
-            }            
+            get { return recievedByDFBridge; }
+            set { this.recievedByDFBridge = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -42,86 +42,44 @@
 
         public ActiveMQDestination Destination
         {
-            get
-            {
-                return destination;
-            }
-            set
-            {
-                destination = value;
-            }            
+            get { return destination; }
+            set { this.destination = value; }            
         }
 
         public TransactionId TransactionId
         {
-            get
-            {
-                return transactionId;
-            }
-            set
-            {
-                transactionId = value;
-            }            
+            get { return transactionId; }
+            set { this.transactionId = value; }            
         }
 
         public ConsumerId ConsumerId
         {
-            get
-            {
-                return consumerId;
-            }
-            set
-            {
-                consumerId = value;
-            }            
+            get { return consumerId; }
+            set { this.consumerId = value; }            
         }
 
         public byte AckType
         {
-            get
-            {
-                return ackType;
-            }
-            set
-            {
-                ackType = value;
-            }            
+            get { return ackType; }
+            set { this.ackType = value; }            
         }
 
         public MessageId FirstMessageId
         {
-            get
-            {
-                return firstMessageId;
-            }
-            set
-            {
-                firstMessageId = value;
-            }            
+            get { return firstMessageId; }
+            set { this.firstMessageId = value; }            
         }
 
         public MessageId LastMessageId
         {
-            get
-            {
-                return lastMessageId;
-            }
-            set
-            {
-                lastMessageId = value;
-            }            
+            get { return lastMessageId; }
+            set { this.lastMessageId = value; }            
         }
 
         public int MessageCount
         {
-            get
-            {
-                return messageCount;
-            }
-            set
-            {
-                messageCount = value;
-            }            
+            get { return messageCount; }
+            set { this.messageCount = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -39,50 +39,26 @@
 
         public ConsumerId ConsumerId
         {
-            get
-            {
-                return consumerId;
-            }
-            set
-            {
-                consumerId = value;
-            }            
+            get { return consumerId; }
+            set { this.consumerId = value; }            
         }
 
         public ActiveMQDestination Destination
         {
-            get
-            {
-                return destination;
-            }
-            set
-            {
-                destination = value;
-            }            
+            get { return destination; }
+            set { this.destination = value; }            
         }
 
         public Message Message
         {
-            get
-            {
-                return message;
-            }
-            set
-            {
-                message = value;
-            }            
+            get { return message; }
+            set { this.message = value; }            
         }
 
         public int RedeliveryCounter
         {
-            get
-            {
-                return redeliveryCounter;
-            }
-            set
-            {
-                redeliveryCounter = value;
-            }            
+            get { return redeliveryCounter; }
+            set { this.redeliveryCounter = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -38,38 +38,20 @@
 
         public ProducerId ProducerId
         {
-            get
-            {
-                return producerId;
-            }
-            set
-            {
-                producerId = value;
-            }            
+            get { return producerId; }
+            set { this.producerId = value; }            
         }
 
         public long ProducerSequenceId
         {
-            get
-            {
-                return producerSequenceId;
-            }
-            set
-            {
-                producerSequenceId = value;
-            }            
+            get { return producerSequenceId; }
+            set { this.producerSequenceId = value; }            
         }
 
         public long BrokerSequenceId
         {
-            get
-            {
-                return brokerSequenceId;
-            }
-            set
-            {
-                brokerSequenceId = value;
-            }            
+            get { return brokerSequenceId; }
+            set { this.brokerSequenceId = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -19,7 +19,7 @@
     			public const byte ID_ProducerId = 123;
     			
         string connectionId;
-        long producerId;
+        long value;
         long sessionId;
 
 
@@ -38,38 +38,20 @@
 
         public string ConnectionId
         {
-            get
-            {
-                return connectionId;
-            }
-            set
-            {
-                connectionId = value;
-            }            
+            get { return connectionId; }
+            set { this.connectionId = value; }            
         }
 
-        public long ProducerIdValue
+        public long Value
         {
-            get
-            {
-                return producerId;
-            }
-            set
-            {
-                producerId = value;
-            }            
+            get { return value; }
+            set { this.value = value; }            
         }
 
         public long SessionId
         {
-            get
-            {
-                return sessionId;
-            }
-            set
-            {
-                sessionId = value;
-            }            
+            get { return sessionId; }
+            set { this.sessionId = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -38,38 +38,20 @@
 
         public ProducerId ProducerId
         {
-            get
-            {
-                return producerId;
-            }
-            set
-            {
-                producerId = value;
-            }            
+            get { return producerId; }
+            set { this.producerId = value; }            
         }
 
         public ActiveMQDestination Destination
         {
-            get
-            {
-                return destination;
-            }
-            set
-            {
-                destination = value;
-            }            
+            get { return destination; }
+            set { this.destination = value; }            
         }
 
         public BrokerId[] BrokerPath
         {
-            get
-            {
-                return brokerPath;
-            }
-            set
-            {
-                brokerPath = value;
-            }            
+            get { return brokerPath; }
+            set { this.brokerPath = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -36,14 +36,8 @@
 
         public DataStructure ObjectId
         {
-            get
-            {
-                return objectId;
-            }
-            set
-            {
-                objectId = value;
-            }            
+            get { return objectId; }
+            set { this.objectId = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -38,38 +38,20 @@
 
         public ConnectionId ConnectionId
         {
-            get
-            {
-                return connectionId;
-            }
-            set
-            {
-                connectionId = value;
-            }            
+            get { return connectionId; }
+            set { this.connectionId = value; }            
         }
 
         public string SubcriptionName
         {
-            get
-            {
-                return subcriptionName;
-            }
-            set
-            {
-                subcriptionName = value;
-            }            
+            get { return subcriptionName; }
+            set { this.subcriptionName = value; }            
         }
 
         public string ClientId
         {
-            get
-            {
-                return clientId;
-            }
-            set
-            {
-                clientId = value;
-            }            
+            get { return clientId; }
+            set { this.clientId = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -36,14 +36,8 @@
 
         public short CorrelationId
         {
-            get
-            {
-                return correlationId;
-            }
-            set
-            {
-                correlationId = value;
-            }            
+            get { return correlationId; }
+            set { this.correlationId = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -37,26 +37,14 @@
 
         public string ConnectionId
         {
-            get
-            {
-                return connectionId;
-            }
-            set
-            {
-                connectionId = value;
-            }            
+            get { return connectionId; }
+            set { this.connectionId = value; }            
         }
 
         public long Value
         {
-            get
-            {
-                return value;
-            }
-            set
-            {
-                value = value;
-            }            
+            get { return value; }
+            set { this.value = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -36,14 +36,8 @@
 
         public SessionId SessionId
         {
-            get
-            {
-                return sessionId;
-            }
-            set
-            {
-                sessionId = value;
-            }            
+            get { return sessionId; }
+            set { this.sessionId = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -39,50 +39,26 @@
 
         public string ClientId
         {
-            get
-            {
-                return clientId;
-            }
-            set
-            {
-                clientId = value;
-            }            
+            get { return clientId; }
+            set { this.clientId = value; }            
         }
 
         public ActiveMQDestination Destination
         {
-            get
-            {
-                return destination;
-            }
-            set
-            {
-                destination = value;
-            }            
+            get { return destination; }
+            set { this.destination = value; }            
         }
 
         public string Selector
         {
-            get
-            {
-                return selector;
-            }
-            set
-            {
-                selector = value;
-            }            
+            get { return selector; }
+            set { this.selector = value; }            
         }
 
         public string SubcriptionName
         {
-            get
-            {
-                return subcriptionName;
-            }
-            set
-            {
-                subcriptionName = value;
-            }            
+            get { return subcriptionName; }
+            set { this.subcriptionName = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -38,38 +38,20 @@
 
         public ConnectionId ConnectionId
         {
-            get
-            {
-                return connectionId;
-            }
-            set
-            {
-                connectionId = value;
-            }            
+            get { return connectionId; }
+            set { this.connectionId = value; }            
         }
 
         public TransactionId TransactionId
         {
-            get
-            {
-                return transactionId;
-            }
-            set
-            {
-                transactionId = value;
-            }            
+            get { return transactionId; }
+            set { this.transactionId = value; }            
         }
 
         public byte Type
         {
-            get
-            {
-                return type;
-            }
-            set
-            {
-                type = value;
-            }            
+            get { return type; }
+            set { this.type = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -38,38 +38,20 @@
 
         public byte[] Magic
         {
-            get
-            {
-                return magic;
-            }
-            set
-            {
-                magic = value;
-            }            
+            get { return magic; }
+            set { this.magic = value; }            
         }
 
         public int Version
         {
-            get
-            {
-                return version;
-            }
-            set
-            {
-                version = value;
-            }            
+            get { return version; }
+            set { this.version = value; }            
         }
 
         public int Options
         {
-            get
-            {
-                return options;
-            }
-            set
-            {
-                options = value;
-            }            
+            get { return options; }
+            set { this.options = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&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 Tue Jan 10 02:56:34 2006
@@ -38,38 +38,20 @@
 
         public int FormatId
         {
-            get
-            {
-                return formatId;
-            }
-            set
-            {
-                formatId = value;
-            }            
+            get { return formatId; }
+            set { this.formatId = value; }            
         }
 
         public byte[] GlobalTransactionId
         {
-            get
-            {
-                return globalTransactionId;
-            }
-            set
-            {
-                globalTransactionId = value;
-            }            
+            get { return globalTransactionId; }
+            set { this.globalTransactionId = value; }            
         }
 
         public byte[] BranchQualifier
         {
-            get
-            {
-                return branchQualifier;
-            }
-            set
-            {
-                branchQualifier = value;
-            }            
+            get { return branchQualifier; }
+            set { this.branchQualifier = value; }            
         }
 
     }

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=367566&r1=367565&r2=367566&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DataStructure.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DataStructure.cs Tue Jan 10 02:56:34 2006
@@ -1,14 +1,11 @@
 using System;
 
-namespace OpenWire.Core
-{
-	/// <summary>
-	/// An OpenWire command
-	/// </summary>
-	public interface DataStructure {
-	
-        byte GetCommandType();
-        
-	}
-}
+namespace OpenWire.Core {
+        /// <summary>
+        /// An OpenWire command
+        /// </summary>
+        public interface DataStructure {
 
+                byte GetCommandType(); 
+        } 
+}

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Destination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Destination.cs?rev=367566&r1=367565&r2=367566&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Destination.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Destination.cs Tue Jan 10 02:56:34 2006
@@ -1,12 +1,10 @@
 using System;
 using OpenWire.Core.Commands;
 
-namespace OpenWire.Core
-{
-	/// <summary>
-	/// Summary description for Destination.
-	/// </summary>
-	public interface Destination 
-	{
-	}
+namespace OpenWire.Core {
+        /// <summary>
+        /// Summary description for Destination.
+        /// </summary>
+        public interface Destination {
+        } 
 }

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=367566&r1=367565&r2=367566&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/DestinationFilter.cs Tue Jan 10 02:56:34 2006
@@ -1,24 +1,18 @@
 using System;
 using OpenWire.Core.Commands;
 
-namespace OpenWire.Core
-{
-	/// <summary>
-	/// Summary description for DestinationFilter.
-	/// </summary>
-	public abstract class DestinationFilter 
-	{
-		public const String ANY_DESCENDENT = ">";
-		public const String ANY_CHILD = "*";
+namespace OpenWire.Core {
+        /// <summary>
+        /// Summary description for DestinationFilter.
+        /// </summary>
+        public abstract class DestinationFilter {
+                public const String ANY_DESCENDENT = ">";
+                public const String ANY_CHILD = "*";
 
-		public bool matches(ActiveMQMessage message) 
-		{
-			return matches(message.Destination);
-		}
-
-		public abstract bool matches(ActiveMQDestination destination);
-
-    
-	}
+                public bool matches(ActiveMQMessage message) {
+                        return matches(message.Destination); 
+                }
 
+                public abstract bool matches(ActiveMQDestination destination); 
+        } 
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs?rev=367566&r1=367565&r2=367566&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/IO/ProducerIdMarshaller.cs Tue Jan 10 02:56:34 2006
@@ -30,7 +30,7 @@
 
             ProducerId info = (ProducerId) command;
             info.ConnectionId = dataIn.ReadString();
-            info.ProducerIdValue = dataIn.ReadInt64();
+            info.Value = dataIn.ReadInt64();
             info.SessionId = dataIn.ReadInt64();
 
         }
@@ -40,7 +40,7 @@
 
             ProducerId info = (ProducerId) command;
             dataOut.Write(info.ConnectionId);
-            dataOut.Write(info.ProducerIdValue);
+            dataOut.Write(info.Value);
             dataOut.Write(info.SessionId);
 
         }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Queue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Queue.cs?rev=367566&r1=367565&r2=367566&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Queue.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Queue.cs Tue Jan 10 02:56:34 2006
@@ -1,16 +1,14 @@
 using System;
 using OpenWire.Core.Commands;
 
-namespace OpenWire.Core
-{
-	/// <summary>
-	/// Summary description for Queue.
-	/// </summary>
-	public interface Queue : Destination {
+namespace OpenWire.Core {
+        /// <summary>
+        /// Summary description for Queue.
+        /// </summary>
+        public interface Queue : Destination {
 
-		String QueueName
-		{
-			get;
-		}
-	}
-}
\ No newline at end of file
+                String QueueName {
+                        get; 
+                } 
+        } 
+}

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs?rev=367566&r1=367565&r2=367566&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryQueue.cs Tue Jan 10 02:56:34 2006
@@ -1,12 +1,10 @@
 using System;
 using OpenWire.Core.Commands;
 
-namespace OpenWire.Core
-{
-	/// <summary>
-	/// Summary description for TemporaryQueue.
-	/// </summary>
-	public interface TemporaryQueue : Destination 
-	{
-	}
+namespace OpenWire.Core {
+        /// <summary>
+        /// Summary description for TemporaryQueue.
+        /// </summary>
+        public interface TemporaryQueue : Destination {
+        } 
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryTopic.cs?rev=367566&r1=367565&r2=367566&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryTopic.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TemporaryTopic.cs Tue Jan 10 02:56:34 2006
@@ -1,12 +1,10 @@
 using System;
 using OpenWire.Core.Commands;
 
-namespace OpenWire.Core
-{
-	/// <summary>
-	/// Summary description for TemporaryTopic.
-	/// </summary>
-	public interface TemporaryTopic : Destination 
-	{
-	}
+namespace OpenWire.Core {
+        /// <summary>
+        /// Summary description for TemporaryTopic.
+        /// </summary>
+        public interface TemporaryTopic : Destination {
+        } 
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Topic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Topic.cs?rev=367566&r1=367565&r2=367566&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Topic.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Topic.cs Tue Jan 10 02:56:34 2006
@@ -1,17 +1,14 @@
 using System;
 using OpenWire.Core.Commands;
 
-namespace OpenWire.Core
-{
-	/// <summary>
-	/// Summary description for Topic.
-	/// </summary>
-	public interface Topic : Destination 
-	{
+namespace OpenWire.Core {
+        /// <summary>
+        /// Summary description for Topic.
+        /// </summary>
+        public interface Topic : Destination {
 
-		String TopicName
-		{
-			get;
-		}
-	}
+                String TopicName {
+                        get; 
+                } 
+        } 
 }

Modified: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TransactionConstants.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TransactionConstants.cs?rev=367566&r1=367565&r2=367566&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TransactionConstants.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/TransactionConstants.cs Tue Jan 10 02:56:34 2006
@@ -1,68 +1,66 @@
 using System;
 
-namespace OpenWire.Core
-{
-	/// <summary>
-	/// Summary description for TransactionConstants.
-	/// </summary>
-	public class TransactionType 
-	{
-    
-		/**
-		 * Transaction state not set
-		 */
-		const int NOT_SET = 0;
-		/**
-		 * Start a transaction
-		 */
-		const int START = 101;
-		/**
-		 * Pre-commit a transaction
-		 */
-		const int PRE_COMMIT = 102;
-		/**
-		 * Commit a transaction
-		 */
-		const int COMMIT = 103;
-		/**
-		 * Recover a transaction
-		 */
-		const int RECOVER = 104;
-		/**
-		 * Rollback a transaction
-		 */
-		const int ROLLBACK = 105;
-		/**
-		 * End a transaction
-		 */
-		const int END = 106;
-		/**
-		 * Forget a transaction
-		 */
-		const int FORGET = 107;
-		/**
-		 * Join a transaction
-		 */
-		const int JOIN = 108;
-		/**
-		 * Do a one phase commit...  No PRE COMMIT has been done.
-		 */
-		const int COMMIT_ONE_PHASE = 109;
-		/**
-		 * Get a list of all the XIDs that are currently prepared.
-		 */
-		const int XA_RECOVER = 110;
-		/**
-		 * Get a the transaction timeout for the RM
-		 */
-		const int GET_TX_TIMEOUT = 111;
-		/**
-		 * Set a the transaction timeout for the RM
-		 */
-		const int SET_TX_TIMEOUT = 112;
-		/**
-		 * Gets the unique id of the resource manager.
-		 */
-		const int GET_RM_ID = 113;
-	}
+namespace OpenWire.Core {
+        /// <summary>
+        /// Summary description for TransactionConstants.
+        /// </summary>
+        public class TransactionType {
+
+                /**
+                 * Transaction state not set
+                 */
+                const int NOT_SET = 0;
+                /**
+                 * Start a transaction
+                 */
+                const int START = 101;
+                /**
+                 * Pre-commit a transaction
+                 */
+                const int PRE_COMMIT = 102;
+                /**
+                 * Commit a transaction
+                 */
+                const int COMMIT = 103;
+                /**
+                 * Recover a transaction
+                 */
+                const int RECOVER = 104;
+                /**
+                 * Rollback a transaction
+                 */
+                const int ROLLBACK = 105;
+                /**
+                 * End a transaction
+                 */
+                const int END = 106;
+                /**
+                 * Forget a transaction
+                 */
+                const int FORGET = 107;
+                /**
+                 * Join a transaction
+                 */
+                const int JOIN = 108;
+                /**
+                 * Do a one phase commit...  No PRE COMMIT has been done.
+                 */
+                const int COMMIT_ONE_PHASE = 109;
+                /**
+                 * Get a list of all the XIDs that are currently prepared.
+                 */
+                const int XA_RECOVER = 110;
+                /**
+                 * Get a the transaction timeout for the RM
+                 */
+                const int GET_TX_TIMEOUT = 111;
+                /**
+                 * Set a the transaction timeout for the RM
+                 */
+                const int SET_TX_TIMEOUT = 112;
+                /**
+                 * Gets the unique id of the resource manager.
+                 */
+                const int GET_RM_ID = 113; 
+        } 
 }

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Transport/FutureResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Transport/FutureResponse.cs?rev=367566&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Transport/FutureResponse.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Transport/FutureResponse.cs Tue Jan 10 02:56:34 2006
@@ -0,0 +1,44 @@
+using System;
+using System.Threading;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+
+namespace OpenWire.Core.Transport {
+        /// <summary>
+        /// Handles asynchronous responses
+        /// </summary>
+        public class FutureResponse : IAsyncResult {
+
+                private Response response;
+                private Mutex asyncWaitHandle = new Mutex();
+                private bool isCompleted;
+
+                public WaitHandle AsyncWaitHandle {
+                        get { return asyncWaitHandle; } 
+                }
+
+                public object AsyncState {
+                        get { return response; }
+                        set { response = (Response) value; } 
+                }
+
+                public bool IsCompleted {
+                        get { return isCompleted; } 
+                }
+
+                public bool CompletedSynchronously {
+                        get { return false; } 
+                }
+
+                public Response Response {
+                        get { return response; }
+                        set {
+                                asyncWaitHandle.WaitOne();
+                                response = value;
+                                isCompleted = true;
+                                asyncWaitHandle.ReleaseMutex();
+                        }
+                } 
+        } 
+}

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

Added: incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Transport/Transport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Transport/Transport.cs?rev=367566&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Transport/Transport.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/OpenWire.Core/Transport/Transport.cs Tue Jan 10 02:56:34 2006
@@ -0,0 +1,24 @@
+using System;
+
+using OpenWire.Core;
+using OpenWire.Core.Commands;
+
+namespace OpenWire.Core.Transport {
+        
+        public delegate void CommandHandler(Transport sender, Command command);
+        public delegate void ExceptionHandler(Transport sender, Exception command);
+
+        /// <summary>
+        /// Represents the logical networking transport layer.
+        /// </summary>
+        public interface Transport {
+                void Oneway(Command command);
+
+                FutureResponse AsyncRequest(Command command);
+
+                Response Request(Command command);
+
+                event CommandHandler Command;
+                event ExceptionHandler Exception; 
+        } 
+}

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



Mime
View raw message