summaryrefslogtreecommitdiff
path: root/dotnet/Qpid.Common/Framing/FieldTable.cs
diff options
context:
space:
mode:
Diffstat (limited to 'dotnet/Qpid.Common/Framing/FieldTable.cs')
-rw-r--r--dotnet/Qpid.Common/Framing/FieldTable.cs22
1 files changed, 11 insertions, 11 deletions
diff --git a/dotnet/Qpid.Common/Framing/FieldTable.cs b/dotnet/Qpid.Common/Framing/FieldTable.cs
index 4c613aa80d..193d96f6cd 100644
--- a/dotnet/Qpid.Common/Framing/FieldTable.cs
+++ b/dotnet/Qpid.Common/Framing/FieldTable.cs
@@ -60,10 +60,10 @@ namespace Qpid.Framing
int sizeRead = 0;
while (sizeRead < _encodedSize)
{
- int sizeRemaining = buffer.Remaining;
+ int sizeRemaining = buffer.remaining();
string key = EncodingUtils.ReadShortString(buffer);
// TODO: use proper charset decoder
- char type = (char)buffer.Get();
+ char type = (char)buffer.get();
object value;
switch (type)
{
@@ -76,7 +76,7 @@ namespace Qpid.Framing
default:
throw new AMQFrameDecodingException("Unsupported field table type: '" + type + "' charcode" + (int)type);
}
- sizeRead += (sizeRemaining - buffer.Remaining);
+ sizeRead += (sizeRemaining - buffer.remaining());
_hash.Add(key, value);
}
@@ -123,7 +123,7 @@ namespace Qpid.Framing
public void WriteToBuffer(ByteBuffer buffer)
{
// Write out the total length, which we have kept up to date as data is added.
- buffer.Put(_encodedSize);
+ buffer.put(_encodedSize);
WritePayload(buffer);
}
@@ -136,20 +136,20 @@ namespace Qpid.Framing
object value = lde.Value;
if (value is byte[])
{
- buffer.Put((byte) 'S');
+ buffer.put((byte) 'S');
EncodingUtils.WriteLongstr(buffer, (byte[]) value);
}
else if (value is string)
{
// TODO: look at using proper charset encoder
- buffer.Put((byte) 'S');
+ buffer.put((byte) 'S');
EncodingUtils.WriteLongStringBytes(buffer, (string) value);
}
else if (value is uint)
{
// TODO: look at using proper charset encoder
- buffer.Put((byte) 'I');
- buffer.Put((uint) value);
+ buffer.put((byte) 'I');
+ buffer.put((uint) value);
}
else
{
@@ -161,11 +161,11 @@ namespace Qpid.Framing
public byte[] GetDataAsBytes()
{
- ByteBuffer buffer = ByteBuffer.Allocate((int)_encodedSize);
+ ByteBuffer buffer = ByteBuffer.allocate((int)_encodedSize);
WritePayload(buffer);
byte[] result = new byte[_encodedSize];
- buffer.Flip();
- buffer.Get(result);
+ buffer.flip();
+ buffer.get(result);
//buffer.Release();
return result;
}