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 2009/12/07 23:49:05 UTC
svn commit: r888168 - in
/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp:
Commands/ConsumerInfo.cs Protocol/StompFrameStream.cs
Protocol/StompWireFormat.cs
Author: tabish
Date: Mon Dec 7 22:49:04 2009
New Revision: 888168
URL: http://svn.apache.org/viewvc?rev=888168&view=rev
Log:
Change some things around since this code is now a dedicated Stomp client, remove anything that was OpenWire related.
Modified:
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/ConsumerInfo.cs
activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompFrameStream.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/ConsumerInfo.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/ConsumerInfo.cs?rev=888168&r1=888167&r2=888168&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/ConsumerInfo.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Commands/ConsumerInfo.cs Mon Dec 7 22:49:04 2009
@@ -18,6 +18,8 @@
using System;
using System.Collections;
+using Apache.NMS;
+
namespace Apache.NMS.Stomp.Commands
{
public class ConsumerInfo : BaseCommand
@@ -25,8 +27,8 @@
public const byte ID_CONSUMERINFO = 5;
ConsumerId consumerId;
- bool browser;
Destination destination;
+ AcknowledgementMode ackMode;
int prefetchSize;
int maximumPendingMessageLimit;
bool dispatchAsync;
@@ -58,8 +60,8 @@
{
return GetType().Name + "[" +
"ConsumerId=" + ConsumerId +
- "Browser=" + Browser +
"Destination=" + Destination +
+ "Ack Mode=" + AckMode +
"PrefetchSize=" + PrefetchSize +
"MaximumPendingMessageLimit=" + MaximumPendingMessageLimit +
"DispatchAsync=" + DispatchAsync +
@@ -78,18 +80,18 @@
set { this.consumerId = value; }
}
- public bool Browser
- {
- get { return browser; }
- set { this.browser = value; }
- }
-
public Destination Destination
{
get { return destination; }
set { this.destination = value; }
}
+ public AcknowledgementMode AckMode
+ {
+ get { return this.ackMode; }
+ set { this.ackMode = value; }
+ }
+
public int PrefetchSize
{
get { return prefetchSize; }
Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompFrameStream.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompFrameStream.cs?rev=888168&r1=888167&r2=888168&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompFrameStream.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/main/csharp/Protocol/StompFrameStream.cs Mon Dec 7 22:49:04 2009
@@ -89,7 +89,7 @@
public void WriteHeader(String name, Object value)
{
- if (value != null)
+ if(value != null)
{
builder.Append(name);
builder.Append(SEPARATOR);
@@ -100,7 +100,7 @@
public void WriteHeader(String name, bool value)
{
- if (value)
+ if(value)
{
builder.Append(name);
builder.Append(SEPARATOR);
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=888168&r1=888167&r2=888168&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 Mon Dec 7 22:49:04 2009
@@ -37,12 +37,14 @@
{
}
- public ITransport Transport {
+ public ITransport Transport
+ {
get { return transport; }
set { transport = value; }
}
- public int Version {
+ public int Version
+ {
get { return 1; }
}