diff options
Diffstat (limited to 'dotnet/Qpid.Common/Framing/AMQDataBlockDecoder.cs')
| -rw-r--r-- | dotnet/Qpid.Common/Framing/AMQDataBlockDecoder.cs | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/dotnet/Qpid.Common/Framing/AMQDataBlockDecoder.cs b/dotnet/Qpid.Common/Framing/AMQDataBlockDecoder.cs index 30be63013a..2e373402b6 100644 --- a/dotnet/Qpid.Common/Framing/AMQDataBlockDecoder.cs +++ b/dotnet/Qpid.Common/Framing/AMQDataBlockDecoder.cs @@ -130,7 +130,9 @@ namespace Qpid.Framing frame.PopulateFromBuffer(input, channel, bodySize, bodyFactory); byte marker = input.get(); - //assert marker == 0xCE; + if (marker != 0xCE) { + throw new FormatException("marker is not 0xCE"); + } return frame; } |