activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r897251 - in /activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp: Commands/MapMessage.cs Protocol/StompWireFormat.cs
Date Fri, 08 Jan 2010 16:24:04 GMT
Author: tabish
Date: Fri Jan  8 16:23:52 2010
New Revision: 897251

URL: http://svn.apache.org/viewvc?rev=897251&view=rev
Log:
Make a few changes to start preping for MapMessage support.

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

Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/MapMessage.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/MapMessage.cs?rev=897251&r1=897250&r2=897251&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/MapMessage.cs
(original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/MapMessage.cs
Fri Jan  8 16:23:52 2010
@@ -41,10 +41,7 @@
 
         public override bool ReadOnlyBody
         {
-            get
-            {
-                return base.ReadOnlyBody;
-            }
+            get { return base.ReadOnlyBody; }
 
             set
             {
@@ -64,21 +61,25 @@
             {
                 if(this.body == null)
                 {
-                    if(this.Content != null && this.Content.Length > 0)
-                    {
-                        MemoryStream buffer = new MemoryStream(this.Content);
-                        this.body = PrimitiveMap.Unmarshal(buffer);
-                    }
-                    else
-                    {
-                        this.body = new PrimitiveMap();
-                    }
-
+                    this.body = new PrimitiveMap();
                     this.typeConverter = new PrimitiveMapInterceptor(this, this.body);
                 }
 
                 return this.typeConverter;
             }
+
+            set
+            {
+                this.body = value as PrimitiveMap;
+                if(value != null)
+                {
+                    this.typeConverter = new PrimitiveMapInterceptor(this, value);
+                }
+                else
+                {
+                    this.typeConverter = null;
+                }
+            }
         }
 
         public override void BeforeMarshall(StompWireFormat wireFormat)

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=897251&r1=897250&r2=897251&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
Fri Jan  8 16:23:52 2010
@@ -401,8 +401,9 @@
             }
 
             // ActiveMQ extensions to STOMP
+            frame.SetProperty("transformation", "jms-map-xml");
             frame.SetProperty("activemq.dispatchAsync", command.DispatchAsync);
-            
+
             if(command.Exclusive)
             {
                 frame.SetProperty("activemq.exclusive", command.Exclusive);



Mime
View raw message