activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r899393 - in /activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src: main/csharp/Protocol/StompWireFormat.cs test/csharp/MapMessageTest.cs
Date Thu, 14 Jan 2010 20:18:39 GMT
Author: tabish
Date: Thu Jan 14 20:18:37 2010
New Revision: 899393

URL: http://svn.apache.org/viewvc?rev=899393&view=rev
Log:
Handle the consumer.transformation setting and add that to the test case.

Modified:
    activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs
    activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/MapMessageTest.cs

Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs?rev=899393&r1=899392&r2=899393&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompWireFormat.cs
Thu Jan 14 20:18:37 2010
@@ -424,7 +424,16 @@
             }
 
             // ActiveMQ extensions to STOMP
-            frame.SetProperty("transformation", "jms-map-xml");
+
+            if(command.Transformation != null)
+            {
+                frame.SetProperty("transformation", command.Transformation);
+            }
+            else
+            {
+            //    frame.SetProperty("transformation", "jms-map-xml");
+            }
+
             frame.SetProperty("activemq.dispatchAsync", command.DispatchAsync);
 
             if(command.Exclusive)

Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/MapMessageTest.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/MapMessageTest.cs?rev=899393&r1=899392&r2=899393&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/MapMessageTest.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/MapMessageTest.cs Thu
Jan 14 20:18:37 2010
@@ -56,7 +56,8 @@
                 connection.Start();
                 using(ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
                 {
-                    IDestination destination = SessionUtil.GetDestination(session, DESTINATION_NAME);
+                    string TOPIC = DESTINATION_NAME + "?consumer.transformation=jms-map-xml";
+                    IDestination destination = session.GetTopic(TOPIC);
                     using(IMessageConsumer consumer = session.CreateConsumer(destination))
                     using(IMessageProducer producer = session.CreateProducer(destination))
                     {



Mime
View raw message