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));
}
}