You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2008/09/16 09:54:14 UTC
svn commit: r695758 -
/incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/network/Assembler.cs
Author: arnaudsimon
Date: Tue Sep 16 00:54:12 2008
New Revision: 695758
URL: http://svn.apache.org/viewvc?rev=695758&view=rev
Log:
qpid-1277: fixed small messages issue found when testing wcf
Modified:
incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/network/Assembler.cs
Modified: incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/network/Assembler.cs
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/network/Assembler.cs?rev=695758&r1=695757&r2=695758&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/network/Assembler.cs (original)
+++ incubator/qpid/trunk/qpid/dotnet/client-010/client/transport/network/Assembler.cs Tue Sep 16 00:54:12 2008
@@ -127,9 +127,13 @@
{
MemoryStream segment;
if (frame.isFirstFrame() && frame.isLastFrame())
- {
- segment = frame.Body;
- assemble(frame, segment);
+ {
+ byte[] tmp = new byte[frame.BodySize];
+ frame.Body.Read(tmp, 0, tmp.Length);
+ segment = new MemoryStream();
+ BinaryWriter w = new BinaryWriter(segment);
+ w.Write(tmp);
+ assemble(frame, new MemoryStream(tmp));
}
else
{