Fixed compile error in ServerCnxTest after merge (#247)

apache · Feb 26, 2017 · 9fde15b · 9fde15b
1 parent cd2d16e
commit 9fde15b
Showing 1 changed file with 3 additions and 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
@@ -1077,15 +1077,16 @@ 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);
 
         PersistentTopic topicRef = (PersistentTopic) brokerService.getTopicReference(successTopicName);
         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();