activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r383295 [3/4] - in /incubator/activemq/trunk/openwire-dotnet: src/ src/ActiveMQ/ src/ActiveMQ/Commands/ src/ActiveMQ/OpenWire/ src/ActiveMQ/OpenWire/Commands/ src/ActiveMQ/OpenWire/V1/ src/ActiveMQ/Transport/ src/JMS/ tests/ tests/ActiveMQ/...
Date Sun, 05 Mar 2006 08:29:09 GMT
Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/TransactionInfo.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,79 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+    //
+    //  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-core module
+    //
+    public class TransactionInfo : BaseCommand
+    {
+        public const byte ID_TransactionInfo = 7;
+    			
+        ConnectionId connectionId;
+        TransactionId transactionId;
+        byte type;
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " ConnectionId=" + ConnectionId
+                + " TransactionId=" + TransactionId
+                + " Type=" + Type
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_TransactionInfo;
+        }
+
+
+        // Properties
+
+        public ConnectionId ConnectionId
+        {
+            get { return connectionId; }
+            set { this.connectionId = value; }            
+        }
+
+        public TransactionId TransactionId
+        {
+            get { return transactionId; }
+            set { this.transactionId = value; }            
+        }
+
+        public byte Type
+        {
+            get { return type; }
+            set { this.type = value; }            
+        }
+
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/WireFormatInfo.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/WireFormatInfo.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/WireFormatInfo.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/WireFormatInfo.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,111 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+    //
+    //  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-core module
+    //
+    public class WireFormatInfo : AbstractCommand
+    {
+        public const byte ID_WireFormatInfo = 1;
+    			
+        byte[] magic;
+        int version;
+        bool cacheEnabled;
+        bool stackTraceEnabled;
+        bool tcpNoDelayEnabled;
+        bool prefixPacketSize;
+        bool tightEncodingEnabled;
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " Magic=" + Magic
+                + " Version=" + Version
+                + " CacheEnabled=" + CacheEnabled
+                + " StackTraceEnabled=" + StackTraceEnabled
+                + " TcpNoDelayEnabled=" + TcpNoDelayEnabled
+                + " PrefixPacketSize=" + PrefixPacketSize
+                + " TightEncodingEnabled=" + TightEncodingEnabled
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_WireFormatInfo;
+        }
+
+
+        // Properties
+
+        public byte[] Magic
+        {
+            get { return magic; }
+            set { this.magic = value; }            
+        }
+
+        public int Version
+        {
+            get { return version; }
+            set { this.version = value; }            
+        }
+
+        public bool CacheEnabled
+        {
+            get { return cacheEnabled; }
+            set { this.cacheEnabled = value; }            
+        }
+
+        public bool StackTraceEnabled
+        {
+            get { return stackTraceEnabled; }
+            set { this.stackTraceEnabled = value; }            
+        }
+
+        public bool TcpNoDelayEnabled
+        {
+            get { return tcpNoDelayEnabled; }
+            set { this.tcpNoDelayEnabled = value; }            
+        }
+
+        public bool PrefixPacketSize
+        {
+            get { return prefixPacketSize; }
+            set { this.prefixPacketSize = value; }            
+        }
+
+        public bool TightEncodingEnabled
+        {
+            get { return tightEncodingEnabled; }
+            set { this.tightEncodingEnabled = value; }            
+        }
+
+    }
+}

Added: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/XATransactionId.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/XATransactionId.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/XATransactionId.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/XATransactionId.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,105 @@
+/*
+* Copyright 2006 The Apache Software Foundation or its licensors, as
+* applicable.
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*     http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+using System;
+using System.Collections;
+
+using ActiveMQ.OpenWire;
+using ActiveMQ.Commands;
+
+namespace ActiveMQ.Commands
+{
+    //
+    //  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-core module
+    //
+    public class XATransactionId : TransactionId
+    {
+        public const byte ID_XATransactionId = 112;
+    			
+        int formatId;
+        byte[] globalTransactionId;
+        byte[] branchQualifier;
+
+		public override int GetHashCode() {
+            int answer = 0;
+            answer = (answer * 37) + HashCode(FormatId);
+            answer = (answer * 37) + HashCode(GlobalTransactionId);
+            answer = (answer * 37) + HashCode(BranchQualifier);
+            return answer;
+
+		}
+	
+
+		public override bool Equals(object that) {
+	    	if (that is XATransactionId) {
+	    	    return Equals((XATransactionId) that);
+			}
+			return false;
+    	}
+    
+		public virtual bool Equals(XATransactionId that) {
+            if (! Equals(this.FormatId, that.FormatId)) return false;
+            if (! Equals(this.GlobalTransactionId, that.GlobalTransactionId)) return false;
+            if (! Equals(this.BranchQualifier, that.BranchQualifier)) return false;
+            return true;
+
+		}
+	
+
+		public override string ToString() {
+            return GetType().Name + "["
+                + " FormatId=" + FormatId
+                + " GlobalTransactionId=" + GlobalTransactionId
+                + " BranchQualifier=" + BranchQualifier
+                + " ]";
+
+		}
+	
+
+
+        public override byte GetDataStructureType() {
+            return ID_XATransactionId;
+        }
+
+
+        // Properties
+
+        public int FormatId
+        {
+            get { return formatId; }
+            set { this.formatId = value; }            
+        }
+
+        public byte[] GlobalTransactionId
+        {
+            get { return globalTransactionId; }
+            set { this.globalTransactionId = value; }            
+        }
+
+        public byte[] BranchQualifier
+        {
+            get { return branchQualifier; }
+            set { this.branchQualifier = value; }            
+        }
+
+    }
+}

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Connection.cs Sun Mar  5 00:28:53 2006
@@ -1,9 +1,9 @@
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.Transport;
+using JMS;
 using System;
 using System.Collections;
-using System.Threading;
-
-using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionClosedException.cs Sun Mar  5 00:28:53 2006
@@ -18,7 +18,6 @@
 using System.Collections;
 
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConnectionFactory.cs Sun Mar  5 00:28:53 2006
@@ -14,11 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+using ActiveMQ.Commands;
+using ActiveMQ.Transport;
+using JMS;
 using System;
-using System.Collections;
-
-using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/ConsumerClosedException.cs Sun Mar  5 00:28:53 2006
@@ -18,7 +18,6 @@
 using System.Collections;
 
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/DestinationFilter.cs Sun Mar  5 00:28:53 2006
@@ -14,10 +14,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+using ActiveMQ.Commands;
 using System;
-
-using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageConsumer.cs Sun Mar  5 00:28:53 2006
@@ -14,12 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-using System;
-using System.Collections;
-using System.Threading;
-
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
+using JMS;
+using System.Threading;
 
 namespace ActiveMQ
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/MessageProducer.cs Sun Mar  5 00:28:53 2006
@@ -14,10 +14,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-using System;
-
-using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
+using ActiveMQ.Commands;
+using JMS;
 
 namespace ActiveMQ
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/AbstractCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/AbstractCommand.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/AbstractCommand.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/AbstractCommand.cs Sun Mar  5 00:28:53 2006
@@ -14,9 +14,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+using ActiveMQ.Commands;
 using System;
-using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ.OpenWire
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BaseDataStreamMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -14,14 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+using ActiveMQ.Commands;
 using System;
+using System.Collections;
 using System.IO;
-using System.Net;
 using System.Text;
-using System.Collections;
-
-using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ.OpenWire
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BooleanStream.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BooleanStream.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BooleanStream.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/BooleanStream.cs Sun Mar  5 00:28:53 2006
@@ -18,7 +18,6 @@
 using System.IO;
 
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ.OpenWire
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/DataStructureSupport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/DataStructureSupport.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/DataStructureSupport.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/DataStructureSupport.cs Sun Mar  5 00:28:53 2006
@@ -17,7 +17,6 @@
 using System;
 
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ.OpenWire
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/Dispatcher.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/Dispatcher.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/Dispatcher.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/Dispatcher.cs Sun Mar  5 00:28:53 2006
@@ -14,11 +14,11 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-using System.Collections;
+using ActiveMQ.Commands;
+using JMS;
 using System;
+using System.Collections;
 using System.Threading;
-
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ.OpenWire
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/FutureResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/FutureResponse.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/FutureResponse.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/FutureResponse.cs Sun Mar  5 00:28:53 2006
@@ -14,10 +14,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+using ActiveMQ.Commands;
 using System;
 using System.Threading;
-
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ.OpenWire
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/MessagePropertyHelper.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/MessagePropertyHelper.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/MessagePropertyHelper.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/MessagePropertyHelper.cs Sun Mar  5 00:28:53 2006
@@ -14,10 +14,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
 */
-using System;
+using ActiveMQ.Commands;
 using System.Collections;
-
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ.OpenWire
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/OpenWireFormat.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/OpenWireFormat.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/OpenWireFormat.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/OpenWireFormat.cs Sun Mar  5 00:28:53 2006
@@ -14,11 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire.V1;
 using System;
 using System.IO;
-
-using ActiveMQ.OpenWire.Commands;
-using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire
 {

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/PrimitiveMap.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/PrimitiveMap.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/PrimitiveMap.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/PrimitiveMap.cs Sun Mar  5 00:28:53 2006
@@ -14,6 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
 */
+using JMS;
 using System;
 using System.Collections;
 

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQBytesMessageMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQDestinationMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMapMessageMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQMessageMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQObjectMessageMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQQueueMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQStreamMessageMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempDestinationMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempQueueMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTempTopicMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTextMessageMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ActiveMQTopicMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BaseCommandMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerIdMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/BrokerInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionErrorMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionIdMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConnectionInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerIdMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ConsumerInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ControlCommandMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataArrayResponseMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataResponseMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DataStructureSupportMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -20,7 +20,6 @@
 using System.IO;
 
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DestinationInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/DiscoveryEventMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ExceptionResponseMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/FlushCommandMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/IntegerResponseMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalQueueAckMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTopicAckMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTraceMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/JournalTransactionMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/KeepAliveInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/LocalTransactionIdMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MarshallerFactory.cs Sun Mar  5 00:28:53 2006
@@ -1,90 +1,90 @@
-//
-//
-// Copyright 2005-2006 The Apache Software Foundation
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-//
-
-// 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 System.IO;
-
-using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
-using ActiveMQ.OpenWire.V1;
-
-namespace ActiveMQ.OpenWire.V1
-{
-    public class MarshallerFactory
-    {
-        public void configure(OpenWireFormat format) 
-        {
-
-            format.addMarshaller(new MessageIdMarshaller());
-            format.addMarshaller(new BrokerInfoMarshaller());
-            format.addMarshaller(new ActiveMQTempQueueMarshaller());
-            format.addMarshaller(new LocalTransactionIdMarshaller());
-            format.addMarshaller(new RemoveSubscriptionInfoMarshaller());
-            format.addMarshaller(new IntegerResponseMarshaller());
-            format.addMarshaller(new ActiveMQQueueMarshaller());
-            format.addMarshaller(new DestinationInfoMarshaller());
-            format.addMarshaller(new ActiveMQBytesMessageMarshaller());
-            format.addMarshaller(new ShutdownInfoMarshaller());
-            format.addMarshaller(new DataResponseMarshaller());
-            format.addMarshaller(new SessionIdMarshaller());
-            format.addMarshaller(new DataArrayResponseMarshaller());
-            format.addMarshaller(new JournalQueueAckMarshaller());
-            format.addMarshaller(new WireFormatInfoMarshaller());
-            format.addMarshaller(new ResponseMarshaller());
-            format.addMarshaller(new ConnectionErrorMarshaller());
-            format.addMarshaller(new ActiveMQObjectMessageMarshaller());
-            format.addMarshaller(new ConsumerInfoMarshaller());
-            format.addMarshaller(new ActiveMQTempTopicMarshaller());
-            format.addMarshaller(new ConnectionIdMarshaller());
-            format.addMarshaller(new DiscoveryEventMarshaller());
-            format.addMarshaller(new ConnectionInfoMarshaller());
-            format.addMarshaller(new KeepAliveInfoMarshaller());
-            format.addMarshaller(new XATransactionIdMarshaller());
-            format.addMarshaller(new JournalTraceMarshaller());
-            format.addMarshaller(new FlushCommandMarshaller());
-            format.addMarshaller(new ConsumerIdMarshaller());
-            format.addMarshaller(new JournalTopicAckMarshaller());
-            format.addMarshaller(new ActiveMQTextMessageMarshaller());
-            format.addMarshaller(new BrokerIdMarshaller());
-            format.addMarshaller(new MessageDispatchMarshaller());
-            format.addMarshaller(new ProducerInfoMarshaller());
-            format.addMarshaller(new SubscriptionInfoMarshaller());
-            format.addMarshaller(new ActiveMQMapMessageMarshaller());
-            format.addMarshaller(new MessageDispatchNotificationMarshaller());
-            format.addMarshaller(new SessionInfoMarshaller());
-            format.addMarshaller(new ActiveMQMessageMarshaller());
-            format.addMarshaller(new TransactionInfoMarshaller());
-            format.addMarshaller(new ActiveMQStreamMessageMarshaller());
-            format.addMarshaller(new MessageAckMarshaller());
-            format.addMarshaller(new ProducerIdMarshaller());
-            format.addMarshaller(new ActiveMQTopicMarshaller());
-            format.addMarshaller(new JournalTransactionMarshaller());
-            format.addMarshaller(new RemoveInfoMarshaller());
-            format.addMarshaller(new ControlCommandMarshaller());
-            format.addMarshaller(new ExceptionResponseMarshaller());
-    	}
-    }
-}
+//
+//
+// Copyright 2005-2006 The Apache Software Foundation
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+
+// 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 System.IO;
+
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.OpenWire.V1;
+
+namespace ActiveMQ.OpenWire.V1
+{
+    public class MarshallerFactory
+    {
+        public void configure(OpenWireFormat format) 
+        {
+
+            format.addMarshaller(new MessageIdMarshaller());
+            format.addMarshaller(new BrokerInfoMarshaller());
+            format.addMarshaller(new ActiveMQTempQueueMarshaller());
+            format.addMarshaller(new LocalTransactionIdMarshaller());
+            format.addMarshaller(new RemoveSubscriptionInfoMarshaller());
+            format.addMarshaller(new IntegerResponseMarshaller());
+            format.addMarshaller(new ActiveMQQueueMarshaller());
+            format.addMarshaller(new DestinationInfoMarshaller());
+            format.addMarshaller(new ActiveMQBytesMessageMarshaller());
+            format.addMarshaller(new ShutdownInfoMarshaller());
+            format.addMarshaller(new DataResponseMarshaller());
+            format.addMarshaller(new SessionIdMarshaller());
+            format.addMarshaller(new DataArrayResponseMarshaller());
+            format.addMarshaller(new JournalQueueAckMarshaller());
+            format.addMarshaller(new WireFormatInfoMarshaller());
+            format.addMarshaller(new ResponseMarshaller());
+            format.addMarshaller(new ConnectionErrorMarshaller());
+            format.addMarshaller(new ActiveMQObjectMessageMarshaller());
+            format.addMarshaller(new ConsumerInfoMarshaller());
+            format.addMarshaller(new ActiveMQTempTopicMarshaller());
+            format.addMarshaller(new ConnectionIdMarshaller());
+            format.addMarshaller(new DiscoveryEventMarshaller());
+            format.addMarshaller(new ConnectionInfoMarshaller());
+            format.addMarshaller(new KeepAliveInfoMarshaller());
+            format.addMarshaller(new XATransactionIdMarshaller());
+            format.addMarshaller(new JournalTraceMarshaller());
+            format.addMarshaller(new FlushCommandMarshaller());
+            format.addMarshaller(new ConsumerIdMarshaller());
+            format.addMarshaller(new JournalTopicAckMarshaller());
+            format.addMarshaller(new ActiveMQTextMessageMarshaller());
+            format.addMarshaller(new BrokerIdMarshaller());
+            format.addMarshaller(new MessageDispatchMarshaller());
+            format.addMarshaller(new ProducerInfoMarshaller());
+            format.addMarshaller(new SubscriptionInfoMarshaller());
+            format.addMarshaller(new ActiveMQMapMessageMarshaller());
+            format.addMarshaller(new MessageDispatchNotificationMarshaller());
+            format.addMarshaller(new SessionInfoMarshaller());
+            format.addMarshaller(new ActiveMQMessageMarshaller());
+            format.addMarshaller(new TransactionInfoMarshaller());
+            format.addMarshaller(new ActiveMQStreamMessageMarshaller());
+            format.addMarshaller(new MessageAckMarshaller());
+            format.addMarshaller(new ProducerIdMarshaller());
+            format.addMarshaller(new ActiveMQTopicMarshaller());
+            format.addMarshaller(new JournalTransactionMarshaller());
+            format.addMarshaller(new RemoveInfoMarshaller());
+            format.addMarshaller(new ControlCommandMarshaller());
+            format.addMarshaller(new ExceptionResponseMarshaller());
+    	}
+    }
+}

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageAckMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageDispatchNotificationMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageIdMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/MessageMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerIdMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ProducerInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/RemoveSubscriptionInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ResponseMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionIdMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SessionInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/ShutdownInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/SubscriptionInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionIdMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/TransactionInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/WireFormatInfoMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/V1/XATransactionIdMarshaller.cs Sun Mar  5 00:28:53 2006
@@ -19,8 +19,8 @@
 using System.Collections;
 using System.IO;
 
+using ActiveMQ.Commands;
 using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 using ActiveMQ.OpenWire.V1;
 
 namespace ActiveMQ.OpenWire.V1

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs?rev=383295&r1=383294&r2=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Session.cs Sun Mar  5 00:28:53 2006
@@ -14,11 +14,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+using ActiveMQ.Commands;
+using JMS;
 using System;
 using System.Collections;
-
-using ActiveMQ.OpenWire;
-using ActiveMQ.OpenWire.Commands;
 
 namespace ActiveMQ
 {

Copied: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/TransactionContext.cs (from r383283, incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/TransactionContext.cs)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/TransactionContext.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/TransactionContext.cs&p1=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/TransactionContext.cs&r1=383283&r2=383295&rev=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/TransactionContext.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/TransactionContext.cs Sun Mar  5 00:28:53 2006
@@ -14,25 +14,29 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
 using System.Collections;
-using System;
 
-using ActiveMQ.OpenWire.Commands;
 
-namespace ActiveMQ.OpenWire
+namespace ActiveMQ
 {
-    public enum TransactionType
+	public enum TransactionType
     {
         Begin = 0, Prepare = 1, CommitOnePhase = 2, CommitTwoPhase = 3, Rollback = 4, Recover=5, Forget = 6, End = 7
     }
-    
-    public class TransactionContext
+}
+
+namespace ActiveMQ
+{
+	public class TransactionContext
     {
         private TransactionId transactionId;
         private Session session;
         private ArrayList synchronizations = new ArrayList();
         
-        public TransactionContext(Session session) {
+        public TransactionContext(Session session)
+		{
             this.session = session;
         }
         
@@ -78,7 +82,8 @@
                 session.Connection.OneWay(info);
             }
             
-            foreach (ISynchronization synchronization in synchronizations) {
+            foreach (ISynchronization synchronization in synchronizations)
+			{
                 synchronization.AfterRollback();
             }
             synchronizations.Clear();
@@ -86,7 +91,8 @@
         
         public void Commit()
         {
-            foreach (ISynchronization synchronization in synchronizations) {
+            foreach (ISynchronization synchronization in synchronizations)
+			{
                 synchronization.BeforeCommit();
             }
             
@@ -101,10 +107,12 @@
                 session.Connection.OneWay(info);
             }
             
-            foreach (ISynchronization synchronization in synchronizations) {
+            foreach (ISynchronization synchronization in synchronizations)
+			{
                 synchronization.AfterCommit();
             }
             synchronizations.Clear();
         }
     }
 }
+

Copied: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs (from r383283, incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/ITransport.cs)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs&p1=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/ITransport.cs&r1=383283&r2=383295&rev=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/ITransport.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs Sun Mar  5 00:28:53 2006
@@ -14,20 +14,28 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using JMS;
 using System;
 
-using ActiveMQ.OpenWire.Commands;
 
-namespace ActiveMQ.OpenWire
+
+namespace ActiveMQ.Transport
+{
+	public delegate void CommandHandler(ITransport sender, Command command);
+}
+namespace ActiveMQ.Transport
 {
-    
-    public delegate void CommandHandler(ITransport sender, Command command);
-    public delegate void ExceptionHandler(ITransport sender, Exception command);
-    
-    /// <summary>
-    /// Represents the logical networking transport layer.
-    /// </summary>
-    public interface ITransport : IStartable, IDisposable
+	public delegate void ExceptionHandler(ITransport sender, Exception command);
+}
+
+/// <summary>
+/// Represents the logical networking transport layer.
+/// </summary>
+namespace ActiveMQ.Transport
+{
+	public interface ITransport : IStartable, IDisposable
     {
         void Oneway(Command command);
         
@@ -39,3 +47,4 @@
         event ExceptionHandler Exception;
     }
 }
+

Copied: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/SocketTransport.cs (from r383283, incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/SocketTransport.cs)
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/SocketTransport.cs?p2=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/SocketTransport.cs&p1=incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/SocketTransport.cs&r1=383283&r2=383295&rev=383295&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/OpenWire/SocketTransport.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/SocketTransport.cs Sun Mar  5 00:28:53 2006
@@ -14,23 +14,23 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
 using System;
 using System.Collections;
 using System.IO;
 using System.Net;
 using System.Net.Sockets;
-using System.Text;
 using System.Threading;
 
-using ActiveMQ.OpenWire.Commands;
 
-namespace ActiveMQ.OpenWire
+
+/// <summary>
+/// An implementation of ITransport that uses sockets to communicate with the broker
+/// </summary>
+namespace ActiveMQ.Transport
 {
-    
-    /// <summary>
-    /// An implementation of ITransport that uses sockets to communicate with the broker
-    /// </summary>
-    public class SocketTransport : ITransport
+	public class SocketTransport : ITransport
     {
         private readonly object transmissionLock = new object();
         private Socket socket;
@@ -222,4 +222,5 @@
         }
     }
 }
+
 

Added: incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+using JMS;
+
+
+/// <summary>
+/// Represents a binary based message
+/// </summary>
+namespace JMS
+{
+	public interface IBytesMessage : IMessage
+    {
+        
+        byte[] Content
+        {
+            get;
+            set;
+        }
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnection.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnection.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnection.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnection.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,61 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+using JMS;
+using System;
+
+namespace JMS
+{
+	public enum AcknowledgementMode
+    {
+        Unknown, AutoAcknowledge, ClientAcknowledge, Transactional
+    }
+
+	/// <summary>
+	/// Represents a connection with a message broker
+	/// </summary>
+	public interface IConnection : IDisposable, IStartable, IStoppable
+    {
+        
+        /// <summary>
+        /// Creates a new session to work on this connection
+        /// </summary>
+        ISession CreateSession();
+        
+        /// <summary>
+        /// Creates a new session to work on this connection
+        /// </summary>
+        ISession CreateSession(AcknowledgementMode acknowledgementMode);
+        
+        
+        // Properties
+        
+        AcknowledgementMode AcknowledgementMode
+        {
+            get;
+            set;
+        }
+        
+        String ClientId
+        {
+            get;
+            set;
+        }
+        
+        
+    }
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,40 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+using JMS;
+
+
+
+/// <summary>
+/// A Factory of IConnection objects
+/// </summary>
+namespace JMS
+{
+	public interface IConnectionFactory
+	{
+		
+		/// <summary>
+		/// Creates a new connection
+		/// </summary>
+		IConnection CreateConnection();
+		
+		/// <summary>
+		/// Creates a new connection with the given user name and password
+		/// </summary>
+		IConnection CreateConnection(string userName, string password);
+	}
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,29 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+
+
+/// <summary>
+/// Summary description for Destination.
+/// </summary>
+namespace JMS
+{
+	public interface IDestination
+	{
+	}
+}
+

Added: incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs?rev=383295&view=auto
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs (added)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs Sun Mar  5 00:28:53 2006
@@ -0,0 +1,35 @@
+/*
+ * Copyright 2006 The Apache Software Foundation or its licensors, as
+ * applicable.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+using JMS;
+
+
+/// <summary>
+/// Represents a Map message which contains key and value pairs which are
+/// of primitive types
+/// </summary>
+namespace JMS
+{
+	public interface IMapMessage : IMessage
+    {
+        IPrimitiveMap Body
+		{
+            get;
+        }
+    }
+}
+
+



Mime
View raw message