public void looseUnmarshal()

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

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

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

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

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