File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
src/test/java/com/rabbitmq/stream/impl Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 13
13
14
14
package com .rabbitmq .stream .impl ;
15
15
16
+ import static com .rabbitmq .stream .impl .TestUtils .ResponseConditions .ko ;
17
+ import static com .rabbitmq .stream .impl .TestUtils .ResponseConditions .responseCode ;
16
18
import static com .rabbitmq .stream .impl .TestUtils .b ;
17
19
import static com .rabbitmq .stream .impl .TestUtils .forEach ;
18
20
import static com .rabbitmq .stream .impl .TestUtils .latchAssert ;
@@ -106,8 +108,7 @@ void trackAndQuery(
106
108
@ Test
107
109
void shouldReturnNoOffsetIfNothingStoredForReference () {
108
110
QueryOffsetResponse response = cf .get ().queryOffset (UUID .randomUUID ().toString (), stream );
109
- assertThat (response .isOk ()).isFalse ();
110
- assertThat (response .getResponseCode ()).isEqualTo (Constants .RESPONSE_CODE_NO_OFFSET );
111
+ assertThat (response ).is (ko ()).has (responseCode (Constants .RESPONSE_CODE_NO_OFFSET ));
111
112
assertThat (response .getOffset ()).isEqualTo (0 );
112
113
}
113
114
You can’t perform that action at this time.
0 commit comments