Test fixes for AssertJ changes
This commit is contained in:
@@ -31,7 +31,6 @@ import org.springframework.integration.IntegrationMessageHeaderAccessor;
|
||||
import org.springframework.integration.channel.QueueChannel;
|
||||
import org.springframework.integration.support.MessageBuilder;
|
||||
import org.springframework.messaging.Message;
|
||||
import org.springframework.messaging.MessageHeaders;
|
||||
import org.springframework.messaging.support.GenericMessage;
|
||||
|
||||
import reactor.core.publisher.Flux;
|
||||
@@ -65,7 +64,7 @@ class FluxAggregatorMessageHandlerTests {
|
||||
assertThat(result).isNotNull()
|
||||
.extracting(Message::getHeaders)
|
||||
.satisfies((headers) ->
|
||||
assertThat((MessageHeaders) headers)
|
||||
assertThat(headers)
|
||||
.containsEntry(IntegrationMessageHeaderAccessor.CORRELATION_ID, 0));
|
||||
|
||||
Object payload = result.getPayload();
|
||||
@@ -87,7 +86,7 @@ class FluxAggregatorMessageHandlerTests {
|
||||
assertThat(result).isNotNull()
|
||||
.extracting(Message::getHeaders)
|
||||
.satisfies((headers) ->
|
||||
assertThat((MessageHeaders) headers)
|
||||
assertThat(headers)
|
||||
.containsEntry(IntegrationMessageHeaderAccessor.CORRELATION_ID, 1));
|
||||
|
||||
payload = result.getPayload();
|
||||
|
||||
@@ -56,6 +56,7 @@ import org.springframework.test.context.junit4.SpringRunner;
|
||||
|
||||
import com.fasterxml.jackson.databind.node.ArrayNode;
|
||||
import com.fasterxml.jackson.databind.node.TextNode;
|
||||
|
||||
import reactor.core.publisher.Flux;
|
||||
import reactor.test.StepVerifier;
|
||||
|
||||
@@ -168,7 +169,7 @@ public class CorrelationHandlerTests {
|
||||
.isNotNull()
|
||||
.extracting(Message::getPayload)
|
||||
.isInstanceOf(ArrayNode.class)
|
||||
.extracting("_children")
|
||||
.extracting(new String[] { "_children" })
|
||||
.element(0)
|
||||
.asList()
|
||||
.hasSize(0);
|
||||
|
||||
@@ -99,7 +99,7 @@ public class TransformerTests {
|
||||
TestPojo result = (TestPojo) payload;
|
||||
assertThat(result.getName()).isEqualTo("Bar Bar");
|
||||
assertThat(result.getDate()).isNotNull();
|
||||
assertThat(new Date()).isAfterOrEqualsTo(result.getDate());
|
||||
assertThat(new Date()).isAfterOrEqualTo(result.getDate());
|
||||
|
||||
this.enricherInput.send(new GenericMessage<>(new TestPojo("junk")));
|
||||
|
||||
@@ -122,7 +122,7 @@ public class TransformerTests {
|
||||
TestPojo result = (TestPojo) payload;
|
||||
assertThat(result.getName()).isEqualTo("Bar Bar");
|
||||
assertThat(result.getDate()).isNotNull();
|
||||
assertThat(new Date()).isAfterOrEqualsTo(result.getDate());
|
||||
assertThat(new Date()).isAfterOrEqualTo(result.getDate());
|
||||
}
|
||||
|
||||
@Test
|
||||
|
||||
Reference in New Issue
Block a user