activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r779626 - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src: main/csharp/Connection.cs test/csharp/VirtualTopicTest.cs
Date Thu, 28 May 2009 15:39:50 GMT
Author: tabish
Date: Thu May 28 15:39:50 2009
New Revision: 779626

URL: http://svn.apache.org/viewvc?rev=779626&view=rev
Log:
Temporary workaround for: http://issues.apache.org/activemq/browse/AMQNET-153

Modified:
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
    activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs?rev=779626&r1=779625&r2=779626&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Connection.cs Thu May
28 15:39:50 2009
@@ -470,6 +470,12 @@
 		{
 			bool dispatched = false;
 
+            // Override the Message's Destination with the one from the Dispatch since in
the
+            // case of a virtual Topic the correct destination ack is the one from the Dispatch.
+            // This is a bit of a hack since we should really be sending the entire dispatch
to
+            // the Consumer.
+            dispatch.Message.Destination = dispatch.Destination;
+
 			lock(sessions.SyncRoot)
 			{
 				foreach(Session session in sessions)

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs?rev=779626&r1=779625&r2=779626&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/VirtualTopicTest.cs
Thu May 28 15:39:50 2009
@@ -30,7 +30,7 @@
 		protected static string CONSUMER_B_DESTINATION_NAME = "queue://Consumer.B.VirtualTopic.TestDestination";
 		protected static string TEST_CLIENT_ID = "VirtualTopicClientId";
 
-		protected const int totalMsgs = 1;
+		protected const int totalMsgs = 5;
 		protected AcknowledgementMode currentAckMode;
 		protected int receivedA;
 		protected int receivedB;



Mime
View raw message