in proton-j/src/main/java/org/apache/qpid/proton/codec/transport/FastPathFlowType.java [118:162]
private final Flow readFields(DecoderImpl decoder, int count) {
Flow flow = new Flow();
for (int index = 0; index < count; ++index) {
switch (index) {
case 0:
flow.setNextIncomingId(decoder.readUnsignedInteger(null));
break;
case 1:
flow.setIncomingWindow(decoder.readUnsignedInteger(null));
break;
case 2:
flow.setNextOutgoingId(decoder.readUnsignedInteger(null));
break;
case 3:
flow.setOutgoingWindow(decoder.readUnsignedInteger(null));
break;
case 4:
flow.setHandle(decoder.readUnsignedInteger(null));
break;
case 5:
flow.setDeliveryCount(decoder.readUnsignedInteger(null));
break;
case 6:
flow.setLinkCredit(decoder.readUnsignedInteger(null));
break;
case 7:
flow.setAvailable(decoder.readUnsignedInteger(null));
break;
case 8:
flow.setDrain(decoder.readBoolean(false));
break;
case 9:
flow.setEcho(decoder.readBoolean(false));
break;
case 10:
flow.setProperties(decoder.readMap());
break;
default:
throw new IllegalStateException("To many entries in Flow encoding");
}
}
return flow;
}