openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v6/DestinationInfoMarshaller.java [130:149]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); DestinationInfo info = (DestinationInfo) o; info.setConnectionId((ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setOperationType(dataIn.readByte()); info.setTimeout(looseUnmarshalLong(wireFormat, 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); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v8/DestinationInfoMarshaller.java [130:149]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); DestinationInfo info = (DestinationInfo) o; info.setConnectionId((ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setOperationType(dataIn.readByte()); info.setTimeout(looseUnmarshalLong(wireFormat, 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); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v9/DestinationInfoMarshaller.java [130:149]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); DestinationInfo info = (DestinationInfo) o; info.setConnectionId((ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setOperationType(dataIn.readByte()); info.setTimeout(looseUnmarshalLong(wireFormat, 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); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v7/DestinationInfoMarshaller.java [130:149]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); DestinationInfo info = (DestinationInfo) o; info.setConnectionId((ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setOperationType(dataIn.readByte()); info.setTimeout(looseUnmarshalLong(wireFormat, 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); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v2/DestinationInfoMarshaller.java [130:149]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); DestinationInfo info = (DestinationInfo) o; info.setConnectionId((ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setOperationType(dataIn.readByte()); info.setTimeout(looseUnmarshalLong(wireFormat, 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); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v5/DestinationInfoMarshaller.java [130:149]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); DestinationInfo info = (DestinationInfo) o; info.setConnectionId((ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setOperationType(dataIn.readByte()); info.setTimeout(looseUnmarshalLong(wireFormat, 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); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v4/DestinationInfoMarshaller.java [130:149]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); DestinationInfo info = (DestinationInfo) o; info.setConnectionId((ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setOperationType(dataIn.readByte()); info.setTimeout(looseUnmarshalLong(wireFormat, 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); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v3/DestinationInfoMarshaller.java [130:149]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); DestinationInfo info = (DestinationInfo) o; info.setConnectionId((ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setOperationType(dataIn.readByte()); info.setTimeout(looseUnmarshalLong(wireFormat, 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); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v11/DestinationInfoMarshaller.java [130:149]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); DestinationInfo info = (DestinationInfo) o; info.setConnectionId((ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setOperationType(dataIn.readByte()); info.setTimeout(looseUnmarshalLong(wireFormat, 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); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v10/DestinationInfoMarshaller.java [130:149]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { super.looseUnmarshal(wireFormat, o, dataIn); DestinationInfo info = (DestinationInfo) o; info.setConnectionId((ConnectionId) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn)); info.setOperationType(dataIn.readByte()); info.setTimeout(looseUnmarshalLong(wireFormat, 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); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -