You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2007/03/05 18:15:19 UTC
svn commit: r514737 - in
/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ: Connection.cs
MessageConsumer.cs
Author: jstrachan
Date: Mon Mar 5 09:15:18 2007
New Revision: 514737
URL: http://svn.apache.org/viewvc?view=rev&rev=514737
Log:
another attempted fix to solve the compile issue on .Net
Modified:
activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Connection.cs
activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/MessageConsumer.cs
Modified: activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Connection.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Connection.cs?view=diff&rev=514737&r1=514736&r2=514737
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Connection.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/Connection.cs Mon Mar 5 09:15:18 2007
@@ -14,15 +14,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+using ActiveMQ;
using NMS;
+using System;
namespace MSMQ
{
/// <summary>
- /// Represents a NMS connection MSMQ. Since the underlying MSMQ APIs are actually
+ /// Represents a NMS connection MSMQ. Since the underlying MSMQ APIs are actually
/// connectionless, NMS connection in the MSMQ case are not expensive operations.
/// </summary>
- ///
+ ///
public class Connection : IConnection
{
@@ -116,6 +118,18 @@
Dispose();
}
+ public void HandleException(Exception e)
+ {
+ if (ExceptionListener != null)
+ {
+ ExceptionListener(e);
+ }
+ else
+ {
+ Tracer.Error(e);
+ }
+
+ }
}
}
Modified: activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/MessageConsumer.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/MessageConsumer.cs?view=diff&rev=514737&r1=514736&r2=514737
==============================================================================
--- activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/MessageConsumer.cs (original)
+++ activemq/activemq-dotnet/trunk/src/main/csharp/MSMQ/MessageConsumer.cs Mon Mar 5 09:15:18 2007
@@ -119,14 +119,7 @@
protected virtual void HandleAsyncException(Exception e)
{
- if (session.Connection.ExceptionListener != null)
- {
- session.Connection.ExceptionListener(e);
- }
- else
- {
- Tracer.Error(e);
- }
+ session.Connection.HandleException(e);
}
protected virtual IMessage ToNmsMessage(Message message)