summaryrefslogtreecommitdiff
path: root/dotnet/Qpid.Client/Client/Message/AMQMessageFactory.cs
diff options
context:
space:
mode:
authorRobert Greig <rgreig@apache.org>2007-02-26 17:46:07 +0000
committerRobert Greig <rgreig@apache.org>2007-02-26 17:46:07 +0000
commit3bfaba7fd65f251b68e8c4085582a4b62edf8e5d (patch)
tree6e90ae3729802623450af664e0a39a52f5f1b3f3 /dotnet/Qpid.Client/Client/Message/AMQMessageFactory.cs
parent2ea003c24ab3170dec118af6f9f8c128241cec65 (diff)
downloadqpid-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.cs10
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);
}