From bfd1d48791cecc3040dab3a72fab2faabf3b4b83 Mon Sep 17 00:00:00 2001 From: Matteo Merli Date: Sat, 25 Feb 2017 18:59:08 -0800 Subject: [PATCH] Fixed compile error in ServerCnxTest after merge --- .../java/com/yahoo/pulsar/broker/service/ServerCnxTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/com/yahoo/pulsar/broker/service/ServerCnxTest.java b/pulsar-broker/src/test/java/com/yahoo/pulsar/broker/service/ServerCnxTest.java index 5a09ad1997c08..b7b433983f3c3 100644 --- a/pulsar-broker/src/test/java/com/yahoo/pulsar/broker/service/ServerCnxTest.java +++ b/pulsar-broker/src/test/java/com/yahoo/pulsar/broker/service/ServerCnxTest.java @@ -1077,7 +1077,8 @@ public void testUnsupportedBatchMsgSubscribeCommand() throws Exception { doReturn(false).when(brokerService).isAuthorizationEnabled(); // test SUBSCRIBE on topic and cursor creation success ByteBuf clientCommand = Commands.newSubscribe(successTopicName, // - successSubName, 1 /* consumer id */, 1 /* request id */, SubType.Exclusive, "test" /* consumer name */); + successSubName, 1 /* consumer id */, 1 /* request id */, SubType.Exclusive, 0 /* priority */, + "test" /* consumer name */); channel.writeInbound(clientCommand); assertTrue(getResponse() instanceof CommandSuccess); @@ -1085,7 +1086,7 @@ public void testUnsupportedBatchMsgSubscribeCommand() throws Exception { topicRef.markBatchMessagePublished(); // test SUBSCRIBE on topic and cursor creation success - clientCommand = Commands.newSubscribe(successTopicName, failSubName, 2, 2, SubType.Exclusive, + clientCommand = Commands.newSubscribe(successTopicName, failSubName, 2, 2, SubType.Exclusive, 0 /* priority */, "test" /* consumer name */); channel.writeInbound(clientCommand); Object response = getResponse();