You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2010/01/14 21:18:39 UTC
svn commit: r899393 - in
/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src:
main/csharp/Protocol/StompWireFormat.cs test/csharp/MapMessageTest.cs
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))
{