svn commit: r387665 [7/9] - in /incubator/activemq/trunk: activecluster/src/java/org/apache/activecluster/impl/ activemq-core/src/main/java/org/apache/activemq/advisory/ activemq-core/src/main/java/org/apache/activemq/broker/jmx/ activemq-core/src/main...

[ch...@apache.org]

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/TransactionContext.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/TransactionContext.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/TransactionContext.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/TransactionContext.cs Tue Mar 21 15:20:55 2006
@@ -1,118 +1,118 @@
-/*
- * 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 ActiveMQ;
-using ActiveMQ.Commands;
-using System.Collections;
-
-
-namespace ActiveMQ
-{
-	public enum TransactionType
-    {
-        Begin = 0, Prepare = 1, CommitOnePhase = 2, CommitTwoPhase = 3, Rollback = 4, Recover=5, Forget = 6, End = 7
-    }
-}
-
-namespace ActiveMQ
-{
-	public class TransactionContext
-    {
-        private TransactionId transactionId;
-        private Session session;
-        private ArrayList synchronizations = new ArrayList();
-        
-        public TransactionContext(Session session)
-		{
-            this.session = session;
-        }
-        
-        public TransactionId TransactionId
-        {
-            get { return transactionId; }
-        }
-        
-        /// <summary>
-        /// Method AddSynchronization
-        /// </summary>
-        public void AddSynchronization(ISynchronization synchronization)
-        {
-            synchronizations.Add(synchronization);
-        }
-        
-        
-        public void Begin()
-        {
-            if (transactionId == null)
-            {
-                transactionId = session.Connection.CreateLocalTransactionId();
-                
-                TransactionInfo info = new TransactionInfo();
-                info.ConnectionId = session.Connection.ConnectionId;
-                info.TransactionId = transactionId;
-                info.Type = (int) TransactionType.Begin;
-                session.Connection.OneWay(info);
-            }
-        }
-        
-        
-        public void Rollback()
-        {
-            if (transactionId != null)
-            {
-                TransactionInfo info = new TransactionInfo();
-                info.ConnectionId = session.Connection.ConnectionId;
-                info.TransactionId = transactionId;
-                info.Type = (int) TransactionType.Rollback;
-                
-                transactionId = null;
-                session.Connection.OneWay(info);
-            }
-            
-            foreach (ISynchronization synchronization in synchronizations)
-			{
-                synchronization.AfterRollback();
-            }
-            synchronizations.Clear();
-        }
-        
-        public void Commit()
-        {
-            foreach (ISynchronization synchronization in synchronizations)
-			{
-                synchronization.BeforeCommit();
-            }
-            
-            if (transactionId != null)
-            {
-                TransactionInfo info = new TransactionInfo();
-                info.ConnectionId = session.Connection.ConnectionId;
-                info.TransactionId = transactionId;
-                info.Type = (int) TransactionType.CommitOnePhase;
-                
-                transactionId = null;
-                session.Connection.OneWay(info);
-            }
-            
-            foreach (ISynchronization synchronization in synchronizations)
-			{
-                synchronization.AfterCommit();
-            }
-            synchronizations.Clear();
-        }
-    }
-}
-
+/*
+ * 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 ActiveMQ;
+using ActiveMQ.Commands;
+using System.Collections;
+
+
+namespace ActiveMQ
+{
+	public enum TransactionType
+    {
+        Begin = 0, Prepare = 1, CommitOnePhase = 2, CommitTwoPhase = 3, Rollback = 4, Recover=5, Forget = 6, End = 7
+    }
+}
+
+namespace ActiveMQ
+{
+	public class TransactionContext
+    {
+        private TransactionId transactionId;
+        private Session session;
+        private ArrayList synchronizations = new ArrayList();
+        
+        public TransactionContext(Session session)
+		{
+            this.session = session;
+        }
+        
+        public TransactionId TransactionId
+        {
+            get { return transactionId; }
+        }
+        
+        /// <summary>
+        /// Method AddSynchronization
+        /// </summary>
+        public void AddSynchronization(ISynchronization synchronization)
+        {
+            synchronizations.Add(synchronization);
+        }
+        
+        
+        public void Begin()
+        {
+            if (transactionId == null)
+            {
+                transactionId = session.Connection.CreateLocalTransactionId();
+                
+                TransactionInfo info = new TransactionInfo();
+                info.ConnectionId = session.Connection.ConnectionId;
+                info.TransactionId = transactionId;
+                info.Type = (int) TransactionType.Begin;
+                session.Connection.OneWay(info);
+            }
+        }
+        
+        
+        public void Rollback()
+        {
+            if (transactionId != null)
+            {
+                TransactionInfo info = new TransactionInfo();
+                info.ConnectionId = session.Connection.ConnectionId;
+                info.TransactionId = transactionId;
+                info.Type = (int) TransactionType.Rollback;
+                
+                transactionId = null;
+                session.Connection.OneWay(info);
+            }
+            
+            foreach (ISynchronization synchronization in synchronizations)
+			{
+                synchronization.AfterRollback();
+            }
+            synchronizations.Clear();
+        }
+        
+        public void Commit()
+        {
+            foreach (ISynchronization synchronization in synchronizations)
+			{
+                synchronization.BeforeCommit();
+            }
+            
+            if (transactionId != null)
+            {
+                TransactionInfo info = new TransactionInfo();
+                info.ConnectionId = session.Connection.ConnectionId;
+                info.TransactionId = transactionId;
+                info.Type = (int) TransactionType.CommitOnePhase;
+                
+                transactionId = null;
+                session.Connection.OneWay(info);
+            }
+            
+            foreach (ISynchronization synchronization in synchronizations)
+			{
+                synchronization.AfterCommit();
+            }
+            synchronizations.Clear();
+        }
+    }
+}
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/TransactionContext.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/ITransportFactory.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/ITransportFactory.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/ITransportFactory.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/ITransportFactory.cs Tue Mar 21 15:20:55 2006
@@ -1,26 +1,26 @@
-/*
- * 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;
-
-namespace ActiveMQ.Transport
-{
-	public interface ITransportFactory
-    {
-		ITransport CreateTransport(Uri location);
-	}
-}
+/*
+ * 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;
+
+namespace ActiveMQ.Transport
+{
+	public interface ITransportFactory
+    {
+		ITransport CreateTransport(Uri location);
+	}
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/ITransportFactory.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/LoggingTransport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/LoggingTransport.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/LoggingTransport.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/LoggingTransport.cs Tue Mar 21 15:20:55 2006
@@ -1,50 +1,50 @@
-/*
- * 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 ActiveMQ.Commands;
-using ActiveMQ.Transport;
-using System;
-
-namespace ActiveMQ.Transport
-{
-	
-	/// <summary>
-	/// A Transport filter that is used to log the commands sent and received.
-	/// </summary>
-	public class LoggingTransport : TransportFilter
-    {
-		public LoggingTransport(ITransport next) : base(next) {
-		}
-		
-		protected override void OnCommand(ITransport sender, Command command) {
-			Console.WriteLine("RECEIVED: " + command);
-			this.commandHandler(sender, command);
-		}
-		
-		protected override void OnException(ITransport sender, Exception error) {
-			Console.WriteLine("RECEIVED Exception: " + error);
-			this.exceptionHandler(sender, error);
-		}
-		
-		public override void Oneway(Command command)
-		{
-			Console.WriteLine("SENDING: " + command);
-			this.next.Oneway(command);
-		}
-				
-    }
-}
-
+/*
+ * 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 ActiveMQ.Commands;
+using ActiveMQ.Transport;
+using System;
+
+namespace ActiveMQ.Transport
+{
+	
+	/// <summary>
+	/// A Transport filter that is used to log the commands sent and received.
+	/// </summary>
+	public class LoggingTransport : TransportFilter
+    {
+		public LoggingTransport(ITransport next) : base(next) {
+		}
+		
+		protected override void OnCommand(ITransport sender, Command command) {
+			Console.WriteLine("RECEIVED: " + command);
+			this.commandHandler(sender, command);
+		}
+		
+		protected override void OnException(ITransport sender, Exception error) {
+			Console.WriteLine("RECEIVED Exception: " + error);
+			this.exceptionHandler(sender, error);
+		}
+		
+		public override void Oneway(Command command)
+		{
+			Console.WriteLine("SENDING: " + command);
+			this.next.Oneway(command);
+		}
+				
+    }
+}
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/LoggingTransport.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/MutexTransport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/MutexTransport.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/MutexTransport.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/MutexTransport.cs Tue Mar 21 15:20:55 2006
@@ -1,70 +1,70 @@
-/*
- * 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 ActiveMQ.Commands;
-using ActiveMQ.Transport;
-using System;
-
-namespace ActiveMQ.Transport
-{
-	
-	/// <summary>
-	/// A Transport which gaurds access to the next transport using a mutex.
-	/// </summary>
-	public class MutexTransport : TransportFilter
-    {
-		
-		private readonly object transmissionLock = new object();
-		
-		public MutexTransport(ITransport next) : base(next) {
-		}
-		
-		
-		public override void Oneway(Command command)
-		{
-            lock (transmissionLock)
-            {
-				this.next.Oneway(command);
-			}
-		}
-		
-		public override FutureResponse AsyncRequest(Command command)
-		{
-            lock (transmissionLock)
-            {
-				return base.AsyncRequest(command);
-			}
-		}
-		
-		public override Response Request(Command command)
-		{
-            lock (transmissionLock)
-            {
-				return base.Request(command);
-			}
-		}
-		
-		public override void Dispose()
-		{
-            lock (transmissionLock)
-            {
-				base.Dispose();
-			}
-		}
-		
-    }
-}
-
+/*
+ * 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 ActiveMQ.Commands;
+using ActiveMQ.Transport;
+using System;
+
+namespace ActiveMQ.Transport
+{
+	
+	/// <summary>
+	/// A Transport which gaurds access to the next transport using a mutex.
+	/// </summary>
+	public class MutexTransport : TransportFilter
+    {
+		
+		private readonly object transmissionLock = new object();
+		
+		public MutexTransport(ITransport next) : base(next) {
+		}
+		
+		
+		public override void Oneway(Command command)
+		{
+            lock (transmissionLock)
+            {
+				this.next.Oneway(command);
+			}
+		}
+		
+		public override FutureResponse AsyncRequest(Command command)
+		{
+            lock (transmissionLock)
+            {
+				return base.AsyncRequest(command);
+			}
+		}
+		
+		public override Response Request(Command command)
+		{
+            lock (transmissionLock)
+            {
+				return base.Request(command);
+			}
+		}
+		
+		public override void Dispose()
+		{
+            lock (transmissionLock)
+            {
+				base.Dispose();
+			}
+		}
+		
+    }
+}
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/MutexTransport.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/ResponseCorrelator.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/ResponseCorrelator.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/ResponseCorrelator.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/ResponseCorrelator.cs Tue Mar 21 15:20:55 2006
@@ -1,104 +1,104 @@
-/*
- * 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.Commands;
-using ActiveMQ.Transport;
-
-namespace ActiveMQ.Transport
-{
-	
-	/// <summary>
-	/// A Transport which gaurds access to the next transport using a mutex.
-	/// </summary>
-	public class ResponseCorrelator : TransportFilter
-    {
-
-        private readonly IDictionary requestMap = Hashtable.Synchronized(new Hashtable());
-        private readonly Object mutex = new Object();
-        private short nextCommandId;
-		
-		public ResponseCorrelator(ITransport next) : base(next) {
-		}
-
-		short GetNextCommandId() {
-			lock(mutex) {
-				return ++nextCommandId;
-			}
-		}
-		
-		public override void Oneway(Command command)
-		{
-			command.CommandId = GetNextCommandId();
-			command.ResponseRequired = false;
-			next.Oneway(command);
-		}
-		
-		public override FutureResponse AsyncRequest(Command command)
-		{
-			command.CommandId = GetNextCommandId();
-			command.ResponseRequired = true;
-			FutureResponse future = new FutureResponse();
-			requestMap[command.CommandId] = future;
-			next.Oneway(command);
-			return future;
-
-		}
-		
-		public override Response Request(Command command)
-		{
-			FutureResponse future = AsyncRequest(command);
-            Response response = future.Response;
-            if (response is ExceptionResponse)
-            {
-                ExceptionResponse er = (ExceptionResponse) response;
-                BrokerError brokerError = er.Exception;
-                throw new BrokerException(brokerError);
-            }
-            return response;
-		}
-		
-		protected override void OnCommand(ITransport sender, Command command)
-		{
-			if( command is Response ) {
-				
-				Response response = (Response) command;
-				FutureResponse future = (FutureResponse) requestMap[response.CorrelationId];
-				if (future != null)
-				{
-					if (response is ExceptionResponse)
-					{
-						ExceptionResponse er = (ExceptionResponse) response;
-						BrokerError brokerError = er.Exception;
-						this.exceptionHandler(this, new BrokerException(brokerError));
-					}
-					future.Response = response;
-				}
-				else
-				{
-					Console.WriteLine("ERROR: Unknown response ID: " + response.CommandId + " for response: " + response);
-				}
-			} else {
-				this.commandHandler(sender, command);
-			}
-		}
-		
-    }
-}
-
+/*
+ * 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.Commands;
+using ActiveMQ.Transport;
+
+namespace ActiveMQ.Transport
+{
+	
+	/// <summary>
+	/// A Transport which gaurds access to the next transport using a mutex.
+	/// </summary>
+	public class ResponseCorrelator : TransportFilter
+    {
+
+        private readonly IDictionary requestMap = Hashtable.Synchronized(new Hashtable());
+        private readonly Object mutex = new Object();
+        private short nextCommandId;
+		
+		public ResponseCorrelator(ITransport next) : base(next) {
+		}
+
+		short GetNextCommandId() {
+			lock(mutex) {
+				return ++nextCommandId;
+			}
+		}
+		
+		public override void Oneway(Command command)
+		{
+			command.CommandId = GetNextCommandId();
+			command.ResponseRequired = false;
+			next.Oneway(command);
+		}
+		
+		public override FutureResponse AsyncRequest(Command command)
+		{
+			command.CommandId = GetNextCommandId();
+			command.ResponseRequired = true;
+			FutureResponse future = new FutureResponse();
+			requestMap[command.CommandId] = future;
+			next.Oneway(command);
+			return future;
+
+		}
+		
+		public override Response Request(Command command)
+		{
+			FutureResponse future = AsyncRequest(command);
+            Response response = future.Response;
+            if (response is ExceptionResponse)
+            {
+                ExceptionResponse er = (ExceptionResponse) response;
+                BrokerError brokerError = er.Exception;
+                throw new BrokerException(brokerError);
+            }
+            return response;
+		}
+		
+		protected override void OnCommand(ITransport sender, Command command)
+		{
+			if( command is Response ) {
+				
+				Response response = (Response) command;
+				FutureResponse future = (FutureResponse) requestMap[response.CorrelationId];
+				if (future != null)
+				{
+					if (response is ExceptionResponse)
+					{
+						ExceptionResponse er = (ExceptionResponse) response;
+						BrokerError brokerError = er.Exception;
+						this.exceptionHandler(this, new BrokerException(brokerError));
+					}
+					future.Response = response;
+				}
+				else
+				{
+					Console.WriteLine("ERROR: Unknown response ID: " + response.CommandId + " for response: " + response);
+				}
+			} else {
+				this.commandHandler(sender, command);
+			}
+		}
+		
+    }
+}
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/ResponseCorrelator.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs Tue Mar 21 15:20:55 2006
@@ -1,152 +1,152 @@
-/*
- * 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 ActiveMQ;
-using ActiveMQ.Commands;
-using ActiveMQ.OpenWire;
-using ActiveMQ.Transport;
-using System;
-using System.Collections;
-using System.IO;
-using System.Net;
-using System.Net.Sockets;
-using System.Threading;
-
-namespace ActiveMQ.Transport.Tcp
-{
-	
-	/// <summary>
-	/// An implementation of ITransport that uses sockets to communicate with the broker
-	/// </summary>
-	public class TcpTransport : ITransport
-    {
-        private Socket socket;
-        private OpenWireFormat wireformat = new OpenWireFormat();
-        private BinaryReader socketReader;
-        private BinaryWriter socketWriter;
-        private Thread readThread;
-        private bool started;
-        volatile private bool closed;
-        
-        private CommandHandler commandHandler;
-        private ExceptionHandler exceptionHandler;
-        
-        public TcpTransport(Socket socket)
-        {
-			this.socket = socket;
-        }
-        
-        /// <summary>
-        /// Method Start
-        /// </summary>
-        public void Start()
-        {
-            if (!started)
-            {
-				if( commandHandler == null )
-					throw new InvalidOperationException ("command cannot be null when Start is called.");
-				if( exceptionHandler == null )
-					throw new InvalidOperationException ("exception cannot be null when Start is called.");
-				
-                started = true;
-                
-                NetworkStream networkStream = new NetworkStream(socket);
-                socketWriter = new OpenWireBinaryWriter(networkStream);
-                socketReader = new OpenWireBinaryReader(networkStream);
-                
-                // now lets create the background read thread
-                readThread = new Thread(new ThreadStart(ReadLoop));
-                readThread.Start();
-                
-                // lets send the wireformat we're using
-				WireFormatInfo info = new WireFormatInfo();
-				info.StackTraceEnabled=false;
-				info.TightEncodingEnabled=false;
-				info.TcpNoDelayEnabled=false;
-				info.CacheEnabled=false;
-				info.SizePrefixDisabled=false;
-				
-                Oneway(info);
-            }
-        }
-        
-		public void Oneway(Command command)
-        {
-			wireformat.Marshal(command, socketWriter);
-			socketWriter.Flush();
-        }
-        
-        public FutureResponse AsyncRequest(Command command)
-        {
-            throw new NotImplementedException("Use a ResponseCorrelator if you want to issue AsyncRequest calls");
-        }
-        
-        public Response Request(Command command)
-        {
-            throw new NotImplementedException("Use a ResponseCorrelator if you want to issue Request calls");
-        }
-        
-        public void Dispose()
-        {
-			closed = true;
-			socket.Close();
-			readThread.Join();
-            socketWriter.Close();
-            socketReader.Close();
-        }
-        
-        public void ReadLoop()
-        {
-            while (!closed)
-            {
-                try
-                {
-                    Command command = (Command) wireformat.Unmarshal(socketReader);
-					this.commandHandler(this, command);
-                }
-				catch (ObjectDisposedException)
-                {
-                    break;
-                }
-				catch ( Exception e) {
-					if( e.GetBaseException() is ObjectDisposedException ) {
-						break;
-					}
-					if( !closed ) {
-						this.exceptionHandler(this,e);
-					}
-					break;
-				}
-            }
-        }
-                
-        // Implementation methods
-                
-		public CommandHandler Command {
-            get { return commandHandler; }
-            set { this.commandHandler = value; }
-        }
-		
-        public  ExceptionHandler Exception {
-            get { return exceptionHandler; }
-            set { this.exceptionHandler = value; }
-        }
-		
-    }
-}
-
-
-
+/*
+ * 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 ActiveMQ;
+using ActiveMQ.Commands;
+using ActiveMQ.OpenWire;
+using ActiveMQ.Transport;
+using System;
+using System.Collections;
+using System.IO;
+using System.Net;
+using System.Net.Sockets;
+using System.Threading;
+
+namespace ActiveMQ.Transport.Tcp
+{
+	
+	/// <summary>
+	/// An implementation of ITransport that uses sockets to communicate with the broker
+	/// </summary>
+	public class TcpTransport : ITransport
+    {
+        private Socket socket;
+        private OpenWireFormat wireformat = new OpenWireFormat();
+        private BinaryReader socketReader;
+        private BinaryWriter socketWriter;
+        private Thread readThread;
+        private bool started;
+        volatile private bool closed;
+        
+        private CommandHandler commandHandler;
+        private ExceptionHandler exceptionHandler;
+        
+        public TcpTransport(Socket socket)
+        {
+			this.socket = socket;
+        }
+        
+        /// <summary>
+        /// Method Start
+        /// </summary>
+        public void Start()
+        {
+            if (!started)
+            {
+				if( commandHandler == null )
+					throw new InvalidOperationException ("command cannot be null when Start is called.");
+				if( exceptionHandler == null )
+					throw new InvalidOperationException ("exception cannot be null when Start is called.");
+				
+                started = true;
+                
+                NetworkStream networkStream = new NetworkStream(socket);
+                socketWriter = new OpenWireBinaryWriter(networkStream);
+                socketReader = new OpenWireBinaryReader(networkStream);
+                
+                // now lets create the background read thread
+                readThread = new Thread(new ThreadStart(ReadLoop));
+                readThread.Start();
+                
+                // lets send the wireformat we're using
+				WireFormatInfo info = new WireFormatInfo();
+				info.StackTraceEnabled=false;
+				info.TightEncodingEnabled=false;
+				info.TcpNoDelayEnabled=false;
+				info.CacheEnabled=false;
+				info.SizePrefixDisabled=false;
+				
+                Oneway(info);
+            }
+        }
+        
+		public void Oneway(Command command)
+        {
+			wireformat.Marshal(command, socketWriter);
+			socketWriter.Flush();
+        }
+        
+        public FutureResponse AsyncRequest(Command command)
+        {
+            throw new NotImplementedException("Use a ResponseCorrelator if you want to issue AsyncRequest calls");
+        }
+        
+        public Response Request(Command command)
+        {
+            throw new NotImplementedException("Use a ResponseCorrelator if you want to issue Request calls");
+        }
+        
+        public void Dispose()
+        {
+			closed = true;
+			socket.Close();
+			readThread.Join();
+            socketWriter.Close();
+            socketReader.Close();
+        }
+        
+        public void ReadLoop()
+        {
+            while (!closed)
+            {
+                try
+                {
+                    Command command = (Command) wireformat.Unmarshal(socketReader);
+					this.commandHandler(this, command);
+                }
+				catch (ObjectDisposedException)
+                {
+                    break;
+                }
+				catch ( Exception e) {
+					if( e.GetBaseException() is ObjectDisposedException ) {
+						break;
+					}
+					if( !closed ) {
+						this.exceptionHandler(this,e);
+					}
+					break;
+				}
+            }
+        }
+                
+        // Implementation methods
+                
+		public CommandHandler Command {
+            get { return commandHandler; }
+            set { this.commandHandler = value; }
+        }
+		
+        public  ExceptionHandler Exception {
+            get { return exceptionHandler; }
+            set { this.exceptionHandler = value; }
+        }
+		
+    }
+}
+
+
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransport.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransportFactory.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransportFactory.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransportFactory.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransportFactory.cs Tue Mar 21 15:20:55 2006
@@ -1,62 +1,62 @@
-/*
-* 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.Net;
-using System.Net.Sockets;
-using ActiveMQ.Transport;
-
-namespace ActiveMQ.Transport.Tcp
-{
-	public class TcpTransportFactory : ITransportFactory
-    {
-		public ITransport CreateTransport(Uri location) {
-			
-			// Console.WriteLine("Opening socket to: " + host + " on port: " + port);
-			Socket socket = Connect(location.Host, location.Port);
-			ITransport rc = new TcpTransport(socket);
-			// TODO: use URI query string to enable the LoggingTransport
-			 rc = new LoggingTransport(rc);
-			rc = new ResponseCorrelator(rc);
-			rc = new MutexTransport(rc);
-			return rc;
-			
-		}
-	
-		protected Socket Connect(string host, int port)
-        {
-            // Looping through the AddressList allows different type of connections to be tried
-            // (IPv4, IPv6 and whatever else may be available).
-            IPHostEntry hostEntry = Dns.Resolve(host);
-            foreach (IPAddress address in hostEntry.AddressList)
-            {
-                Socket socket = new Socket(
-                    address.AddressFamily,
-                    SocketType.Stream,
-                    ProtocolType.Tcp);
-                socket.Connect(new IPEndPoint(address, port));
-                if (socket.Connected)
-                {
-                    return socket;
-                }
-            }
-            throw new SocketException();
-        }
-		
-	}
-	
-}
+/*
+* 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.Net;
+using System.Net.Sockets;
+using ActiveMQ.Transport;
+
+namespace ActiveMQ.Transport.Tcp
+{
+	public class TcpTransportFactory : ITransportFactory
+    {
+		public ITransport CreateTransport(Uri location) {
+			
+			// Console.WriteLine("Opening socket to: " + host + " on port: " + port);
+			Socket socket = Connect(location.Host, location.Port);
+			ITransport rc = new TcpTransport(socket);
+			// TODO: use URI query string to enable the LoggingTransport
+			 rc = new LoggingTransport(rc);
+			rc = new ResponseCorrelator(rc);
+			rc = new MutexTransport(rc);
+			return rc;
+			
+		}
+	
+		protected Socket Connect(string host, int port)
+        {
+            // Looping through the AddressList allows different type of connections to be tried
+            // (IPv4, IPv6 and whatever else may be available).
+            IPHostEntry hostEntry = Dns.Resolve(host);
+            foreach (IPAddress address in hostEntry.AddressList)
+            {
+                Socket socket = new Socket(
+                    address.AddressFamily,
+                    SocketType.Stream,
+                    ProtocolType.Tcp);
+                socket.Connect(new IPEndPoint(address, port));
+                if (socket.Connected)
+                {
+                    return socket;
+                }
+            }
+            throw new SocketException();
+        }
+		
+	}
+	
+}

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/Tcp/TcpTransportFactory.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/TransportFilter.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/TransportFilter.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/TransportFilter.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/TransportFilter.cs Tue Mar 21 15:20:55 2006
@@ -1,109 +1,109 @@
-/*
- * 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 ActiveMQ.Commands;
-using ActiveMQ.Transport;
-using System;
-
-namespace ActiveMQ.Transport
-{
-	
-	/// <summary>
-	/// Used to implement a filter on the transport layer.
-	/// </summary>
-	public class TransportFilter : ITransport
-    {
-		protected readonly ITransport next;
-		protected CommandHandler commandHandler;
-		protected ExceptionHandler exceptionHandler;
-		
-		public TransportFilter(ITransport next) {
-			this.next = next;
-			this.next.Command = new CommandHandler(OnCommand);
-			this.next.Exception = new ExceptionHandler(OnException);
-		}
-		
-		protected virtual void OnCommand(ITransport sender, Command command) {
-			this.commandHandler(sender, command);
-		}
-		
-		protected virtual void OnException(ITransport sender, Exception command) {
-			this.exceptionHandler(sender, command);
-		}
-		
-		
-		/// <summary>
-		/// Method Oneway
-		/// </summary>
-		/// <param name="command">A  Command</param>
-		public virtual void Oneway(Command command)
-		{
-			this.next.Oneway(command);
-		}
-		
-		/// <summary>
-		/// Method AsyncRequest
-		/// </summary>
-		/// <returns>A FutureResponse</returns>
-		/// <param name="command">A  Command</param>
-		public virtual FutureResponse AsyncRequest(Command command)
-		{
-			return this.next.AsyncRequest(command);
-		}
-		
-		/// <summary>
-		/// Method Request
-		/// </summary>
-		/// <returns>A Response</returns>
-		/// <param name="command">A  Command</param>
-		public virtual Response Request(Command command)
-		{
-			return this.next.Request(command);
-		}
-		
-		/// <summary>
-		/// Method Start
-		/// </summary>
-		public virtual void Start()
-		{
-			if( commandHandler == null )
-				throw new InvalidOperationException ("command cannot be null when Start is called.");
-			if( exceptionHandler == null )
-				throw new InvalidOperationException ("exception cannot be null when Start is called.");
-			this.next.Start();
-		}
-		
-		/// <summary>
-		/// Method Dispose
-		/// </summary>
-		public virtual void Dispose()
-		{
-			this.next.Dispose();
-		}
-		
-		public CommandHandler Command {
-            get { return commandHandler; }
-            set { this.commandHandler = value; }
-        }
-		
-        public  ExceptionHandler Exception {
-            get { return exceptionHandler; }
-            set { this.exceptionHandler = value; }
-        }
-		
-    }
-}
-
+/*
+ * 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 ActiveMQ.Commands;
+using ActiveMQ.Transport;
+using System;
+
+namespace ActiveMQ.Transport
+{
+	
+	/// <summary>
+	/// Used to implement a filter on the transport layer.
+	/// </summary>
+	public class TransportFilter : ITransport
+    {
+		protected readonly ITransport next;
+		protected CommandHandler commandHandler;
+		protected ExceptionHandler exceptionHandler;
+		
+		public TransportFilter(ITransport next) {
+			this.next = next;
+			this.next.Command = new CommandHandler(OnCommand);
+			this.next.Exception = new ExceptionHandler(OnException);
+		}
+		
+		protected virtual void OnCommand(ITransport sender, Command command) {
+			this.commandHandler(sender, command);
+		}
+		
+		protected virtual void OnException(ITransport sender, Exception command) {
+			this.exceptionHandler(sender, command);
+		}
+		
+		
+		/// <summary>
+		/// Method Oneway
+		/// </summary>
+		/// <param name="command">A  Command</param>
+		public virtual void Oneway(Command command)
+		{
+			this.next.Oneway(command);
+		}
+		
+		/// <summary>
+		/// Method AsyncRequest
+		/// </summary>
+		/// <returns>A FutureResponse</returns>
+		/// <param name="command">A  Command</param>
+		public virtual FutureResponse AsyncRequest(Command command)
+		{
+			return this.next.AsyncRequest(command);
+		}
+		
+		/// <summary>
+		/// Method Request
+		/// </summary>
+		/// <returns>A Response</returns>
+		/// <param name="command">A  Command</param>
+		public virtual Response Request(Command command)
+		{
+			return this.next.Request(command);
+		}
+		
+		/// <summary>
+		/// Method Start
+		/// </summary>
+		public virtual void Start()
+		{
+			if( commandHandler == null )
+				throw new InvalidOperationException ("command cannot be null when Start is called.");
+			if( exceptionHandler == null )
+				throw new InvalidOperationException ("exception cannot be null when Start is called.");
+			this.next.Start();
+		}
+		
+		/// <summary>
+		/// Method Dispose
+		/// </summary>
+		public virtual void Dispose()
+		{
+			this.next.Dispose();
+		}
+		
+		public CommandHandler Command {
+            get { return commandHandler; }
+            set { this.commandHandler = value; }
+        }
+		
+        public  ExceptionHandler Exception {
+            get { return exceptionHandler; }
+            set { this.exceptionHandler = value; }
+        }
+		
+    }
+}
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/ActiveMQ/Transport/TransportFilter.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/CommonAssemblyInfo.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IBytesMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IBytesMessage.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IBytesMessage.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IBytesMessage.cs Tue Mar 21 15:20:55 2006
@@ -1,33 +1,33 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	/// <summary>
-	/// Represents a binary based message
-	/// </summary>
-	public interface IBytesMessage : IMessage
-    {
-        
-        byte[] Content
-        {
-            get;
-            set;
-        }
-    }
-}
-
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	/// <summary>
+	/// Represents a binary based message
+	/// </summary>
+	public interface IBytesMessage : IMessage
+    {
+        
+        byte[] Content
+        {
+            get;
+            set;
+        }
+    }
+}
+
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IBytesMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IConnection.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IConnectionFactory.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IConnectionFactory.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IConnectionFactory.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IConnectionFactory.cs Tue Mar 21 15:20:55 2006
@@ -1,38 +1,38 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	
-	/// <summary>
-	/// A Factory of IConnection objects
-	/// </summary>
-	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);
-	}
-}
-
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	
+	/// <summary>
+	/// A Factory of IConnection objects
+	/// </summary>
+	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);
+	}
+}
+
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IConnectionFactory.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IDestination.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMapMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMapMessage.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMapMessage.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMapMessage.cs Tue Mar 21 15:20:55 2006
@@ -1,34 +1,34 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	
-	/// <summary>
-	/// Represents a Map message which contains key and value pairs which are
-	/// of primitive types
-	/// </summary>
-	public interface IMapMessage : IMessage
-    {
-        IPrimitiveMap Body
-		{
-            get;
-        }
-    }
-}
-
-
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	
+	/// <summary>
+	/// Represents a Map message which contains key and value pairs which are
+	/// of primitive types
+	/// </summary>
+	public interface IMapMessage : IMessage
+    {
+        IPrimitiveMap Body
+		{
+            get;
+        }
+    }
+}
+
+
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMapMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessage.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessage.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessage.cs Tue Mar 21 15:20:55 2006
@@ -1,130 +1,130 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	/// <summary>
-	/// Represents a message either to be sent to a message broker or received from a message broker
-	/// </summary>
-	public interface IMessage
-    {
-        
-        /// <summary>
-        /// If using client acknowledgement mode on the session then this method will acknowledge that the
-        /// message has been processed correctly.
-        /// </summary>
-        void Acknowledge();
-        
-        /// <summary>
-        /// Provides access to the message properties (headers)
-        /// </summary>
-        IPrimitiveMap Properties
-		{
-            get;
-        }
-        
-        /// <summary>
-        /// The correlation ID used to correlate messages from conversations or long running business processes
-        /// </summary>
-        string NMSCorrelationID
-        {
-            get;
-            set;
-        }
-        
-        /// <summary>
-        /// The destination of the message
-        /// </summary>
-        IDestination NMSDestination
-        {
-            get;
-        }
-        
-        /// <summary>
-        /// The time in milliseconds that this message should expire in
-        /// </summary>
-        long NMSExpiration
-        {
-            get;
-            set;
-        }
-        
-        /// <summary>
-        /// The message ID which is set by the provider
-        /// </summary>
-        string NMSMessageId
-        {
-            get;
-        }
-        
-        /// <summary>
-        /// Whether or not this message is persistent
-        /// </summary>
-        bool NMSPersistent
-        {
-            get;
-            set;
-        }
-        
-        /// <summary>
-        /// The Priority on this message
-        /// </summary>
-        byte NMSPriority
-        {
-            get;
-            set;
-        }
-        
-        /// <summary>
-        /// Returns true if this message has been redelivered to this or another consumer before being acknowledged successfully.
-        /// </summary>
-        bool NMSRedelivered
-        {
-            get;
-        }
-        
-        
-        /// <summary>
-        /// The destination that the consumer of this message should send replies to
-        /// </summary>
-        IDestination NMSReplyTo
-        {
-            get;
-            set;
-        }
-        
-        
-        /// <summary>
-        /// The timestamp the broker added to the message
-        /// </summary>
-        long NMSTimestamp
-        {
-            get;
-        }
-        
-        /// <summary>
-        /// The type name of this message
-        /// </summary>
-        string NMSType
-        {
-            get;
-            set;
-        }
-                        
-    }
-}
-
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	/// <summary>
+	/// Represents a message either to be sent to a message broker or received from a message broker
+	/// </summary>
+	public interface IMessage
+    {
+        
+        /// <summary>
+        /// If using client acknowledgement mode on the session then this method will acknowledge that the
+        /// message has been processed correctly.
+        /// </summary>
+        void Acknowledge();
+        
+        /// <summary>
+        /// Provides access to the message properties (headers)
+        /// </summary>
+        IPrimitiveMap Properties
+		{
+            get;
+        }
+        
+        /// <summary>
+        /// The correlation ID used to correlate messages from conversations or long running business processes
+        /// </summary>
+        string NMSCorrelationID
+        {
+            get;
+            set;
+        }
+        
+        /// <summary>
+        /// The destination of the message
+        /// </summary>
+        IDestination NMSDestination
+        {
+            get;
+        }
+        
+        /// <summary>
+        /// The time in milliseconds that this message should expire in
+        /// </summary>
+        long NMSExpiration
+        {
+            get;
+            set;
+        }
+        
+        /// <summary>
+        /// The message ID which is set by the provider
+        /// </summary>
+        string NMSMessageId
+        {
+            get;
+        }
+        
+        /// <summary>
+        /// Whether or not this message is persistent
+        /// </summary>
+        bool NMSPersistent
+        {
+            get;
+            set;
+        }
+        
+        /// <summary>
+        /// The Priority on this message
+        /// </summary>
+        byte NMSPriority
+        {
+            get;
+            set;
+        }
+        
+        /// <summary>
+        /// Returns true if this message has been redelivered to this or another consumer before being acknowledged successfully.
+        /// </summary>
+        bool NMSRedelivered
+        {
+            get;
+        }
+        
+        
+        /// <summary>
+        /// The destination that the consumer of this message should send replies to
+        /// </summary>
+        IDestination NMSReplyTo
+        {
+            get;
+            set;
+        }
+        
+        
+        /// <summary>
+        /// The timestamp the broker added to the message
+        /// </summary>
+        long NMSTimestamp
+        {
+            get;
+        }
+        
+        /// <summary>
+        /// The type name of this message
+        /// </summary>
+        string NMSType
+        {
+            get;
+            set;
+        }
+                        
+    }
+}
+
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessage.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessageConsumer.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessageProducer.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessageProducer.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessageProducer.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessageProducer.cs Tue Mar 21 15:20:55 2006
@@ -1,69 +1,69 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	
-	/// <summary>
-	/// An object capable of sending messages to some destination
-	/// </summary>
-	public interface IMessageProducer : System.IDisposable
-	{
-		
-        /// <summary>
-        /// Sends the message to the default destination for this producer
-        /// </summary>
-        void Send(IMessage message);
-		
-        /// <summary>
-        /// Sends the message to the given destination
-        /// </summary>
-        void Send(IDestination destination, IMessage message);
-		
-		bool Persistent
-		{
-			get;
-			set;
-		}
-		
-		long TimeToLive
-		{
-			get;
-			set;
-		}
-		
-		int Priority
-		{
-			get;
-			set;
-		}
-		
-		bool DisableMessageID
-		{
-			get;
-			set;
-		}
-		
-		bool DisableMessageTimestamp
-		{
-			get;
-			set;
-		}
-		
-    }
-}
-
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	
+	/// <summary>
+	/// An object capable of sending messages to some destination
+	/// </summary>
+	public interface IMessageProducer : System.IDisposable
+	{
+		
+        /// <summary>
+        /// Sends the message to the default destination for this producer
+        /// </summary>
+        void Send(IMessage message);
+		
+        /// <summary>
+        /// Sends the message to the given destination
+        /// </summary>
+        void Send(IDestination destination, IMessage message);
+		
+		bool Persistent
+		{
+			get;
+			set;
+		}
+		
+		long TimeToLive
+		{
+			get;
+			set;
+		}
+		
+		int Priority
+		{
+			get;
+			set;
+		}
+		
+		bool DisableMessageID
+		{
+			get;
+			set;
+		}
+		
+		bool DisableMessageTimestamp
+		{
+			get;
+			set;
+		}
+		
+    }
+}
+
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IMessageProducer.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IPrimitiveMap.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IQueue.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IQueue.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IQueue.cs Tue Mar 21 15:20:55 2006
@@ -1,32 +1,32 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	/// <summary>
-	/// Summary description for IQueue.
-	/// </summary>
-	public interface IQueue : IDestination
-	{
-		
-		string QueueName
-		{
-			get;
-		}
-	}
-}
-
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	/// <summary>
+	/// Summary description for IQueue.
+	/// </summary>
+	public interface IQueue : IDestination
+	{
+		
+		string QueueName
+		{
+			get;
+		}
+	}
+}
+
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IQueue.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ISession.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ISession.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ISession.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ISession.cs Tue Mar 21 15:20:55 2006
@@ -1,123 +1,123 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	/// <summary>
-	/// Represents a single unit of work on an IConnection.
-	/// So the ISession can be used to perform transactional receive and sends
-	/// </summary>
-	public interface ISession : System.IDisposable
-    {
-        
-        /// <summary>
-        /// Creates a producer of messages
-        /// </summary>
-        IMessageProducer CreateProducer();
-        
-        /// <summary>
-        /// Creates a producer of messages on a given destination
-        /// </summary>
-        IMessageProducer CreateProducer(IDestination destination);
-        
-        /// <summary>
-        /// Creates a consumer of messages on a given destination
-        /// </summary>
-        IMessageConsumer CreateConsumer(IDestination destination);
-        
-        /// <summary>
-        /// Creates a consumer of messages on a given destination with a selector
-        /// </summary>
-        IMessageConsumer CreateConsumer(IDestination destination, string selector);
-        
-        /// <summary>
-        /// Creates a named durable consumer of messages on a given destination with a selector
-        /// </summary>
-        IMessageConsumer CreateDurableConsumer(ITopic destination, string name, string selector, bool noLocal);
-		
-        /// <summary>
-        /// Returns the queue for the given name
-        /// </summary>
-        IQueue GetQueue(string name);
-        
-        /// <summary>
-        /// Returns the topic for the given name
-        /// </summary>
-        ITopic GetTopic(string name);
-        
-        
-        /// <summary>
-        /// Creates a temporary queue
-        /// </summary>
-        ITemporaryQueue CreateTemporaryQueue();
-		
-        /// <summary>
-        /// Creates a temporary topic
-        /// </summary>
-        ITemporaryTopic CreateTemporaryTopic();
-		
-        
-        // Factory methods to create messages
-        
-        /// <summary>
-        /// Creates a new message with an empty body
-        /// </summary>
-        IMessage CreateMessage();
-        
-        /// <summary>
-        /// Creates a new text message with an empty body
-        /// </summary>
-        ITextMessage CreateTextMessage();
-        
-        /// <summary>
-        /// Creates a new text message with the given body
-        /// </summary>
-        ITextMessage CreateTextMessage(string text);
-        
-        /// <summary>
-        /// Creates a new Map message which contains primitive key and value pairs
-        /// </summary>
-        IMapMessage CreateMapMessage();
-        
-        /// <summary>
-        /// Creates a new binary message
-        /// </summary>
-        IBytesMessage CreateBytesMessage();
-        
-        /// <summary>
-        /// Creates a new binary message with the given body
-        /// </summary>
-        IBytesMessage CreateBytesMessage(byte[] body);
-		
-		
-        // Transaction methods
-        
-        /// <summary>
-        /// If this is a transactional session then commit all message
-        /// send and acknowledgements for producers and consumers in this session
-        /// </summary>
-        void Commit();
-        
-        /// <summary>
-        /// If this is a transactional session then rollback all message
-        /// send and acknowledgements for producers and consumers in this session
-        /// </summary>
-        void Rollback();
-        
-    }
-}
-
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	/// <summary>
+	/// Represents a single unit of work on an IConnection.
+	/// So the ISession can be used to perform transactional receive and sends
+	/// </summary>
+	public interface ISession : System.IDisposable
+    {
+        
+        /// <summary>
+        /// Creates a producer of messages
+        /// </summary>
+        IMessageProducer CreateProducer();
+        
+        /// <summary>
+        /// Creates a producer of messages on a given destination
+        /// </summary>
+        IMessageProducer CreateProducer(IDestination destination);
+        
+        /// <summary>
+        /// Creates a consumer of messages on a given destination
+        /// </summary>
+        IMessageConsumer CreateConsumer(IDestination destination);
+        
+        /// <summary>
+        /// Creates a consumer of messages on a given destination with a selector
+        /// </summary>
+        IMessageConsumer CreateConsumer(IDestination destination, string selector);
+        
+        /// <summary>
+        /// Creates a named durable consumer of messages on a given destination with a selector
+        /// </summary>
+        IMessageConsumer CreateDurableConsumer(ITopic destination, string name, string selector, bool noLocal);
+		
+        /// <summary>
+        /// Returns the queue for the given name
+        /// </summary>
+        IQueue GetQueue(string name);
+        
+        /// <summary>
+        /// Returns the topic for the given name
+        /// </summary>
+        ITopic GetTopic(string name);
+        
+        
+        /// <summary>
+        /// Creates a temporary queue
+        /// </summary>
+        ITemporaryQueue CreateTemporaryQueue();
+		
+        /// <summary>
+        /// Creates a temporary topic
+        /// </summary>
+        ITemporaryTopic CreateTemporaryTopic();
+		
+        
+        // Factory methods to create messages
+        
+        /// <summary>
+        /// Creates a new message with an empty body
+        /// </summary>
+        IMessage CreateMessage();
+        
+        /// <summary>
+        /// Creates a new text message with an empty body
+        /// </summary>
+        ITextMessage CreateTextMessage();
+        
+        /// <summary>
+        /// Creates a new text message with the given body
+        /// </summary>
+        ITextMessage CreateTextMessage(string text);
+        
+        /// <summary>
+        /// Creates a new Map message which contains primitive key and value pairs
+        /// </summary>
+        IMapMessage CreateMapMessage();
+        
+        /// <summary>
+        /// Creates a new binary message
+        /// </summary>
+        IBytesMessage CreateBytesMessage();
+        
+        /// <summary>
+        /// Creates a new binary message with the given body
+        /// </summary>
+        IBytesMessage CreateBytesMessage(byte[] body);
+		
+		
+        // Transaction methods
+        
+        /// <summary>
+        /// If this is a transactional session then commit all message
+        /// send and acknowledgements for producers and consumers in this session
+        /// </summary>
+        void Commit();
+        
+        /// <summary>
+        /// If this is a transactional session then rollback all message
+        /// send and acknowledgements for producers and consumers in this session
+        /// </summary>
+        void Rollback();
+        
+    }
+}
+
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ISession.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IStartable.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IStartable.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IStartable.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IStartable.cs Tue Mar 21 15:20:55 2006
@@ -1,28 +1,28 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	/// <summary>
-	/// Implemented by NMS objects that can be started.
-	/// </summary>
-	public interface IStartable
-    {
-        void Start();
-    }
-}
-
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	/// <summary>
+	/// Implemented by NMS objects that can be started.
+	/// </summary>
+	public interface IStartable
+    {
+        void Start();
+    }
+}
+
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IStartable.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IStoppable.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IStoppable.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IStoppable.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IStoppable.cs Tue Mar 21 15:20:55 2006
@@ -1,27 +1,27 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	/// <summary>
-	/// Implemented by NMS objects that can be started.
-	/// </summary>
-	public interface IStoppable
-	{
-		void Stop();
-	}
-}
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	/// <summary>
+	/// Implemented by NMS objects that can be started.
+	/// </summary>
+	public interface IStoppable
+	{
+		void Stop();
+	}
+}
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/IStoppable.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ITemporaryQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ITemporaryQueue.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ITemporaryQueue.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ITemporaryQueue.cs Tue Mar 21 15:20:55 2006
@@ -1,27 +1,27 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	/// <summary>
-	/// Summary description for ITemporaryQueue.
-	/// </summary>
-	public interface ITemporaryQueue : IDestination
-	{
-	}
-}
-
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	/// <summary>
+	/// Summary description for ITemporaryQueue.
+	/// </summary>
+	public interface ITemporaryQueue : IDestination
+	{
+	}
+}
+
+

Propchange: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ITemporaryQueue.cs
------------------------------------------------------------------------------
    svn:eol-style = native

Modified: incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ITemporaryTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ITemporaryTopic.cs?rev=387665&r1=387664&r2=387665&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ITemporaryTopic.cs (original)
+++ incubator/activemq/trunk/activemq-dotnet/src/main/csharp/NMS/ITemporaryTopic.cs Tue Mar 21 15:20:55 2006
@@ -1,27 +1,27 @@
-/*
- * 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.
- */
-namespace NMS
-{
-	/// <summary>
-	/// Summary description for TemporaryTopic.
-	/// </summary>
-	public interface ITemporaryTopic : IDestination
-	{
-	}
-}
-
-
+/*
+ * 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.
+ */
+namespace NMS
+{
+	/// <summary>
+	/// Summary description for TemporaryTopic.
+	/// </summary>
+	public interface ITemporaryTopic : IDestination
+	{
+	}
+}
+
+