public void tightUnmarshal()

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


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

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

        info.setBrokerId((BrokerId) tightUnmarsalCachedObject(wireFormat, dataIn, bs));
        info.setBrokerURL(tightUnmarshalString(dataIn, bs));
        if (bs.readBoolean()) {
            short size = dataIn.readShort();
            BrokerInfo value[] = new BrokerInfo[size];
            for (int i = 0; i < size; i++) {
                value[i] = (BrokerInfo) tightUnmarsalNestedObject(wireFormat,dataIn, bs);
            }
            info.setPeerBrokerInfos(value);
        } else {
            info.setPeerBrokerInfos(null);
        }
        info.setBrokerName(tightUnmarshalString(dataIn, bs));
        info.setSlaveBroker(bs.readBoolean());
        info.setMasterBroker(bs.readBoolean());
        info.setFaultTolerantConfiguration(bs.readBoolean());
        if (version >= 2) {
            info.setDuplexConnection(bs.readBoolean());
        }
        if (version >= 2) {
            info.setNetworkConnection(bs.readBoolean());
        }
        if (version >= 2) {
            info.setConnectionId(tightUnmarshalLong(wireFormat, dataIn, bs));
        }
        if (version >= 3) {
            info.setBrokerUploadUrl(tightUnmarshalString(dataIn, bs));
        }
        if (version >= 3) {
            info.setNetworkProperties(tightUnmarshalString(dataIn, bs));
        }
    }