unnamed variables, code cleanup

hhund · hhund · commit 504749a8c443 · 2025-09-17T22:06:55.000+02:00
* Changed unused variables to unnamed variables (underscore)
* Some code cleanup
diff --git a/dsf-bpe/dsf-bpe-process-api-v1-impl/src/main/java/dev/dsf/bpe/v1/service/OrganizationProviderImpl.java b/dsf-bpe/dsf-bpe-process-api-v1-impl/src/main/java/dev/dsf/bpe/v1/service/OrganizationProviderImpl.java
@@ -141,6 +141,6 @@ public List<Organization> getRemoteOrganizations()
 
 		Map<String, List<String>> searchParameters = Map.of("active", List.of("true"), "identifier:not",
 				List.of(toSearchParameter(localOrganizationIdentifier.get())));
-		return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, o -> true);
+		return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, _ -> true);
 	}
 }
diff --git a/dsf-bpe/dsf-bpe-process-api-v1-impl/src/main/java/dev/dsf/fhir/authorization/read/ReadAccessHelperImpl.java b/dsf-bpe/dsf-bpe-process-api-v1-impl/src/main/java/dev/dsf/fhir/authorization/read/ReadAccessHelperImpl.java
@@ -284,7 +284,7 @@ public boolean hasAll(Resource resource)
 	@Override
 	public boolean isValid(Resource resource)
 	{
-		return isValid(resource, organizationIdentifier -> true, role -> true);
+		return isValid(resource, _ -> true, _ -> true);
 	}
 
 	@Override
diff --git a/dsf-bpe/dsf-bpe-process-api-v1/src/main/java/dev/dsf/fhir/authorization/process/ProcessAuthorizationHelperImpl.java b/dsf-bpe/dsf-bpe-process-api-v1/src/main/java/dev/dsf/fhir/authorization/process/ProcessAuthorizationHelperImpl.java
@@ -322,7 +322,7 @@ public Stream<Requester> getRequesters(ActivityDefinition activityDefinition, St
 							.equals(e.getUrl()))
 					.filter(Extension::hasValue).filter(e -> e.getValue() instanceof Coding)
 					.map(e -> (Coding) e.getValue())
-					.flatMap(coding -> requesterFrom(coding, c -> true, i -> true, c -> true).stream());
+					.flatMap(coding -> requesterFrom(coding, _ -> true, _ -> true, _ -> true).stream());
 	}
 
 	@Override
@@ -340,7 +340,7 @@ public Stream<Recipient> getRecipients(ActivityDefinition activityDefinition, St
 							.equals(e.getUrl()))
 					.filter(Extension::hasValue).filter(e -> e.getValue() instanceof Coding)
 					.map(e -> (Coding) e.getValue())
-					.flatMap(coding -> recipientFrom(coding, i -> true, c -> true).stream());
+					.flatMap(coding -> recipientFrom(coding, _ -> true, _ -> true).stream());
 	}
 
 	private Optional<Extension> getAuthorizationExtension(ActivityDefinition activityDefinition, String processUrl,
diff --git a/dsf-bpe/dsf-bpe-process-api-v2-impl/src/main/java/dev/dsf/bpe/v2/service/OrganizationProviderImpl.java b/dsf-bpe/dsf-bpe-process-api-v2-impl/src/main/java/dev/dsf/bpe/v2/service/OrganizationProviderImpl.java
@@ -142,14 +142,14 @@ public List<Organization> getRemoteOrganizations()
 		Map<String, List<String>> searchParameters = Map.of("active", List.of("true"), "identifier:not",
 				List.of(toSearchParameter(localOrganizationIdentifier.get())), "_profile",
 				List.of("http://dsf.dev/fhir/StructureDefinition/organization"));
-		return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, o -> true);
+		return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, _ -> true);
 	}
 
 	@Override
 	public List<Organization> getParentOrganizations()
 	{
 		Map<String, List<String>> searchParameters = Map.of("active", List.of("true"), "_profile",
 				List.of("http://dsf.dev/fhir/StructureDefinition/organization-parent"));
-		return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, o -> true);
+		return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, _ -> true);
 	}
 }
diff --git a/dsf-bpe/dsf-bpe-process-api-v2-impl/src/main/java/dev/dsf/bpe/v2/service/ReadAccessHelperImpl.java b/dsf-bpe/dsf-bpe-process-api-v2-impl/src/main/java/dev/dsf/bpe/v2/service/ReadAccessHelperImpl.java
@@ -298,7 +298,7 @@ public boolean hasAll(Resource resource)
 	@Override
 	public boolean isValid(Resource resource)
 	{
-		return isValid(resource, organizationIdentifier -> true, role -> true);
+		return isValid(resource, _ -> true, _ -> true);
 	}
 
 	@Override
diff --git a/dsf-bpe/dsf-bpe-process-api-v2-impl/src/main/java/dev/dsf/bpe/v2/service/process/ProcessAuthorizationHelperImpl.java b/dsf-bpe/dsf-bpe-process-api-v2-impl/src/main/java/dev/dsf/bpe/v2/service/process/ProcessAuthorizationHelperImpl.java
@@ -437,7 +437,7 @@ public Stream<Requester> getRequesters(ActivityDefinition activityDefinition, St
 					.filter(e -> EXTENSION_PROCESS_AUTHORIZATION_REQUESTER.equals(e.getUrl()))
 					.filter(Extension::hasValue).filter(e -> e.getValue() instanceof Coding)
 					.map(e -> (Coding) e.getValue())
-					.flatMap(coding -> requesterFrom(coding, c -> true, i -> true, c -> true).stream());
+					.flatMap(coding -> requesterFrom(coding, _ -> true, _ -> true, _ -> true).stream());
 	}
 
 	@Override
@@ -454,7 +454,7 @@ public Stream<Recipient> getRecipients(ActivityDefinition activityDefinition, St
 					.filter(e -> EXTENSION_PROCESS_AUTHORIZATION_RECIPIENT.equals(e.getUrl()))
 					.filter(Extension::hasValue).filter(e -> e.getValue() instanceof Coding)
 					.map(e -> (Coding) e.getValue())
-					.flatMap(coding -> recipientFrom(coding, i -> true, c -> true).stream());
+					.flatMap(coding -> recipientFrom(coding, _ -> true, _ -> true).stream());
 	}
 
 	private Optional<Extension> getAuthorizationExtension(ActivityDefinition activityDefinition, String processUrl,
diff --git a/dsf-bpe/dsf-bpe-process-api-v2/src/main/java/dev/dsf/bpe/v2/activity/task/DefaultTaskSender.java b/dsf-bpe/dsf-bpe-process-api-v2/src/main/java/dev/dsf/bpe/v2/activity/task/DefaultTaskSender.java
@@ -44,7 +44,7 @@ protected static record TaskAndConfig(Task task, String instantiatesCanonical, S
 	public DefaultTaskSender(ProcessPluginApi api, Variables variables, SendTaskValues sendTaskValues,
 			BusinessKeyStrategy businessKeyStrategy)
 	{
-		this(api, variables, sendTaskValues, businessKeyStrategy, t -> List.of());
+		this(api, variables, sendTaskValues, businessKeyStrategy, _ -> List.of());
 	}
 
 	public DefaultTaskSender(ProcessPluginApi api, Variables variables, SendTaskValues sendTaskValues,
diff --git a/dsf-bpe/dsf-bpe-process-api/src/main/java/dev/dsf/bpe/api/plugin/AbstractProcessPlugin.java b/dsf-bpe/dsf-bpe-process-api/src/main/java/dev/dsf/bpe/api/plugin/AbstractProcessPlugin.java
@@ -247,7 +247,7 @@ public boolean initializeAndValidateResources(String localOrganizationIdentifier
 		}
 
 		Map<String, Integer> processCounts = models.stream()
-				.collect(Collectors.toMap(m -> m.toProcessIdAndVersion().getId(), m -> 1, (c1, c2) -> c1 + c2));
+				.collect(Collectors.toMap(m -> m.toProcessIdAndVersion().getId(), _ -> 1, (c1, c2) -> c1 + c2));
 		if (processCounts.values().stream().anyMatch(c -> c > 1))
 		{
 			logger.warn("Ignoring process plugin {}-{} from {}: Processes with duplicate IDs found {}",
@@ -1164,7 +1164,7 @@ private boolean isValidQuestionnaire(String file, Object resource)
 	private Object modifyBaseDefinitionIfTaskProfile(Object resource, String file)
 	{
 		Optional<String> baseDefinition = fhirConfig.getStructureDefinitionBaseDefinition(resource);
-		baseDefinition.filter(d -> STRUCTURE_DEFINITION_BASE_TASK_URL_V1.equals(d)).ifPresent(d ->
+		baseDefinition.filter(d -> STRUCTURE_DEFINITION_BASE_TASK_URL_V1.equals(d)).ifPresent(_ ->
 		{
 			logger.info(
 					"Setting StructureDefinition.baseDefinition to {} for FHIR resource {} from process plugin {}-{}",
diff --git a/dsf-bpe/dsf-bpe-server/src/main/java/dev/dsf/bpe/camunda/MultiVersionClassDelegateActivityBehavior.java b/dsf-bpe/dsf-bpe-server/src/main/java/dev/dsf/bpe/camunda/MultiVersionClassDelegateActivityBehavior.java
@@ -40,14 +40,14 @@ protected ActivityBehavior getActivityBehaviorInstance(ActivityExecution executi
 
 			JavaDelegate delegate = switch (e.getBpmnModelElementInstance())
 			{
-				case SendTask st ->
+				case SendTask _ ->
 					delegateProvider.getMessageSendTask(processKeyAndVersion, className, fieldDeclarations, execution);
-				case ServiceTask st ->
+				case ServiceTask _ ->
 					delegateProvider.getServiceTask(processKeyAndVersion, className, fieldDeclarations, execution);
-				case EndEvent ee ->
+				case EndEvent _ ->
 					delegateProvider.getMessageEndEvent(processKeyAndVersion, className, fieldDeclarations, execution);
-				case IntermediateThrowEvent ite -> delegateProvider.getMessageIntermediateThrowEvent(
-						processKeyAndVersion, className, fieldDeclarations, execution);
+				case IntermediateThrowEvent _ -> delegateProvider.getMessageIntermediateThrowEvent(processKeyAndVersion,
+						className, fieldDeclarations, execution);
 
 				default -> throw new IllegalArgumentException("Unexpected value: " + e.getBpmnModelElementInstance());
 			};
diff --git a/dsf-bpe/dsf-bpe-server/src/main/java/dev/dsf/bpe/mail/SmtpMailService.java b/dsf-bpe/dsf-bpe-server/src/main/java/dev/dsf/bpe/mail/SmtpMailService.java
@@ -156,8 +156,8 @@ private Log4jAppender(Session session, MimeMessage message, String subject, int
 			MailManagerFactory factory = (name, data) -> new SmtpManager(name, session, message, data)
 			{
 			};
-			FactoryData data = new FactoryData(null, null, null, null, null, null, event -> subject, null, null, 0,
-					null, null, false, messageBufferSize, null, null);
+			FactoryData data = new FactoryData(null, null, null, null, null, null, _ -> subject, null, null, 0, null,
+					null, false, messageBufferSize, null, null);
 			manager = AbstractManager.getManager("SmtpMailService.Log4jAppender.Manager", factory, data);
 		}
 
diff --git a/dsf-bpe/dsf-bpe-server/src/main/java/dev/dsf/bpe/plugin/FhirResourceHandlerImpl.java b/dsf-bpe/dsf-bpe-server/src/main/java/dev/dsf/bpe/plugin/FhirResourceHandlerImpl.java
@@ -96,7 +96,7 @@ public void applyStateChangesAndStoreNewResourcesInDb(Map<ProcessIdAndVersion, L
 
 			currentOrOldProcessResources.forEach(res ->
 			{
-				resources.computeIfPresent(res.getResourceInfo(), (processInfo, processResource) ->
+				resources.computeIfPresent(res.getResourceInfo(), (_, processResource) ->
 				{
 					processResource.addAll(res.getProcesses());
 
diff --git a/dsf-bpe/dsf-bpe-server/src/main/java/dev/dsf/bpe/spring/config/AuthenticationConfig.java b/dsf-bpe/dsf-bpe-server/src/main/java/dev/dsf/bpe/spring/config/AuthenticationConfig.java
@@ -44,7 +44,7 @@ public IdentityProvider identityProvider()
 	public RoleConfig roleConfig()
 	{
 		RoleConfig config = new RoleConfigReader().read(propertiesConfig.getRoleConfig(),
-				role -> BpeServerRole.isValid(role) ? BpeServerRole.valueOf(role) : null, s -> null);
+				role -> BpeServerRole.isValid(role) ? BpeServerRole.valueOf(role) : null, _ -> null);
 
 		logger.info("Role config: {}", config.toString());
 		return config;
diff --git a/dsf-bpe/dsf-bpe-server/src/main/java/dev/dsf/bpe/subscription/ConcurrentSubscriptionHandlerFactory.java b/dsf-bpe/dsf-bpe-server/src/main/java/dev/dsf/bpe/subscription/ConcurrentSubscriptionHandlerFactory.java
@@ -35,7 +35,7 @@ public ConcurrentSubscriptionHandlerFactory(int corePoolSize, SubscriptionHandle
 			throw new IllegalArgumentException("corePoolSize <= 0");
 
 		executor = new ThreadPoolExecutor(corePoolSize, corePoolSize, 30, TimeUnit.MINUTES, queue,
-				(r, executor) -> logger.error("Unable to handle Task - execution rejected"));
+				(_, _) -> logger.error("Unable to handle Task - execution rejected"));
 		executor.allowCoreThreadTimeOut(true);
 
 		this.delegate = delegate;
diff --git a/dsf-bpe/dsf-bpe-test-plugin-v2/src/main/java/dev/dsf/bpe/test/service/ErrorBoundaryEventTestThrow.java b/dsf-bpe/dsf-bpe-test-plugin-v2/src/main/java/dev/dsf/bpe/test/service/ErrorBoundaryEventTestThrow.java
@@ -21,6 +21,6 @@ public void execute(ProcessPluginApi api, Variables variables) throws ErrorBound
 	@Override
 	public ServiceTaskErrorHandler getErrorHandler()
 	{
-		return new ExceptionToErrorBoundaryEventTranslationErrorHandler(e -> TEST_ERROR_CODE);
+		return new ExceptionToErrorBoundaryEventTranslationErrorHandler(_ -> TEST_ERROR_CODE);
 	}
 }
diff --git a/dsf-common/dsf-common-auth/src/test/java/dev/dsf/common/auth/RoleConfigReaderTest.java b/dsf-common/dsf-common-auth/src/test/java/dev/dsf/common/auth/RoleConfigReaderTest.java
@@ -12,24 +12,24 @@ public class RoleConfigReaderTest
 	@Test(expected = NullPointerException.class)
 	public void testReadNullString() throws Exception
 	{
-		new RoleConfigReader().read((String) null, s -> null, s -> null);
+		new RoleConfigReader().read((String) null, _ -> null, _ -> null);
 	}
 
 	@Test
 	public void testReadEmptyString() throws Exception
 	{
-		new RoleConfigReader().read("", s -> null, s -> null);
+		new RoleConfigReader().read("", _ -> null, _ -> null);
 	}
 
 	@Test(expected = NullPointerException.class)
 	public void testReadNullInputStream() throws Exception
 	{
-		new RoleConfigReader().read((InputStream) null, s -> null, s -> null);
+		new RoleConfigReader().read((InputStream) null, _ -> null, _ -> null);
 	}
 
 	@Test
 	public void testReadEmptyInputStream() throws Exception
 	{
-		new RoleConfigReader().read(new ByteArrayInputStream(new byte[0]), s -> null, s -> null);
+		new RoleConfigReader().read(new ByteArrayInputStream(new byte[0]), _ -> null, _ -> null);
 	}
 }
diff --git a/dsf-common/dsf-common-jetty/src/main/java/dev/dsf/common/logging/Log4jInitializer.java b/dsf-common/dsf-common-jetty/src/main/java/dev/dsf/common/logging/Log4jInitializer.java
@@ -180,11 +180,11 @@ else if (SPECIAL_JSON_LOGSTASH.equalsIgnoreCase(value))
 			return configuration -> JsonTemplateLayout.newBuilder().setConfiguration(configuration)
 					.setEventTemplateUri(TemplateUri.LOGSTASH.getUri()).build();
 		else if (SPECIAL_TEXT.equalsIgnoreCase(value))
-			return configuration -> PatternLayout.newBuilder().withPattern("%d %m%n").build();
+			return _ -> PatternLayout.newBuilder().withPattern("%d %m%n").build();
 		else if (SPECIAL_TEXT_MDC.equalsIgnoreCase(value))
-			return configuration -> PatternLayout.newBuilder().withPattern("%d%notEmpty{ %X} %m%n").build();
+			return _ -> PatternLayout.newBuilder().withPattern("%d%notEmpty{ %X} %m%n").build();
 		else if (SPECIAL_OFF.equalsIgnoreCase(value))
-			return configuration -> null;
+			return _ -> null;
 		else
 			throw new IllegalArgumentException("Value '" + value + "' for " + parameter + " not supported");
 	}
diff --git a/dsf-common/dsf-common-oidc/src/main/java/dev/dsf/common/oidc/JwtVerifierImpl.java b/dsf-common/dsf-common-oidc/src/main/java/dev/dsf/common/oidc/JwtVerifierImpl.java
@@ -45,7 +45,7 @@ public DecodedJWT verifyBackchannelLogout(String token) throws JWTVerificationEx
 		JWTVerifier verifier = oidcClient.getJwks().getKey(keyId).map(JwksKey::toAlgorithm).map(algorithm ->
 		{
 			return createVerification(algorithm).withAudience(clientId).withClaim("events",
-					(claim, jwt) -> claim.asMap().containsKey("http://schemas.openid.net/event/backchannel-logout"))
+					(claim, _) -> claim.asMap().containsKey("http://schemas.openid.net/event/backchannel-logout"))
 					.build();
 
 		}).orElseThrow(() -> new OidcClientException(
diff --git a/dsf-common/dsf-common-status/src/main/java/dev/dsf/common/status/webservice/StatusService.java b/dsf-common/dsf-common-status/src/main/java/dev/dsf/common/status/webservice/StatusService.java
@@ -55,7 +55,7 @@ public Response status(@Context UriInfo uri, @Context HttpHeaders headers, @Cont
 			return Response.status(Status.UNAUTHORIZED).build();
 		}
 
-		try (Connection connection = dataSource.getConnection())
+		try (Connection _ = dataSource.getConnection())
 		{
 			return Response.ok().build();
 		}
diff --git a/dsf-fhir/dsf-fhir-auth/src/main/java/dev/dsf/fhir/authorization/process/ProcessAuthorizationHelperImpl.java b/dsf-fhir/dsf-fhir-auth/src/main/java/dev/dsf/fhir/authorization/process/ProcessAuthorizationHelperImpl.java
@@ -322,7 +322,7 @@ public Stream<Requester> getRequesters(ActivityDefinition activityDefinition, St
 							.equals(e.getUrl()))
 					.filter(Extension::hasValue).filter(e -> e.getValue() instanceof Coding)
 					.map(e -> (Coding) e.getValue())
-					.flatMap(coding -> requesterFrom(coding, c -> true, i -> true, c -> true).stream());
+					.flatMap(coding -> requesterFrom(coding, _ -> true, _ -> true, _ -> true).stream());
 	}
 
 	@Override
@@ -340,7 +340,7 @@ public Stream<Recipient> getRecipients(ActivityDefinition activityDefinition, St
 							.equals(e.getUrl()))
 					.filter(Extension::hasValue).filter(e -> e.getValue() instanceof Coding)
 					.map(e -> (Coding) e.getValue())
-					.flatMap(coding -> recipientFrom(coding, i -> true, c -> true).stream());
+					.flatMap(coding -> recipientFrom(coding, _ -> true, _ -> true).stream());
 	}
 
 	private Optional<Extension> getAuthorizationExtension(ActivityDefinition activityDefinition, String processUrl,
diff --git a/dsf-fhir/dsf-fhir-auth/src/main/java/dev/dsf/fhir/authorization/read/ReadAccessHelperImpl.java b/dsf-fhir/dsf-fhir-auth/src/main/java/dev/dsf/fhir/authorization/read/ReadAccessHelperImpl.java
@@ -284,7 +284,7 @@ public boolean hasAll(Resource resource)
 	@Override
 	public boolean isValid(Resource resource)
 	{
-		return isValid(resource, organizationIdentifier -> true, role -> true);
+		return isValid(resource, _ -> true, _ -> true);
 	}
 
 	@Override
diff --git a/dsf-fhir/dsf-fhir-auth/src/test/java/dev/dsf/fhir/authorization/process/ProcessAuthorizationHelperTest.java b/dsf-fhir/dsf-fhir-auth/src/test/java/dev/dsf/fhir/authorization/process/ProcessAuthorizationHelperTest.java
@@ -69,7 +69,7 @@ public void testActivityDefinitionNotValidWithProcessAuthorizationsSameMessageNa
 		pa2.addExtension("recipient",
 				new Coding("http://dsf.dev/fhir/CodeSystem/process-authorization", "LOCAL_ALL", null));
 
-		assertFalse(helper.isValid(ad, p -> true, c -> true, o -> true, c -> true));
+		assertFalse(helper.isValid(ad, _ -> true, _ -> true, _ -> true, _ -> true));
 	}
 
 	@Test
@@ -80,7 +80,7 @@ public void testActivityDefinitionRequesterRemoteAllRecipientLocalAllValidViaFil
 		{
 			var ad = FhirContext.forR4().newXmlParser().parseResource(ActivityDefinition.class, in);
 
-			assertTrue(helper.isValid(ad, p -> true, c -> true, o -> true, c -> true));
+			assertTrue(helper.isValid(ad, _ -> true, _ -> true, _ -> true, _ -> true));
 		}
 	}
 
@@ -93,7 +93,7 @@ public void testActivityDefinitionRequesterRemoteOrganizationRecipientLocalParen
 		{
 			var ad = FhirContext.forR4().newXmlParser().parseResource(ActivityDefinition.class, in);
 
-			assertTrue(helper.isValid(ad, p -> true, c -> true, o -> true, c -> true));
+			assertTrue(helper.isValid(ad, _ -> true, _ -> true, _ -> true, _ -> true));
 		}
 	}
 
diff --git a/dsf-fhir/dsf-fhir-auth/src/test/java/dev/dsf/fhir/authorization/read/ReadAccessHelperTest.java b/dsf-fhir/dsf-fhir-auth/src/test/java/dev/dsf/fhir/authorization/read/ReadAccessHelperTest.java
@@ -52,7 +52,7 @@ public void testHasLocalViaFile() throws Exception
 			var r = FhirContext.forR4().newXmlParser().parseResource(CodeSystem.class, in);
 
 			assertTrue(helper.isValid(r));
-			assertTrue(helper.isValid(r, org -> false, role -> false));
+			assertTrue(helper.isValid(r, _ -> false, _ -> false));
 
 			assertTrue(helper.hasLocal(r));
 			assertFalse(helper.hasAll(r));
@@ -102,7 +102,7 @@ public void testHasOrganizationViaFile() throws Exception
 			var r = FhirContext.forR4().newXmlParser().parseResource(CodeSystem.class, in);
 
 			assertTrue(helper.isValid(r));
-			assertTrue(helper.isValid(r, org -> organizationIdentifier.equals(org.getValue()), role -> false));
+			assertTrue(helper.isValid(r, org -> organizationIdentifier.equals(org.getValue()), _ -> false));
 
 			assertTrue(helper.hasLocal(r));
 			assertTrue(helper.hasOrganization(r, organizationIdentifier));
@@ -202,7 +202,7 @@ public void testHasAllViaFile() throws Exception
 			var r = FhirContext.forR4().newXmlParser().parseResource(CodeSystem.class, in);
 
 			assertTrue(helper.isValid(r));
-			assertTrue(helper.isValid(r, org -> false, role -> false));
+			assertTrue(helper.isValid(r, _ -> false, _ -> false));
 			assertTrue(helper.hasAll(r));
 		}
 	}
@@ -235,7 +235,7 @@ public void testOrganizationValidWithTests() throws Exception
 		helper.addLocal(r);
 		helper.addOrganization(r, organizationIdentifier);
 
-		assertTrue(helper.isValid(r, org -> organizationIdentifier.equals(org.getValue()), role -> true));
+		assertTrue(helper.isValid(r, org -> organizationIdentifier.equals(org.getValue()), _ -> true));
 	}
 
 	@Test
diff --git a/dsf-fhir/dsf-fhir-rest-adapter/src/main/java/dev/dsf/fhir/adapter/FhirAdapter.java b/dsf-fhir/dsf-fhir-rest-adapter/src/main/java/dev/dsf/fhir/adapter/FhirAdapter.java
@@ -158,7 +158,7 @@ private void writeBundleWithBinary(MediaType mediaType, OutputStream entityStrea
 	{
 		Map<String, DeferredBase64BinaryType> dataByPlaceholder = getDeferredBase64BinaryTypes(bundle)
 				.collect(Collectors.toMap(DeferredBase64BinaryType::createPlaceHolderAndSetAsUserData,
-						Function.identity(), (a, b) -> a, LinkedHashMap::new));
+						Function.identity(), (a, _) -> a, LinkedHashMap::new));
 
 		String s = getParser(mediaType).encodeResourceToString(bundle);
 
diff --git a/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/adapter/ResourceTask.java b/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/adapter/ResourceTask.java
@@ -221,17 +221,17 @@ private String getHtmlInputType(Type typedValue)
 	{
 		return switch (typedValue)
 		{
-			case BooleanType b -> "boolean";
-			case DecimalType d -> "number";
-			case IntegerType i -> "number";
-			case DateType d -> "date";
-			case DateTimeType dt -> "datetime-local";
-			case TimeType t -> "time";
-			case InstantType i -> "datetime-local";
-			case StringType s -> "text";
-			case UriType u -> "url";
-			case Coding c -> "coding";
-			case Identifier i -> "identifier";
+			case BooleanType _ -> "boolean";
+			case DecimalType _ -> "number";
+			case IntegerType _ -> "number";
+			case DateType _ -> "date";
+			case DateTimeType _ -> "datetime-local";
+			case TimeType _ -> "time";
+			case InstantType _ -> "datetime-local";
+			case StringType _ -> "text";
+			case UriType _ -> "url";
+			case Coding _ -> "coding";
+			case Identifier _ -> "identifier";
 			case Reference r when r.hasReferenceElement() -> "url";
 			case Reference r when r.hasIdentifier() -> "identifier";
 
diff --git a/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/adapter/ThymeleafTemplateServiceImpl.java b/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/adapter/ThymeleafTemplateServiceImpl.java
@@ -163,7 +163,7 @@ private Optional<ThymeleafContext> getContext(Class<?> type, UriInfo uriInfo)
 		{
 			Optional<String> lastSegment = uriInfo.getPathSegments().stream().filter(Objects::nonNull)
 					.map(PathSegment::getPath).filter(Objects::nonNull).filter(s -> !s.isBlank())
-					.reduce((first, second) -> second);
+					.reduce((_, second) -> second);
 
 			return lastSegment.map(g::isResourceSupported).orElse(false);
 		}).findFirst();
diff --git a/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/authorization/ActivityDefinitionAuthorizationRule.java b/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/authorization/ActivityDefinitionAuthorizationRule.java
@@ -68,8 +68,7 @@ private Optional<String> newResourceOk(Connection connection, ActivityDefinition
 		List<String> errors = new ArrayList<>();
 
 		// TODO check existence of profiles, codes and identifier against DB
-		if (!processAuthorizationHelper.isValid(newResource, taskProfile -> true, practitionerRole -> true,
-				organizationIdentifier -> true, organizationRole -> true))
+		if (!processAuthorizationHelper.isValid(newResource, _ -> true, _ -> true, _ -> true, _ -> true))
 		{
 			errors.add("ActivityDefinition.extension with url "
 					+ ProcessAuthorizationHelper.EXTENSION_PROCESS_AUTHORIZATION
diff --git a/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/authorization/StructureDefinitionAuthorizationRule.java b/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/authorization/StructureDefinitionAuthorizationRule.java
@@ -96,7 +96,7 @@ protected boolean resourceExists(Connection connection, StructureDefinition newR
 		{
 			return getDao()
 					.readByUrlAndVersionWithTransaction(connection, newResource.getUrl(), newResource.getVersion())
-					.map(s -> true).orElse(false);
+					.isPresent();
 		}
 		catch (SQLException e)
 		{
diff --git a/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/dao/command/CommandFactoryImpl.java b/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/dao/command/CommandFactoryImpl.java
@@ -279,7 +279,7 @@ private <R extends Resource> Stream<Command> resolveReferences(Command cmd, int
 		Optional<? extends ResourceDao<R>> dao = (Optional<? extends ResourceDao<R>>) daoProvider
 				.getDao(resource.getClass());
 
-		if (referenceExtractor.getReferences(resource).anyMatch(r -> true)) // at least one entry
+		if (referenceExtractor.getReferences(resource).anyMatch(_ -> true)) // at least one entry
 		{
 			return dao.map(d -> Stream.of(cmd,
 					new CheckReferencesCommand<R, ResourceDao<R>>(index, identity, returnType, bundle, entry,
diff --git a/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/webservice/secure/AbstractResourceServiceSecure.java b/dsf-fhir/dsf-fhir-server/src/main/java/dev/dsf/fhir/webservice/secure/AbstractResourceServiceSecure.java
diff --git a/dsf-fhir/dsf-fhir-server/src/test/java/dev/dsf/fhir/integration/BinaryIntegrationTest.java b/dsf-fhir/dsf-fhir-server/src/test/java/dev/dsf/fhir/integration/BinaryIntegrationTest.java
diff --git a/dsf-fhir/dsf-fhir-server/src/test/java/dev/dsf/fhir/integration/ParallelCreateIntegrationTest.java b/dsf-fhir/dsf-fhir-server/src/test/java/dev/dsf/fhir/integration/ParallelCreateIntegrationTest.java

Original file line number	Diff line number	Diff line change
`@@ -141,6 +141,6 @@ public List<Organization> getRemoteOrganizations()`
`141`	`141`
`142`	`142`	`Map<String, List<String>> searchParameters = Map.of("active", List.of("true"), "identifier:not",`
`143`	`143`	`List.of(toSearchParameter(localOrganizationIdentifier.get())));`
`144`		`- return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, o -> true);`
	`144`	`+ return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, _ -> true);`
`145`	`145`	`}`
`146`	`146`	`}`
Original file line number	Diff line number	Diff line change
`@@ -284,7 +284,7 @@ public boolean hasAll(Resource resource)`
`284`	`284`	`@Override`
`285`	`285`	`public boolean isValid(Resource resource)`
`286`	`286`	`{`
`287`		`- return isValid(resource, organizationIdentifier -> true, role -> true);`
	`287`	`+ return isValid(resource, _ -> true, _ -> true);`
`288`	`288`	`}`
`289`	`289`
`290`	`290`	`@Override`
Original file line number	Diff line number	Diff line change
`@@ -142,14 +142,14 @@ public List<Organization> getRemoteOrganizations()`
`142`	`142`	`Map<String, List<String>> searchParameters = Map.of("active", List.of("true"), "identifier:not",`
`143`	`143`	`List.of(toSearchParameter(localOrganizationIdentifier.get())), "_profile",`
`144`	`144`	`List.of("http://dsf.dev/fhir/StructureDefinition/organization"));`
`145`		`- return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, o -> true);`
	`145`	`+ return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, _ -> true);`
`146`	`146`	`}`
`147`	`147`
`148`	`148`	`@Override`
`149`	`149`	`public List<Organization> getParentOrganizations()`
`150`	`150`	`{`
`151`	`151`	`Map<String, List<String>> searchParameters = Map.of("active", List.of("true"), "_profile",`
`152`	`152`	`List.of("http://dsf.dev/fhir/StructureDefinition/organization-parent"));`
`153`		`- return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, o -> true);`
	`153`	`+ return search(Organization.class, searchParameters, SearchEntryMode.MATCH, Organization.class, _ -> true);`
`154`	`154`	`}`
`155`	`155`	`}`
Original file line number	Diff line number	Diff line change
`@@ -298,7 +298,7 @@ public boolean hasAll(Resource resource)`
`298`	`298`	`@Override`
`299`	`299`	`public boolean isValid(Resource resource)`
`300`	`300`	`{`
`301`		`- return isValid(resource, organizationIdentifier -> true, role -> true);`
	`301`	`+ return isValid(resource, _ -> true, _ -> true);`
`302`	`302`	`}`
`303`	`303`
`304`	`304`	`@Override`
Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ protected static record TaskAndConfig(Task task, String instantiatesCanonical, S`
`44`	`44`	`public DefaultTaskSender(ProcessPluginApi api, Variables variables, SendTaskValues sendTaskValues,`
`45`	`45`	`BusinessKeyStrategy businessKeyStrategy)`
`46`	`46`	`{`
`47`		`- this(api, variables, sendTaskValues, businessKeyStrategy, t -> List.of());`
	`47`	`+ this(api, variables, sendTaskValues, businessKeyStrategy, _ -> List.of());`
`48`	`48`	`}`
`49`	`49`
`50`	`50`	`public DefaultTaskSender(ProcessPluginApi api, Variables variables, SendTaskValues sendTaskValues,`
Original file line number	Diff line number	Diff line change
`@@ -247,7 +247,7 @@ public boolean initializeAndValidateResources(String localOrganizationIdentifier`
`247`	`247`	`}`
`248`	`248`
`249`	`249`	`Map<String, Integer> processCounts = models.stream()`
`250`		`- .collect(Collectors.toMap(m -> m.toProcessIdAndVersion().getId(), m -> 1, (c1, c2) -> c1 + c2));`
	`250`	`+ .collect(Collectors.toMap(m -> m.toProcessIdAndVersion().getId(), _ -> 1, (c1, c2) -> c1 + c2));`
`251`	`251`	`if (processCounts.values().stream().anyMatch(c -> c > 1))`
`252`	`252`	`{`
`253`	`253`	`logger.warn("Ignoring process plugin {}-{} from {}: Processes with duplicate IDs found {}",`
`@@ -1164,7 +1164,7 @@ private boolean isValidQuestionnaire(String file, Object resource)`
`1164`	`1164`	`private Object modifyBaseDefinitionIfTaskProfile(Object resource, String file)`
`1165`	`1165`	`{`
`1166`	`1166`	`Optional<String> baseDefinition = fhirConfig.getStructureDefinitionBaseDefinition(resource);`
`1167`		`- baseDefinition.filter(d -> STRUCTURE_DEFINITION_BASE_TASK_URL_V1.equals(d)).ifPresent(d ->`
	`1167`	`+ baseDefinition.filter(d -> STRUCTURE_DEFINITION_BASE_TASK_URL_V1.equals(d)).ifPresent(_ ->`
`1168`	`1168`	`{`
`1169`	`1169`	`logger.info(`
`1170`	`1170`	`"Setting StructureDefinition.baseDefinition to {} for FHIR resource {} from process plugin {}-{}",`
Original file line number	Diff line number	Diff line change
`@@ -156,8 +156,8 @@ private Log4jAppender(Session session, MimeMessage message, String subject, int`
`156`	`156`	`MailManagerFactory factory = (name, data) -> new SmtpManager(name, session, message, data)`
`157`	`157`	`{`
`158`	`158`	`};`
`159`		`- FactoryData data = new FactoryData(null, null, null, null, null, null, event -> subject, null, null, 0,`
`160`		`- null, null, false, messageBufferSize, null, null);`
	`159`	`+ FactoryData data = new FactoryData(null, null, null, null, null, null, _ -> subject, null, null, 0, null,`
	`160`	`+ null, false, messageBufferSize, null, null);`
`161`	`161`	`manager = AbstractManager.getManager("SmtpMailService.Log4jAppender.Manager", factory, data);`
`162`	`162`	`}`
`163`	`163`