diff options
| author | Robert Greig <rgreig@apache.org> | 2007-02-26 17:46:07 +0000 |
|---|---|---|
| committer | Robert Greig <rgreig@apache.org> | 2007-02-26 17:46:07 +0000 |
| commit | 3bfaba7fd65f251b68e8c4085582a4b62edf8e5d (patch) | |
| tree | 6e90ae3729802623450af664e0a39a52f5f1b3f3 /dotnet/Qpid.Client/Client/Message/AMQMessageFactory.cs | |
| parent | 2ea003c24ab3170dec118af6f9f8c128241cec65 (diff) | |
| download | qpid-python-3bfaba7fd65f251b68e8c4085582a4b62edf8e5d.tar.gz | |
(Patch submitted by Tomas Restrepo) QPID-ByteBuffer.diff.
Completely refactors the byte buffer implementation, doing away with a complex inheritance hierarchy.
Fixes reading and writing of field table to permit interop with Java client.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@511923 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'dotnet/Qpid.Client/Client/Message/AMQMessageFactory.cs')
| -rw-r--r-- | dotnet/Qpid.Client/Client/Message/AMQMessageFactory.cs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/dotnet/Qpid.Client/Client/Message/AMQMessageFactory.cs b/dotnet/Qpid.Client/Client/Message/AMQMessageFactory.cs index 13a6fa8113..75c4edd67d 100644 --- a/dotnet/Qpid.Client/Client/Message/AMQMessageFactory.cs +++ b/dotnet/Qpid.Client/Client/Message/AMQMessageFactory.cs @@ -43,20 +43,20 @@ namespace Qpid.Client.Message if (bodies != null && bodies.Count == 1) { _logger.Debug("Non-fragmented message body (bodySize=" + contentHeader.BodySize +")"); - data = ByteBuffer.wrap(((ContentBody)bodies[0]).Payload); + data = ByteBuffer.Wrap(((ContentBody)bodies[0]).Payload); } else { _logger.Debug("Fragmented message body (" + bodies.Count + " frames, bodySize=" + contentHeader.BodySize + ")"); - data = ByteBuffer.allocate((int)contentHeader.BodySize); // XXX: Is cast a problem? + data = ByteBuffer.Allocate((int)contentHeader.BodySize); // XXX: Is cast a problem? foreach (ContentBody body in bodies) { - data.put(body.Payload); + data.Put(body.Payload); //body.Payload.Release(); } - data.flip(); + data.Flip(); } - _logger.Debug("Creating message from buffer with position=" + data.position() + " and remaining=" + data.remaining()); + _logger.Debug("Creating message from buffer with position=" + data.Position + " and remaining=" + data.Remaining); return CreateMessage(messageNbr, data, contentHeader); } |
