File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
basic/mqtt5/src/test/java/org/springframework/integration/samples/mqtt5 Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change 1
1
package org .springframework .integration .samples .mqtt5 ;
2
2
3
- import static org .assertj .core .api .Assertions .assertThat ;
3
+ import static org .junit .Assert .assertTrue ;
4
+ import static org .junit .jupiter .api .Assertions .assertEquals ;
4
5
import static org .mockito .ArgumentMatchers .any ;
5
6
import static org .mockito .Mockito .verify ;
6
7
import static org .springframework .integration .test .mock .MockIntegration .messageArgumentCaptor ;
@@ -52,9 +53,8 @@ void testMqttFlow() throws InterruptedException {
52
53
53
54
mqttOutFlow .getInputChannel ().send (new GenericMessage <>("foo" ));
54
55
55
- assertThat (receiveLatch .await (10 , TimeUnit .SECONDS )). isTrue ( );
56
+ assertTrue (receiveLatch .await (10 , TimeUnit .SECONDS ));
56
57
verify (mockMessageHandler ).handleMessage (any ());
57
- assertThat (captor .getValue ().getPayload ())
58
- .isEqualTo ("foo sent to MQTT5, received from MQTT5" );
58
+ assertEquals ("foo sent to MQTT5, received from MQTT5" ,captor .getValue ().getPayload ());
59
59
}
60
60
}
You can’t perform that action at this time.
0 commit comments