From 90218314a8ad1ed4bfb7c6dd1cbb23ee67bd502c Mon Sep 17 00:00:00 2001 From: Steven Shaw Date: Tue, 28 Nov 2006 23:37:52 +0000 Subject: QPID-135 Ported enough transaction support to run FailoverTxTest. Still has same problem as the Java client in that on fail-over the "transaction" continues but the earlier part of the transaction is forgotten. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@480283 13f79535-47bb-0310-9956-ffa450edef68 --- .../Qpid.Client/Client/Message/AMQMessage.cs | 25 +++++++++++++--------- 1 file changed, 15 insertions(+), 10 deletions(-) (limited to 'qpid/dotnet/Qpid.Client/Client/Message') diff --git a/qpid/dotnet/Qpid.Client/Client/Message/AMQMessage.cs b/qpid/dotnet/Qpid.Client/Client/Message/AMQMessage.cs index eb34fa45db..81499e31fe 100644 --- a/qpid/dotnet/Qpid.Client/Client/Message/AMQMessage.cs +++ b/qpid/dotnet/Qpid.Client/Client/Message/AMQMessage.cs @@ -31,22 +31,27 @@ namespace Qpid.Client.Message /// protected AmqChannel _channel; - public AMQMessage(IContentHeaderProperties properties) + private long _deliveryTag; + + public AMQMessage(IContentHeaderProperties properties, long deliveryTag) { _contentHeaderProperties = properties; + _deliveryTag = deliveryTag; } - public AmqChannel Channel + public AMQMessage(IContentHeaderProperties properties) : this(properties, -1) + { + } + + public long DeliveryTag { - get - { - return _channel; - } + get { return _deliveryTag; } + } - set - { - _channel = value; - } + public AmqChannel Channel + { + get { return _channel; } + set { _channel = value; } } } } -- cgit v1.2.1