activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r383314 - in /incubator/activemq/trunk/openwire-dotnet: src/ActiveMQ/ src/ActiveMQ/Commands/ src/ActiveMQ/Transport/ src/ActiveMQ/Transport/Tcp/ src/JMS/ tests/ActiveMQ/OpenWire/
Date Sun, 05 Mar 2006 13:07:50 GMT
Author: chirino
Date: Sun Mar  5 05:07:48 2006
New Revision: 383314

URL: http://svn.apache.org/viewcvs?rev=383314&view=rev
Log:
Fixed up some comments.

Modified:
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/AbstractCommand.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQDestination.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempTopic.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTopic.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerError.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Command.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataStructure.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataStructureSupport.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MarshallAware.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Dispatcher.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/FutureResponse.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/LoggingTransport.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/MutexTransport.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ResponseCorrelator.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/Tcp/TcpTransport.cs
    incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/TransportFilter.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageConsumer.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageProducer.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IPrimitiveMap.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/IQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/ISession.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryQueue.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryTopic.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/ITextMessage.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/ITopic.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/JMSConnectionException.cs
    incubator/activemq/trunk/openwire-dotnet/src/JMS/JMSException.cs
    incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/BrokerException.cs Sun Mar  5 05:07:48
2006
@@ -17,13 +17,12 @@
 using ActiveMQ.Commands;
 using JMS;
 
-
-/// <summary>
-/// Exception thrown when the broker returns an error
-/// </summary>
-
 namespace ActiveMQ
 {
+	
+	/// <summary>
+	/// Exception thrown when the broker returns an error
+	/// </summary>
 	public class BrokerException : JMSException
     {
         

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/AbstractCommand.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/AbstractCommand.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/AbstractCommand.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/AbstractCommand.cs Sun
Mar  5 05:07:48 2006
@@ -17,12 +17,12 @@
 using ActiveMQ.Commands;
 using System;
 
-
-/// <summary>
-/// Summary description for AbstractCommand.
-/// </summary>
 namespace ActiveMQ.Commands
 {
+	
+	/// <summary>
+	/// Summary description for AbstractCommand.
+	/// </summary>
 	public abstract class AbstractCommand : Command
     {
         private short commandId;

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQDestination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQDestination.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQDestination.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQDestination.cs
Sun Mar  5 05:07:48 2006
@@ -17,14 +17,12 @@
 using ActiveMQ.Commands;
 using JMS;
 using System;
-
-
-
-/// <summary>
-/// Summary description for ActiveMQDestination.
-/// </summary>
 namespace ActiveMQ.Commands
 {
+	
+	/// <summary>
+	/// Summary description for ActiveMQDestination.
+	/// </summary>
 	public abstract class ActiveMQDestination : AbstractCommand, IDestination
     {
         

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQQueue.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQQueue.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQQueue.cs Sun Mar
 5 05:07:48 2006
@@ -18,12 +18,12 @@
 using JMS;
 using System;
 
-
-/// <summary>
-/// Summary description for ActiveMQQueue.
-/// </summary>
 namespace ActiveMQ.Commands
 {
+	
+	/// <summary>
+	/// Summary description for ActiveMQQueue.
+	/// </summary>
 	public class ActiveMQQueue : ActiveMQDestination, IQueue
     {
         public const byte ID_ActiveMQQueue = 100;

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempQueue.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempQueue.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempQueue.cs Sun
Mar  5 05:07:48 2006
@@ -18,12 +18,12 @@
 using JMS;
 using System;
 
-
-/// <summary>
-/// A Temporary Queue
-/// </summary>
 namespace ActiveMQ.Commands
 {
+	
+	/// <summary>
+	/// A Temporary Queue
+	/// </summary>
 	public class ActiveMQTempQueue : ActiveMQTempDestination, ITemporaryQueue
     {
         public const byte ID_ActiveMQTempQueue = 102;

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempTopic.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempTopic.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTempTopic.cs Sun
Mar  5 05:07:48 2006
@@ -18,12 +18,12 @@
 using JMS;
 using System;
 
-
-/// <summary>
-/// A Temporary Topic
-/// </summary>
 namespace ActiveMQ.Commands
 {
+	
+	/// <summary>
+	/// A Temporary Topic
+	/// </summary>
 	public class ActiveMQTempTopic : ActiveMQTempDestination, ITemporaryTopic
     {
         public const byte ID_ActiveMQTempTopic = 103;

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTopic.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTopic.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/ActiveMQTopic.cs Sun Mar
 5 05:07:48 2006
@@ -18,12 +18,12 @@
 using JMS;
 using System;
 
-
-/// <summary>
-/// Summary description for ActiveMQTopic.
-/// </summary>
 namespace ActiveMQ.Commands
 {
+	
+	/// <summary>
+	/// Summary description for ActiveMQTopic.
+	/// </summary>
 	public class ActiveMQTopic : ActiveMQDestination, ITopic
     {
         public const byte ID_ActiveMQTopic = 101;

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerError.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerError.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerError.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/BrokerError.cs Sun Mar
 5 05:07:48 2006
@@ -28,14 +28,10 @@
         public string MethodName;
         public int LineNumber;
     }
-}
 
-
-/// <summary>
-/// Represents an exception on the broker
-/// </summary>
-namespace ActiveMQ.Commands
-{
+	/// <summary>
+	/// Represents an exception on the broker
+	/// </summary>
 	public class BrokerError : AbstractCommand
     {
         private string message;

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Command.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Command.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Command.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/Command.cs Sun Mar  5 05:07:48
2006
@@ -16,12 +16,12 @@
  */
 using ActiveMQ.Commands;
 
-
-/// <summary>
-/// An OpenWire command
-/// </summary>
 namespace ActiveMQ.Commands
 {
+	
+	/// <summary>
+	/// An OpenWire command
+	/// </summary>
 	public interface Command : DataStructure
     {
         short CommandId

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataStructure.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataStructure.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataStructure.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataStructure.cs Sun Mar
 5 05:07:48 2006
@@ -14,14 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
-
-
-/// <summary>
-/// An OpenWire command
-/// </summary>
 namespace ActiveMQ.Commands
 {
+	
+	/// <summary>
+	/// An OpenWire command
+	/// </summary>
 	public interface DataStructure
 	{
 		

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataStructureSupport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataStructureSupport.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataStructureSupport.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/DataStructureSupport.cs
Sun Mar  5 05:07:48 2006
@@ -16,12 +16,12 @@
  */
 using ActiveMQ.Commands;
 
-
-/// <summary>
-/// Summary description for DataStructureSupport.
-/// </summary>
 namespace ActiveMQ.Commands
 {
+	
+	/// <summary>
+	/// Summary description for DataStructureSupport.
+	/// </summary>
 	public abstract class DataStructureSupport : DataStructure
 	{
 		

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MarshallAware.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MarshallAware.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MarshallAware.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Commands/MarshallAware.cs Sun Mar
 5 05:07:48 2006
@@ -16,12 +16,12 @@
  */
 using ActiveMQ.OpenWire;
 
-
-/// <summary>
-/// Represents a marshallable entity
-/// </summary>
 namespace ActiveMQ.Commands
 {
+	
+	/// <summary>
+	/// Represents a marshallable entity
+	/// </summary>
 	public interface MarshallAware
 	{
 		

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Dispatcher.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Dispatcher.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Dispatcher.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Dispatcher.cs Sun Mar  5 05:07:48
2006
@@ -20,12 +20,12 @@
 using System.Collections;
 using System.Threading;
 
-
-/// <summary>
-/// Handles the multi-threaded dispatching between the transport and the consumers
-/// </summary>
 namespace ActiveMQ
 {
+	
+	/// <summary>
+	/// Handles the multi-threaded dispatching between the transport and the consumers
+	/// </summary>
 	public class Dispatcher
     {
         Queue queue = new Queue();

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/FutureResponse.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/FutureResponse.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/FutureResponse.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/FutureResponse.cs Sun
Mar  5 05:07:48 2006
@@ -18,12 +18,12 @@
 using System;
 using System.Threading;
 
-
-/// <summary>
-/// Handles asynchronous responses
-/// </summary>
 namespace ActiveMQ.Transport
 {
+	
+	/// <summary>
+	/// Handles asynchronous responses
+	/// </summary>
 	public class FutureResponse : IAsyncResult
     {
         

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ITransport.cs Sun Mar
 5 05:07:48 2006
@@ -19,14 +19,14 @@
 using JMS;
 using System;
 
-/// <summary>
-/// Represents the logical networking transport layer.
-/// </summary>
 namespace ActiveMQ.Transport
 {
 	public delegate void CommandHandler(ITransport sender, Command command);
 	public delegate void ExceptionHandler(ITransport sender, Exception command);
 
+	/// <summary>
+	/// Represents the logical networking transport layer.
+	/// </summary>
 	public interface ITransport : IStartable, IDisposable
     {
         void Oneway(Command command);
@@ -35,12 +35,12 @@
         
         Response Request(Command command);
         
-        CommandHandler Command{
+        CommandHandler Command {
             get;
             set;
         }
 		
-        ExceptionHandler Exception{
+        ExceptionHandler Exception {
             get;
             set;
         }

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/LoggingTransport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/LoggingTransport.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/LoggingTransport.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/LoggingTransport.cs Sun
Mar  5 05:07:48 2006
@@ -19,11 +19,12 @@
 using JMS;
 using System;
 
-/// <summary>
-/// A Transport filter that is used to log the commands sent and received.
-/// </summary>
 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) {
@@ -31,12 +32,12 @@
 		
 		protected override void OnCommand(ITransport sender, Command command) {
 			Console.WriteLine("RECEIVED: " + command);
-			this.command(sender, command);
+			this.commandHandler(sender, command);
 		}
 		
 		protected override void OnException(ITransport sender, Exception error) {
 			Console.WriteLine("RECEIVED Exception: " + error);
-			this.exception(sender, error);
+			this.exceptionHandler(sender, error);
 		}
 		
 		public override void Oneway(Command command)

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/MutexTransport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/MutexTransport.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/MutexTransport.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/MutexTransport.cs Sun
Mar  5 05:07:48 2006
@@ -19,11 +19,12 @@
 using JMS;
 using System;
 
-/// <summary>
-/// A Transport which gaurds access to the next transport using a mutex.
-/// </summary>
 namespace ActiveMQ.Transport
 {
+	
+	/// <summary>
+	/// A Transport which gaurds access to the next transport using a mutex.
+	/// </summary>
 	public class MutexTransport : TransportFilter
     {
 		

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ResponseCorrelator.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ResponseCorrelator.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ResponseCorrelator.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/ResponseCorrelator.cs
Sun Mar  5 05:07:48 2006
@@ -22,11 +22,12 @@
 using ActiveMQ.Transport;
 using JMS;
 
-/// <summary>
-/// A Transport which gaurds access to the next transport using a mutex.
-/// </summary>
 namespace ActiveMQ.Transport
 {
+	
+	/// <summary>
+	/// A Transport which gaurds access to the next transport using a mutex.
+	/// </summary>
 	public class ResponseCorrelator : TransportFilter
     {
 
@@ -86,7 +87,7 @@
 					{
 						ExceptionResponse er = (ExceptionResponse) response;
 						BrokerError brokerError = er.Exception;
-						this.exception(this, new BrokerException(brokerError));
+						this.exceptionHandler(this, new BrokerException(brokerError));
 					}
 					future.Response = response;
 				}
@@ -95,7 +96,7 @@
 					Console.WriteLine("ERROR: Unknown response ID: " + response.CommandId + " for response:
" + response);
 				}
 			} else {
-				this.command(sender, command);
+				this.commandHandler(sender, command);
 			}
 		}
 		

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/Tcp/TcpTransport.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/Tcp/TcpTransport.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/Tcp/TcpTransport.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/Tcp/TcpTransport.cs Sun
Mar  5 05:07:48 2006
@@ -25,14 +25,12 @@
 using System.Net.Sockets;
 using System.Threading;
 
-
-
-/// <summary>
-/// An implementation of ITransport that uses sockets to communicate with the broker
-/// </summary>
-
 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;
@@ -43,8 +41,8 @@
         private bool started;
         volatile private bool closed;
         
-        public CommandHandler command;
-        public ExceptionHandler exception;
+        private CommandHandler commandHandlerHandlerHandlerHandlerHandler;
+        private ExceptionHandler exceptionHandler;
         
         public TcpTransport(Socket socket)
         {
@@ -58,9 +56,9 @@
         {
             if (!started)
             {
-				if( command == null )
+				if( commandHandlerHandlerHandlerHandlerHandler == null )
 					throw new InvalidOperationException ("command cannot be null when Start is called.");
-				if( exception == null )
+				if( exceptionHandler == null )
 					throw new InvalidOperationException ("exception cannot be null when Start is called.");
 				
                 started = true;
@@ -110,7 +108,7 @@
                 try
                 {
                     Command command = (Command) wireformat.Unmarshal(socketReader);
-					this.command(this, command);
+					this.commandHandlerHandlerHandlerHandlerHandler(this, command);
                 }
 				catch (ObjectDisposedException)
                 {
@@ -118,7 +116,7 @@
                 }
                 catch (Exception e)
                 {
-                    this.exception(this,e);
+                    this.exceptionHandler(this,e);
                 }
             }
         }
@@ -129,13 +127,13 @@
         // Implementation methods
                 
 		public CommandHandler Command {
-            get { return command; }
-            set { this.command = value; }
+            get { return commandHandlerHandlerHandlerHandlerHandler; }
+            set { this.commandHandlerHandlerHandlerHandlerHandler = value; }
         }
 		
         public  ExceptionHandler Exception {
-            get { return exception; }
-            set { this.exception = value; }
+            get { return exceptionHandler; }
+            set { this.exceptionHandler = value; }
         }
 		
     }

Modified: incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/TransportFilter.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/TransportFilter.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/TransportFilter.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/ActiveMQ/Transport/TransportFilter.cs Sun
Mar  5 05:07:48 2006
@@ -19,16 +19,17 @@
 using JMS;
 using System;
 
-/// <summary>
-/// Used to implement a filter on the transport layer.
-/// </summary>
 namespace ActiveMQ.Transport
 {
+	
+	/// <summary>
+	/// Used to implement a filter on the transport layer.
+	/// </summary>
 	public class TransportFilter : ITransport
     {
 		protected readonly ITransport next;
-		protected CommandHandler command;
-		protected ExceptionHandler exception;
+		protected CommandHandler commandHandler;
+		protected ExceptionHandler exceptionHandler;
 		
 		public TransportFilter(ITransport next) {
 			this.next = next;
@@ -37,11 +38,11 @@
 		}
 		
 		protected virtual void OnCommand(ITransport sender, Command command) {
-			this.command(sender, command);
+			this.commandHandler(sender, command);
 		}
 		
 		protected virtual void OnException(ITransport sender, Exception command) {
-			this.exception(sender, command);
+			this.exceptionHandler(sender, command);
 		}
 		
 		
@@ -79,9 +80,9 @@
 		/// </summary>
 		public virtual void Start()
 		{
-			if( command == null )
+			if( commandHandler == null )
 				throw new InvalidOperationException ("command cannot be null when Start is called.");
-			if( exception == null )
+			if( exceptionHandler == null )
 				throw new InvalidOperationException ("exception cannot be null when Start is called.");
 			this.next.Start();
 		}
@@ -95,13 +96,13 @@
 		}
 		
 		public CommandHandler Command {
-            get { return command; }
-            set { this.command = value; }
+            get { return commandHandler; }
+            set { this.commandHandler = value; }
         }
 		
         public  ExceptionHandler Exception {
-            get { return exception; }
-            set { this.exception = value; }
+            get { return exceptionHandler; }
+            set { this.exceptionHandler = value; }
         }
 		
     }

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IBytesMessage.cs Sun Mar  5 05:07:48
2006
@@ -16,12 +16,12 @@
  */
 using JMS;
 
-
-/// <summary>
-/// Represents a binary based message
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Represents a binary based message
+	/// </summary>
 	public interface IBytesMessage : IMessage
     {
         

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IConnectionFactory.cs Sun Mar  5 05:07:48
2006
@@ -16,13 +16,12 @@
  */
 using JMS;
 
-
-
-/// <summary>
-/// A Factory of IConnection objects
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// A Factory of IConnection objects
+	/// </summary>
 	public interface IConnectionFactory
 	{
 		

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IDestination.cs Sun Mar  5 05:07:48 2006
@@ -14,14 +14,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-
-
-
-/// <summary>
-/// Summary description for Destination.
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Summary description for Destination.
+	/// </summary>
 	public interface IDestination
 	{
 	}

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IMapMessage.cs Sun Mar  5 05:07:48 2006
@@ -16,13 +16,13 @@
  */
 using JMS;
 
-
-/// <summary>
-/// Represents a Map message which contains key and value pairs which are
-/// of primitive types
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Represents a Map message which contains key and value pairs which are
+	/// of primitive types
+	/// </summary>
 	public interface IMapMessage : IMessage
     {
         IPrimitiveMap Body

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessage.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessage.cs Sun Mar  5 05:07:48 2006
@@ -16,12 +16,12 @@
  */
 using JMS;
 
-
-/// <summary>
-/// Represents a message either to be sent to a message broker or received from a message
broker
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Represents a message either to be sent to a message broker or received from a message
broker
+	/// </summary>
 	public interface IMessage
     {
         

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageConsumer.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageConsumer.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageConsumer.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageConsumer.cs Sun Mar  5 05:07:48
2006
@@ -17,17 +17,13 @@
 using JMS;
 using System;
 
-
 namespace JMS
 {
 	public delegate void MessageListener(IMessage message);
-}
 
-/// <summary>
-/// A consumer of messages
-/// </summary>
-namespace JMS
-{
+	/// <summary>
+	/// A consumer of messages
+	/// </summary>
 	public interface IMessageConsumer : IDisposable
     {
         

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageProducer.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageProducer.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageProducer.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IMessageProducer.cs Sun Mar  5 05:07:48
2006
@@ -17,12 +17,12 @@
 using JMS;
 using System;
 
-
-/// <summary>
-/// An object capable of sending messages to some destination
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// An object capable of sending messages to some destination
+	/// </summary>
 	public interface IMessageProducer : IDisposable
 	{
 		

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/IPrimitiveMap.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IPrimitiveMap.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IPrimitiveMap.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IPrimitiveMap.cs Sun Mar  5 05:07:48
2006
@@ -16,13 +16,13 @@
  */
 using System.Collections;
 
-
-/// <summary>
-/// Represents a Map of primitive types where the keys are all string instances
-/// and the values are strings or numbers.
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Represents a Map of primitive types where the keys are all string instances
+	/// and the values are strings or numbers.
+	/// </summary>
 	public interface IPrimitiveMap
     {
         

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/IQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/IQueue.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/IQueue.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/IQueue.cs Sun Mar  5 05:07:48 2006
@@ -17,12 +17,12 @@
 using JMS;
 using System;
 
-
-/// <summary>
-/// Summary description for IQueue.
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Summary description for IQueue.
+	/// </summary>
 	public interface IQueue : IDestination
 	{
 		

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/ISession.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/ISession.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/ISession.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/ISession.cs Sun Mar  5 05:07:48 2006
@@ -17,13 +17,13 @@
 using JMS;
 using System;
 
-
-/// <summary>
-/// Represents a single unit of work on an IConnection.
-/// So the ISession can be used to perform transactional receive and sends
-/// </summary>
 namespace JMS
 {
+	
+	/// <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 : IDisposable
     {
         

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryQueue.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryQueue.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryQueue.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryQueue.cs Sun Mar  5 05:07:48
2006
@@ -16,12 +16,12 @@
  */
 using JMS;
 
-
-/// <summary>
-/// Summary description for ITemporaryQueue.
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Summary description for ITemporaryQueue.
+	/// </summary>
 	public interface ITemporaryQueue : IDestination
 	{
 	}

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryTopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryTopic.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryTopic.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/ITemporaryTopic.cs Sun Mar  5 05:07:48
2006
@@ -16,12 +16,12 @@
  */
 using JMS;
 
-
-/// <summary>
-/// Summary description for TemporaryTopic.
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Summary description for TemporaryTopic.
+	/// </summary>
 	public interface ITemporaryTopic : IDestination
 	{
 	}

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/ITextMessage.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/ITextMessage.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/ITextMessage.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/ITextMessage.cs Sun Mar  5 05:07:48 2006
@@ -16,12 +16,12 @@
  */
 using JMS;
 
-
-/// <summary>
-/// Represents a text based message
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Represents a text based message
+	/// </summary>
 	public interface ITextMessage : IMessage
     {
         

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/ITopic.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/ITopic.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/ITopic.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/ITopic.cs Sun Mar  5 05:07:48 2006
@@ -17,12 +17,12 @@
 using JMS;
 using System;
 
-
-/// <summary>
-/// Summary description for ITopic.
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Summary description for ITopic.
+	/// </summary>
 	public interface ITopic : IDestination
 	{
 		

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/JMSConnectionException.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/JMSConnectionException.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/JMSConnectionException.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/JMSConnectionException.cs Sun Mar  5
05:07:48 2006
@@ -16,15 +16,15 @@
  */
 using System;
 
-
-/// <summary>
-/// Represents a connection failure.
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Represents a connection failure.
+	/// </summary>
 	public class ConnectionException : JMSException
 	{
-		public JMSException(string message) : base(message)
+		public ConnectionException(string message) : base(message)
 		{
 		}
 	}

Modified: incubator/activemq/trunk/openwire-dotnet/src/JMS/JMSException.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/src/JMS/JMSException.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/src/JMS/JMSException.cs (original)
+++ incubator/activemq/trunk/openwire-dotnet/src/JMS/JMSException.cs Sun Mar  5 05:07:48 2006
@@ -16,12 +16,12 @@
  */
 using System;
 
-
-/// <summary>
-/// Represents a JMS exception
-/// </summary>
 namespace JMS
 {
+	
+	/// <summary>
+	/// Represents a JMS exception
+	/// </summary>
 	public class JMSException : Exception
 	{
 		public JMSException(string message) : base(message)

Modified: incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs?rev=383314&r1=383313&r2=383314&view=diff
==============================================================================
--- incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs
(original)
+++ incubator/activemq/trunk/openwire-dotnet/tests/ActiveMQ/OpenWire/BooleanStreamTest.cs
Sun Mar  5 05:07:48 2006
@@ -120,7 +120,7 @@
 				dis.ReadByte();
 				Assert.Fail("Should have reached the end of the stream");
 			}
-			catch (IOException e)
+			catch (IOException)
 			{
 			}
 		}



Mime
View raw message