Skip to content

Commit a0f9770

Browse files
committed
Still have to review one failing test
1 parent e44930a commit a0f9770

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

spring-integration-redis/src/test/java/org/springframework/integration/redis/outbound/ReactiveRedisStreamMessageHandlerTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -120,14 +120,14 @@ public void explicitSerializationContextTest() {
120120

121121
assertThat(record.getStream()).isEqualTo(ReactiveRedisStreamMessageHandlerTestsContext.STREAM_KEY);
122122

123-
assertThat(record.getValue()).isEqualTo("[\"Hello\", \"stream\", \"message\"]");
123+
assertThat(record.getValue()).containsExactlyInAnyOrder("stream", "message", "Hello");
124124
}
125125

126126

127127
@Test
128128
@RedisAvailable
129129
public void explicitSerializationContextWithModelTest() {
130-
Address address = new Address().withAddress("Rennes, France");
130+
Address address = new Address("Rennes, France");
131131
Person person = new Person(address, "Attoumane");
132132

133133
Message message = new GenericMessage(person);

spring-integration-redis/src/test/java/org/springframework/integration/redis/util/Address.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,8 +34,7 @@ public void setAddress(String address) {
3434
public Address() {
3535
}
3636

37-
public Address withAddress(String address) {
38-
this.setAddress(address);
39-
return this;
37+
public Address(String address) {
38+
this.address = address;
4039
}
4140
}

0 commit comments

Comments
 (0)