diff options
Diffstat (limited to 'dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs')
| -rw-r--r-- | dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs | 47 |
1 files changed, 10 insertions, 37 deletions
diff --git a/dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs b/dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs index 035a009006..c56ea28e53 100644 --- a/dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs +++ b/dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs @@ -32,29 +32,11 @@ namespace Qpid.Client.Message { private static readonly ILog _log = LogManager.GetLogger(typeof(AbstractQmsMessage)); -// protected long _messageNbr; - protected bool _redelivered; protected ByteBuffer _data; protected bool _readableMessage = false; - //protected AbstractQmsMessage() : base(new BasicContentHeaderProperties()) - //{ - //} - - //protected AbstractQmsMessage(ulong messageNbr, BasicContentHeaderProperties contentHeader) - // : this(contentHeader) - //{ - // _messageNbr = messageNbr; - //} - - //protected AbstractQmsMessage(BasicContentHeaderProperties contentHeader) - // : base(contentHeader) - //{ - //} - - #region new_java_ctrs protected AbstractQmsMessage(ByteBuffer data) @@ -374,11 +356,18 @@ namespace Qpid.Client.Message { get { - // make sure we rewind the data just in case any method has moved the - // position beyond the start if (_data != null) { - _data.rewind(); + if (!_readableMessage) + { + _data.flip(); + } + else + { + // Make sure we rewind the data just in case any method has moved the + // position beyond the start. + _data.rewind(); + } } return _data; } @@ -465,22 +454,6 @@ namespace Qpid.Client.Message } } - /// <summary> - /// Get the AMQ message number assigned to this message - /// </summary> - /// <returns>the message number</returns> - //public ulong MessageNbr - //{ - // get - // { - // return _messageNbr; - // } - // set - // { - // _messageNbr = value; - // } - //} - public BasicContentHeaderProperties ContentHeaderProperties { get |