fixed #201 优雅的关闭Broker功能调试通过

beiling · Aug 6, 2013 · 5776855 · 5776855
1 parent 5630bab
commit 5776855
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rocketmq-client/src/main/java/com/alibaba/rocketmq/client/impl/MQClientAPIImpl.java b/rocketmq-client/src/main/java/com/alibaba/rocketmq/client/impl/MQClientAPIImpl.java
@@ -1062,7 +1062,7 @@ public int wipeWritePermOfBroker(final String namesrvAddr, String brokerName, fi
         RemotingCommand request =
                 RemotingCommand.createRequestCommand(MQRequestCode.WIPE_WRITE_PERM_OF_BROKER_VALUE,
                     requestHeader);
-        RemotingCommand response = this.remotingClient.invokeSync(null, request, timeoutMillis);
+        RemotingCommand response = this.remotingClient.invokeSync(namesrvAddr, request, timeoutMillis);
         assert response != null;
         switch (response.getCode()) {
         case ResponseCode.SUCCESS_VALUE: {