activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jstrac...@apache.org
Subject svn commit: r507857 - in /activemq/activemq-dotnet/trunk/src/main/csharp: ActiveMQ/ ActiveMQ/Util/ NMS/
Date Thu, 15 Feb 2007 08:51:28 GMT
Author: jstrachan
Date: Thu Feb 15 00:51:27 2007
New Revision: 507857

URL: http://svn.apache.org/viewvc?view=rev&rev=507857
Log:
Removed some compile warnings and added some extra helper methods to NMS

Added:
    activemq/activemq-dotnet/trunk/src/main/csharp/NMS/InvalidDestinationException.cs
Modified:
    activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Connection.cs
    activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/ConnectionFactory.cs
    activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/ITrace.cs
    activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/MessageProducer.cs
    activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/URISupport.cs
    activemq/activemq-dotnet/trunk/src/main/csharp/NMS/IMessageProducer.cs

Modified: activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Connection.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Connection.cs?view=diff&rev=507857&r1=507856&r2=507857
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Connection.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Connection.cs Thu Feb 15 00:51:27
2007
@@ -315,7 +315,7 @@
             }
             else if (command is ShutdownInfo)
             {
-                ShutdownInfo info = (ShutdownInfo)command;
+                //ShutdownInfo info = (ShutdownInfo)command;
                 if( !closing && !closed )
                 {
                     OnException(transport, new NMSException("Broker closed this connection."));

Modified: activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/ConnectionFactory.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/ConnectionFactory.cs?view=diff&rev=507857&r1=507856&r2=507857
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/ConnectionFactory.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/ConnectionFactory.cs Thu Feb 15
00:51:27 2007
@@ -42,6 +42,11 @@
 			this.brokerUri=brokerUri;
         }
         
+        public ConnectionFactory(string brokerUri)
+        {
+			this.brokerUri=new Uri(brokerUri);
+        }
+        
         public IConnection CreateConnection()
         {
             return CreateConnection(userName, password);

Modified: activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/ITrace.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/ITrace.cs?view=diff&rev=507857&r1=507856&r2=507857
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/ITrace.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/ITrace.cs Thu Feb 15 00:51:27
2007
@@ -20,7 +20,7 @@
 namespace ActiveMQ
 {
 	/// <summary>
-	/// The ITrace interface is used internally by ActiveMW DotNet to log messages.
+	/// The ITrace interface is used internally by ActiveMQ to log messages.
 	/// The client aplication may provide an implementation of ITrace if it wishes to
 	/// route messages to a specific destination.
 	/// </summary>
@@ -29,6 +29,7 @@
 	/// Use the <see cref="Tracer"/> class to register an instance of ITrace as the
 	/// active trace destination.
 	/// </para>
+	/// </remarks>
 	public interface ITrace
 	{
 		void Debug(string message);

Modified: activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/MessageProducer.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/MessageProducer.cs?view=diff&rev=507857&r1=507856&r2=507857
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/MessageProducer.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/MessageProducer.cs Thu Feb 15
00:51:27 2007
@@ -52,6 +52,11 @@
 			Send(destination, message, Persistent, Priority, TimeToLive);
 		}
 		
+        public void Send(IMessage message, bool persistent, byte priority, TimeSpan timeToLive)
+        {
+			Send(info.Destination, message, persistent, priority, timeToLive);
+		}
+		
         public void Send(IDestination destination, IMessage message, bool persistent, byte
priority, TimeSpan timeToLive)
         {
 			ActiveMQMessage activeMessage = (ActiveMQMessage)message;

Modified: activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/URISupport.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/URISupport.cs?view=diff&rev=507857&r1=507856&r2=507857
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/URISupport.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/ActiveMQ/Util/URISupport.cs Thu Feb 15
00:51:27 2007
@@ -28,7 +28,7 @@
 	internal class URISupport
 	{
 		/// <summary>
-		/// Parse a URI query string of the form ?x=y&z=0
+		/// Parse a URI query string of the form ?x=y&amp;z=0
 		/// into a map of name/value pairs.
 		/// </summary>
 		/// <param name="query">The query string to parse. This string should not contain

Modified: activemq/activemq-dotnet/trunk/src/main/csharp/NMS/IMessageProducer.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/NMS/IMessageProducer.cs?view=diff&rev=507857&r1=507856&r2=507857
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/NMS/IMessageProducer.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/NMS/IMessageProducer.cs Thu Feb 15 00:51:27
2007
@@ -31,6 +31,11 @@
         void Send(IMessage message);
 		
         /// <summary>
+        /// Sends the message to the default destination with the explicit QoS configuration
+        /// </summary>
+        void Send(IMessage message, bool persistent, byte priority, TimeSpan timeToLive);
+
+        /// <summary>
         /// Sends the message to the given destination
         /// </summary>
         void Send(IDestination destination, IMessage message);

Added: activemq/activemq-dotnet/trunk/src/main/csharp/NMS/InvalidDestinationException.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/NMS/InvalidDestinationException.cs?view=auto&rev=507857
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/NMS/InvalidDestinationException.cs (added)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/NMS/InvalidDestinationException.cs Thu
Feb 15 00:51:27 2007
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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 NMS
+{
+	/// <summary>
+	/// An attempt is made to access an invalid destination
+	/// </summary>
+	public class InvalidDestinationException : NMSException
+	{
+		public InvalidDestinationException(string message) 
+		    : base(message)
+		{
+		}
+	    
+        public InvalidDestinationException(string message, Exception innerException)
+            : base(message, innerException)
+        {
+        }
+    }
+}
+
+
+



Mime
View raw message