You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/03/05 14:07:50 UTC
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/
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)
{
}
}