Skip to content

Commit 1836f73

Browse files
committed
fix:three nondeterminism tests
1 parent 4a4fd90 commit 1836f73

File tree

3 files changed

+7
-5
lines changed

3 files changed

+7
-5
lines changed

spring-cloud-aws-kinesis/src/test/java/io/awspring/cloud/kinesis/integration/KinesisMessageDrivenChannelAdapterTests.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -252,8 +252,9 @@ void resharding() throws InterruptedException {
252252

253253
KinesisShardEndedEvent kinesisShardEndedEvent = this.config.shardEndedEventReference.get();
254254

255-
assertThat(kinesisShardEndedEvent).isNotNull().extracting(KinesisShardEndedEvent::getShardKey)
256-
.isEqualTo("SpringIntegration:streamForResharding:closedEmptyShard5");
255+
assertThat(kinesisShardEndedEvent).isNotNull().extracting(KinesisShardEndedEvent::getShardKey).isIn(
256+
"SpringIntegration:" + STREAM_FOR_RESHARDING + ":closedEmptyShard5",
257+
"SpringIntegration:" + STREAM_FOR_RESHARDING + ":closedShard4");
257258
}
258259

259260
@Configuration

spring-cloud-aws-sns/src/test/java/io/awspring/cloud/sns/integration/SnsBodyBuilderTests.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,8 @@ void snsBodyBuilder() {
4545

4646
message = SnsBodyBuilder.withDefault("foo").forProtocols("{\"foo\" : \"bar\"}", "sms").build();
4747

48-
assertThat(message).isEqualTo("{\"default\":\"foo\",\"sms\":\"{\\\"foo\\\" : \\\"bar\\\"}\"}");
48+
assertThat(message).startsWith("{").endsWith("}").contains("\"default\":\"foo\"")
49+
.contains("\"sms\":\"{\\\"foo\\\" : \\\"bar\\\"}\"");
4950
}
5051

5152
}

spring-cloud-aws-sns/src/test/java/io/awspring/cloud/sns/integration/SnsMessageHandlerTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,8 +92,8 @@ void snsMessageHandler() {
9292
assertThat(publishRequest.subject()).isEqualTo("subject");
9393
assertThat(publishRequest.messageGroupId()).isEqualTo("SUBJECT");
9494
assertThat(publishRequest.messageDeduplicationId()).isEqualTo("TESTVALUE");
95-
assertThat(publishRequest.message())
96-
.isEqualTo("{\"default\":\"test data\",\"sms\":\"{\\\"testAttribute\\\" : \\\"test data\\\"}\"}");
95+
assertThat(publishRequest.message()).startsWith("{").endsWith("}").contains("\"default\":\"test data\"")
96+
.contains("\"sms\":\"{\\\"testAttribute\\\" : \\\"test data\\\"}\"");
9797

9898
Map<String, MessageAttributeValue> messageAttributes = publishRequest.messageAttributes();
9999

0 commit comments

Comments
 (0)