summaryrefslogtreecommitdiff
path: root/qpid/java/common
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2008-06-16 21:01:51 +0000
committerRafael H. Schloming <rhs@apache.org>2008-06-16 21:01:51 +0000
commit29302ff81b4874e2ed09341cd334599d5541b9e6 (patch)
tree06fdfee8b7f452b968c50ccb6e6fb5ef9618b135 /qpid/java/common
parentb96140b9c47e40ef97bc0b85712c8fb76c8e2458 (diff)
downloadqpid-python-29302ff81b4874e2ed09341cd334599d5541b9e6.tar.gz
QPID-901: set the frame track correctly
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@668308 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common')
-rw-r--r--qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Disassembler.java10
1 files changed, 4 insertions, 6 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Disassembler.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Disassembler.java
index 709b4f0e02..da9ba84ab0 100644
--- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Disassembler.java
+++ b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/Disassembler.java
@@ -80,6 +80,8 @@ public class Disassembler implements Sender<ConnectionEvent>,
private void fragment(byte flags, SegmentType type, ConnectionEvent event,
ByteBuffer buf, boolean first, boolean last)
{
+ byte track = event.getProtocolEvent().getEncodedTrack() == Frame.L4 ? (byte) 1 : (byte) 0;
+
if(!buf.hasRemaining())
{
//empty data
@@ -90,9 +92,7 @@ public class Disassembler implements Sender<ConnectionEvent>,
first = false;
}
nflags |= LAST_FRAME;
- Frame frame = new Frame(nflags, type,
- event.getProtocolEvent().getEncodedTrack(),
- event.getChannel());
+ Frame frame = new Frame(nflags, type, track, event.getChannel());
// frame.addFragment(buf);
sender.send(frame);
}
@@ -115,9 +115,7 @@ public class Disassembler implements Sender<ConnectionEvent>,
newflags |= LAST_FRAME;
}
- Frame frame = new Frame(newflags, type,
- event.getProtocolEvent().getEncodedTrack(),
- event.getChannel());
+ Frame frame = new Frame(newflags, type, track, event.getChannel());
frame.addFragment(slice);
sender.send(frame);
}