private void writeTightUnmarshal()

in openwire-generator/src/main/java/org/apache/activemq/openwire/generator/builtin/UniversalMarshallerGenerator.java [158:263]
97 lines of code
23 McCabe index (conditional complexity)

    private void writeTightUnmarshal(PrintWriter out, OpenWireTypeDescriptor openWireType) {
        out.println("    /**");
        out.println("     * Un-marshal an object instance from the data input stream");
        out.println("     *");
        out.println("     * @param wireFormat the OpenWireFormat instance to use");
        out.println("     * @param target the object to un-marshal");
        out.println("     * @param dataIn the data input stream to build the object from");
        out.println("     * @param bs the boolean stream where the type's booleans were marshaled");
        out.println("     *");
        out.println("     * @throws IOException if an error occurs while reading the data");
        out.println("     */");
        out.println("    public void tightUnmarshal(OpenWireFormat wireFormat, Object target, DataInput dataIn, BooleanStream bs) throws IOException {");
        out.println("        super.tightUnmarshal(wireFormat, target, dataIn, bs);");

        if (openWireType.hasProperties()) {
            out.println("");
            out.println("        " + openWireType.getTypeName() + " info = (" + openWireType.getTypeName() + ") target;");
            if (isOpenWireVersionNeeded(openWireType)) {
                out.println("        int version = wireFormat.getVersion();");
            }
            out.println("");
        }

        if (openWireType.isMarshalAware()) {
            out.println("        info.beforeUnmarshall(wireFormat);");
        }

        for (final OpenWirePropertyDescriptor property : openWireType.getProperties()) {
            final int size = property.getSize();
            final String typeName = property.getTypeName();
            final String setter = property.getSetterName();

            String indent = "        ";
            if (property.getVersion() > 1) {
                indent = indent + "    ";
                out.println("        if (version >= " + property.getVersion() + ") {");
            }

            if (property.isArray() && !typeName.equals("byte[]")) {
                final String arrayType = property.getType().getComponentType().getSimpleName();

                if (size > 0) {
                    out.println(indent + "{");
                    out.println(indent + "    " + arrayType + " value[] = new " + arrayType + "[" + size + "];");
                    out.println(indent + "    " + "for (int i = 0; i < " + size + "; i++) {");
                    out.println(indent + "        value[i] = (" + arrayType + ") tightUnmarsalNestedObject(wireFormat,dataIn, bs);");
                    out.println(indent + "    }");
                    out.println(indent + "    info." + setter + "(value);");
                    out.println(indent + "}");
                } else {
                    out.println(indent + "if (bs.readBoolean()) {");
                    out.println(indent + "    short size = dataIn.readShort();");
                    out.println(indent + "    " + arrayType + " value[] = new " + arrayType + "[size];");
                    out.println(indent + "    for (int i = 0; i < size; i++) {");
                    out.println(indent + "        value[i] = (" + arrayType + ") tightUnmarsalNestedObject(wireFormat,dataIn, bs);");
                    out.println(indent + "    }");
                    out.println(indent + "    info." + setter + "(value);");
                    out.println(indent + "} else {");
                    out.println(indent + "    info." + setter + "(null);");
                    out.println(indent + "}");
                }
            } else {
                if (typeName.equals("boolean")) {
                    out.println(indent + "info." + setter + "(bs.readBoolean());");
                } else if (typeName.equals("byte")) {
                    out.println(indent + "info." + setter + "(dataIn.readByte());");
                } else if (typeName.equals("char")) {
                    out.println(indent + "info." + setter + "(dataIn.readChar());");
                } else if (typeName.equals("short")) {
                    out.println(indent + "info." + setter + "(dataIn.readShort());");
                } else if (typeName.equals("int")) {
                    out.println(indent + "info." + setter + "(dataIn.readInt());");
                } else if (typeName.equals("long")) {
                    out.println(indent + "info." + setter + "(tightUnmarshalLong(wireFormat, dataIn, bs));");
                } else if (typeName.equals("String")) {
                    out.println(indent + "info." + setter + "(tightUnmarshalString(dataIn, bs));");
                } else if (typeName.equals("byte[]")) {
                    if (size >= 0) {
                        out.println(indent + "info." + setter + "(tightUnmarshalConstByteArray(dataIn, bs, " + size + "));");
                    } else {
                        out.println(indent + "info." + setter + "(tightUnmarshalByteArray(dataIn, bs));");
                    }
                } else if (typeName.equals("Buffer")) {
                    out.println(indent + "info." + setter + "(tightUnmarshalByteSequence(dataIn, bs));");
                } else if (property.isThrowable()) {
                    out.println(indent + "info." + setter + "((" + property.getTypeName() + ") tightUnmarsalThrowable(wireFormat, dataIn, bs));");
                } else if (property.isCached()) {
                    out.println(indent + "info." + setter + "((" + property.getTypeName() + ") tightUnmarsalCachedObject(wireFormat, dataIn, bs));");
                } else {
                    out.println(indent + "info." + setter + "((" + property.getTypeName() + ") tightUnmarsalNestedObject(wireFormat, dataIn, bs));");
                }
            }

            if (property.getVersion() > 1) {
                out.println("        }");
            }
        }

        if (openWireType.isMarshalAware()) {
            out.println("");
            out.println("        info.afterUnmarshall(wireFormat);");
        }

        out.println("    }");
        out.println("");
    }