svn commit: r779626 - in /activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src: main/csharp/Connection.cs test/csharp/VirtualTopicTest.cs

[ta...@apache.org]

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;