diff options
| author | Gordon Sim <gsim@apache.org> | 2008-03-05 19:56:43 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-03-05 19:56:43 +0000 |
| commit | 7e162fa97ef0d430714b9630121a055fe5adece9 (patch) | |
| tree | 3e0a99d34d9718837a44802683f7fe6f49785613 /cpp/src/qpid/framing/AMQFrame.cpp | |
| parent | 86779be122dea590bc1e5201c58777ea3e362a95 (diff) | |
| download | qpid-python-7e162fa97ef0d430714b9630121a055fe5adece9.tar.gz | |
forked python tests for 0-10 preview and 0-10 final
fixed result handling in c++ broker
modified testlib in python to allow new 0-10 client to be run as well
converted query tests for final 0-10
added python tests for 0-10 final to automated set for c++ broker (most unconverted still)
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@634003 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/framing/AMQFrame.cpp')
| -rw-r--r-- | cpp/src/qpid/framing/AMQFrame.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/cpp/src/qpid/framing/AMQFrame.cpp b/cpp/src/qpid/framing/AMQFrame.cpp index 3750f4a9a8..eeb658600d 100644 --- a/cpp/src/qpid/framing/AMQFrame.cpp +++ b/cpp/src/qpid/framing/AMQFrame.cpp @@ -49,12 +49,15 @@ uint32_t AMQFrame::frameOverhead() { void AMQFrame::encode(Buffer& buffer) const { + //set track first (controls on track 0, everything else on 1): + uint8_t track = getBody()->type() ? 1 : 0; + uint8_t flags = (bof ? 0x08 : 0) | (eof ? 0x04 : 0) | (bos ? 0x02 : 0) | (eos ? 0x01 : 0); buffer.putOctet(flags); buffer.putOctet(getBody()->type()); buffer.putShort(size() - 1); // Don't include end marker (it's not part of the frame itself) buffer.putOctet(0); - buffer.putOctet(0x0f & subchannel); + buffer.putOctet(0x0f & track); buffer.putShort(channel); buffer.putLong(0); body->encode(buffer); |
