Skip to content

Commit

Permalink
Fix tests
Browse files Browse the repository at this point in the history
Signed-off-by: Vadim Guenther <vadim.guenther@bosch.io>
  • Loading branch information
VadimGue committed Nov 4, 2020
1 parent 89cd82e commit a0ba5d6
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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())
Expand All @@ -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(),
Expand All @@ -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(),
Expand Down

0 comments on commit a0ba5d6

Please sign in to comment.