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/03/30 15:33:40 UTC
svn commit: r929131 - in
/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp:
Commands/Message.cs Protocol/StompWireFormat.cs
Author: tabish
Date: Tue Mar 30 13:33:40 2010
New Revision: 929131
URL: http://svn.apache.org/viewvc?rev=929131&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQNET-245
Added encode of timestamp field. Removed default init of timestamp in Message class.
Modified:
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/Message.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/Message.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/Message.cs?rev=929131&r1=929130&r2=929131&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/Message.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/Message.cs Tue Mar 30 13:33:40 2010
@@ -39,7 +39,6 @@ namespace Apache.NMS.Stomp.Commands
public Message() : base()
{
- Timestamp = DateUtils.ToJavaTimeUtc(DateTime.UtcNow);
}
public override byte GetDataStructureType()
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=929131&r1=929130&r2=929131&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 Tue Mar 30 13:33:40 2010
@@ -306,6 +306,10 @@ namespace Apache.NMS.Stomp.Protocol
{
frame.SetProperty("expires", command.Expiration);
}
+ if(command.Timestamp != 0)
+ {
+ frame.SetProperty("timestamp", command.Timestamp);
+ }
if(command.Priority != 4)
{
frame.SetProperty("priority", command.Priority);