diff --git a/zenoh-java/src/jvmTest/java/io/zenoh/QueryableTest.java b/zenoh-java/src/jvmTest/java/io/zenoh/QueryableTest.java index 8a2da00..ee3a401 100644 --- a/zenoh-java/src/jvmTest/java/io/zenoh/QueryableTest.java +++ b/zenoh-java/src/jvmTest/java/io/zenoh/QueryableTest.java @@ -137,8 +137,6 @@ public void queryReplySuccessTest() throws ZError, InterruptedException { Queryable queryable = session.declareQueryable(testKeyExpr, query -> { var options = new ReplyOptions(); options.setTimeStamp(timestamp); - options.setPriority(Priority.DATA_HIGH); - options.setCongestionControl(CongestionControl.DROP); options.setExpress(true); try { query.reply(testKeyExpr, message, options); @@ -158,9 +156,9 @@ public void queryReplySuccessTest() throws ZError, InterruptedException { var sample = ((Reply.Success) receivedReply[0]).getSample(); assertEquals(message, sample.getPayload()); assertEquals(timestamp, sample.getTimestamp()); - assertEquals(Priority.DATA_HIGH, sample.getPriority()); + assertEquals(Priority.DATA, sample.getPriority()); assertTrue(sample.getQos().getExpress()); - assertEquals(CongestionControl.DROP, sample.getCongestionControl()); + assertEquals(CongestionControl.BLOCK, sample.getCongestionControl()); } @Test