public void tightUnmarshal()

in openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/ConnectionInfoMarshaller.java [60:94]

• 33 lines of code
• 7 McCabe index (conditional complexity)

    public void tightUnmarshal(OpenWireFormat wireFormat, Object target, DataInput dataIn, BooleanStream bs) throws IOException {
        super.tightUnmarshal(wireFormat, target, dataIn, bs);

        ConnectionInfo info = (ConnectionInfo) target;
        int version = wireFormat.getVersion();

        info.setConnectionId((ConnectionId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
        info.setClientId(tightUnmarshalString(dataIn, bs));
        info.setPassword(tightUnmarshalString(dataIn, bs));
        info.setUserName(tightUnmarshalString(dataIn, bs));
        if (bs.readBoolean()) {
            short size = dataIn.readShort();
            BrokerId value[] = new BrokerId[size];
            for (int i = 0; i < size; i++) {
                value[i] = (BrokerId) tightUnmarsalNestedObject(wireFormat,dataIn, bs);
            }
            info.setBrokerPath(value);
        } else {
            info.setBrokerPath(null);
        }
        info.setBrokerMasterConnector(bs.readBoolean());
        info.setManageable(bs.readBoolean());
        if (version >= 2) {
            info.setClientMaster(bs.readBoolean());
        }
        if (version >= 6) {
            info.setFaultTolerant(bs.readBoolean());
        }
        if (version >= 6) {
            info.setFailoverReconnect(bs.readBoolean());
        }
        if (version >= 8) {
            info.setClientIp(tightUnmarshalString(dataIn, bs));
        }
    }