plc4j/integrations/apache-nifi/nifi-plc4x-processors/src/main/java/org/apache/plc4x/nifi/Plc4xSinkProcessor.java [82:100]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                if (tags == null) {
                    if (debugEnabled)
                        logger.debug("Adding PlcTypes resolution into cache with key: " + addressMap);

                    // Parse plc addresses
                    Map<String, PlcTag> validAddressesPlcTags = new LinkedHashMap<>();
                    for (Map.Entry<String, String> entry : addressMap.entrySet()) {
                        Optional<PlcTag> newTag = connection.parseTagAddress(entry.getValue());
                        newTag.ifPresent(parsed -> validAddressesPlcTags.put(entry.getKey(), parsed));
                    }

                    getSchemaCache().addSchema(
                            addressMap,
                            validAddressesPlcTags.keySet(),
                            new ArrayList<>(validAddressesPlcTags.values()),
                            null
                    );
                }
            } catch (TimeoutException e) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



plc4j/integrations/apache-nifi/nifi-plc4x-processors/src/main/java/org/apache/plc4x/nifi/Plc4xSinkRecordProcessor.java [141:159]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
							if (tags == null) {
								if (debugEnabled)
									logger.debug("Adding PlcTypes resolution into cache with key: " + addressMap);

								// Parse plc addresses
								Map<String, PlcTag> validAddressesPlcTags = new LinkedHashMap<>();
								for (Map.Entry<String, String> entry : addressMap.entrySet()) {
									Optional<PlcTag> newTag = connection.parseTagAddress(entry.getValue());
									newTag.ifPresent(parsed -> validAddressesPlcTags.put(entry.getKey(), parsed));
								}

								getSchemaCache().addSchema(
										addressMap,
										validAddressesPlcTags.keySet(),
										new ArrayList<>(validAddressesPlcTags.values()),
										null
								);
							}
						} catch (TimeoutException e) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -