openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v6/BrokerInfoMarshaller.java [59:85]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException { super.tightUnmarshal(wireFormat, o, dataIn, bs); BrokerInfo info = (BrokerInfo) o; 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()); info.setDuplexConnection(bs.readBoolean()); info.setNetworkConnection(bs.readBoolean()); info.setConnectionId(tightUnmarshalLong(wireFormat, dataIn, bs)); info.setBrokerUploadUrl(tightUnmarshalString(dataIn, bs)); info.setNetworkProperties(tightUnmarshalString(dataIn, bs)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v8/BrokerInfoMarshaller.java [59:85]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException { super.tightUnmarshal(wireFormat, o, dataIn, bs); BrokerInfo info = (BrokerInfo) o; 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()); info.setDuplexConnection(bs.readBoolean()); info.setNetworkConnection(bs.readBoolean()); info.setConnectionId(tightUnmarshalLong(wireFormat, dataIn, bs)); info.setBrokerUploadUrl(tightUnmarshalString(dataIn, bs)); info.setNetworkProperties(tightUnmarshalString(dataIn, bs)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v9/BrokerInfoMarshaller.java [59:85]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException { super.tightUnmarshal(wireFormat, o, dataIn, bs); BrokerInfo info = (BrokerInfo) o; 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()); info.setDuplexConnection(bs.readBoolean()); info.setNetworkConnection(bs.readBoolean()); info.setConnectionId(tightUnmarshalLong(wireFormat, dataIn, bs)); info.setBrokerUploadUrl(tightUnmarshalString(dataIn, bs)); info.setNetworkProperties(tightUnmarshalString(dataIn, bs)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v7/BrokerInfoMarshaller.java [59:85]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException { super.tightUnmarshal(wireFormat, o, dataIn, bs); BrokerInfo info = (BrokerInfo) o; 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()); info.setDuplexConnection(bs.readBoolean()); info.setNetworkConnection(bs.readBoolean()); info.setConnectionId(tightUnmarshalLong(wireFormat, dataIn, bs)); info.setBrokerUploadUrl(tightUnmarshalString(dataIn, bs)); info.setNetworkProperties(tightUnmarshalString(dataIn, bs)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v5/BrokerInfoMarshaller.java [59:85]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException { super.tightUnmarshal(wireFormat, o, dataIn, bs); BrokerInfo info = (BrokerInfo) o; 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()); info.setDuplexConnection(bs.readBoolean()); info.setNetworkConnection(bs.readBoolean()); info.setConnectionId(tightUnmarshalLong(wireFormat, dataIn, bs)); info.setBrokerUploadUrl(tightUnmarshalString(dataIn, bs)); info.setNetworkProperties(tightUnmarshalString(dataIn, bs)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v4/BrokerInfoMarshaller.java [59:85]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException { super.tightUnmarshal(wireFormat, o, dataIn, bs); BrokerInfo info = (BrokerInfo) o; 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()); info.setDuplexConnection(bs.readBoolean()); info.setNetworkConnection(bs.readBoolean()); info.setConnectionId(tightUnmarshalLong(wireFormat, dataIn, bs)); info.setBrokerUploadUrl(tightUnmarshalString(dataIn, bs)); info.setNetworkProperties(tightUnmarshalString(dataIn, bs)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v3/BrokerInfoMarshaller.java [59:85]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException { super.tightUnmarshal(wireFormat, o, dataIn, bs); BrokerInfo info = (BrokerInfo) o; 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()); info.setDuplexConnection(bs.readBoolean()); info.setNetworkConnection(bs.readBoolean()); info.setConnectionId(tightUnmarshalLong(wireFormat, dataIn, bs)); info.setBrokerUploadUrl(tightUnmarshalString(dataIn, bs)); info.setNetworkProperties(tightUnmarshalString(dataIn, bs)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v11/BrokerInfoMarshaller.java [59:85]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException { super.tightUnmarshal(wireFormat, o, dataIn, bs); BrokerInfo info = (BrokerInfo) o; 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()); info.setDuplexConnection(bs.readBoolean()); info.setNetworkConnection(bs.readBoolean()); info.setConnectionId(tightUnmarshalLong(wireFormat, dataIn, bs)); info.setBrokerUploadUrl(tightUnmarshalString(dataIn, bs)); info.setNetworkProperties(tightUnmarshalString(dataIn, bs)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v10/BrokerInfoMarshaller.java [59:85]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn, BooleanStream bs) throws IOException { super.tightUnmarshal(wireFormat, o, dataIn, bs); BrokerInfo info = (BrokerInfo) o; 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()); info.setDuplexConnection(bs.readBoolean()); info.setNetworkConnection(bs.readBoolean()); info.setConnectionId(tightUnmarshalLong(wireFormat, dataIn, bs)); info.setBrokerUploadUrl(tightUnmarshalString(dataIn, bs)); info.setNetworkProperties(tightUnmarshalString(dataIn, bs)); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -