From a0ba5d68901befbddc4f51cc5c19d0fb1fd73897 Mon Sep 17 00:00:00 2001
From: Vadim Guenther <vadim.guenther@bosch.io>
Date: Wed, 4 Nov 2020 13:47:07 +0100
Subject: [PATCH] Fix tests

Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
---
 .../messaging/validation/ConnectionValidatorTest.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java b/services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java
index d3c63ae544..e154bc8507 100644
--- a/services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java
+++ b/services/connectivity/messaging/src/test/java/org/eclipse/ditto/services/connectivity/messaging/validation/ConnectionValidatorTest.java
@@ -246,7 +246,7 @@ public void rejectConnectionWithEmptyTargetAddress() {
     @Test
     public void rejectConnectionWithInvalidTargetIssuedAck() {
         final Connection connection = createConnection(CONNECTION_ID).toBuilder()
-                .targets(TestConstants.Targets.TARGETS.stream()
+                .setTargets(TestConstants.Targets.TARGETS.stream()
                         .map(target -> ConnectivityModelFactory.newTargetBuilder(target)
                                 .issuedAcknowledgementLabel(AcknowledgementLabel.of("ack"))
                                 .build())
@@ -262,14 +262,14 @@ public void rejectConnectionWithInvalidTargetIssuedAck() {
     public void acceptConnectionWithValidSourceDeclaredAcksAndTargetIssuedAcks() {
         final Target targetTemplate = TestConstants.Targets.TWIN_TARGET;
         final Connection connection = createConnection(CONNECTION_ID).toBuilder()
-                .sources(TestConstants.Sources.SOURCES_WITH_SAME_ADDRESS.stream()
+                .setSources(TestConstants.Sources.SOURCES_WITH_SAME_ADDRESS.stream()
                         .map(source -> ConnectivityModelFactory.newSourceBuilder(source)
                                 .declaredAcknowledgementLabels(Set.of(AcknowledgementLabel.of(
                                         CONNECTION_ID + ":ack")))
                                 .build())
                         .collect(Collectors.toList())
                 )
-                .targets(List.of(
+                .setTargets(List.of(
                         ConnectivityModelFactory.newTargetBuilder(targetTemplate)
                                 .issuedAcknowledgementLabel(AcknowledgementLabel.of("live-response"))
                                 .build(),
@@ -287,13 +287,13 @@ public void acceptConnectionWithValidSourceDeclaredAcksAndTargetIssuedAcks() {
     public void acceptConnectionWithValidSourceDeclaredAcksAndTargetIssuedAcksUsingPlaceholder() {
         final Target targetTemplate = TestConstants.Targets.TWIN_TARGET;
         final Connection connection = createConnection(CONNECTION_ID).toBuilder()
-                .sources(TestConstants.Sources.SOURCES_WITH_SAME_ADDRESS.stream()
+                .setSources(TestConstants.Sources.SOURCES_WITH_SAME_ADDRESS.stream()
                         .map(source -> ConnectivityModelFactory.newSourceBuilder(source)
                                 .declaredAcknowledgementLabels(Set.of(AcknowledgementLabel.of("{{connection:id}}:ack")))
                                 .build())
                         .collect(Collectors.toList())
                 )
-                .targets(List.of(
+                .setTargets(List.of(
                         ConnectivityModelFactory.newTargetBuilder(targetTemplate)
                                 .issuedAcknowledgementLabel(AcknowledgementLabel.of("live-response"))
                                 .build(),