diff options
| author | Steven Shaw <steshaw@apache.org> | 2006-12-13 17:59:50 +0000 |
|---|---|---|
| committer | Steven Shaw <steshaw@apache.org> | 2006-12-13 17:59:50 +0000 |
| commit | fe2b1ac2e6968534650ed0341acd5f11ed42f38d (patch) | |
| tree | 1646dfe9293f2c0f3f3833433d549c39c29d3aed /dotnet/Qpid.Client/Client/Message/AbstractQmsMessage.cs | |
| parent | 5cef2357d12fd1e4a72c127adf47750bf42ea13d (diff) | |
| download | qpid-python-fe2b1ac2e6968534650ed0341acd5f11ed42f38d.tar.gz | |
QPID-182. GRM broke :(. We need to flip the buffer when getting the Data from the AbstractQmsMessage.
Also removed some commented out code.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@486778 13f79535-47bb-0310-9956-ffa450edef68
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 |