提交 3adbca97 编写于 作者: H huzongtang

[ISSUE #1156]fix failure test cases for acl mqadmin command;

上级 18601ec8
...@@ -268,7 +268,12 @@ public class MQClientAPIImplTest { ...@@ -268,7 +268,12 @@ public class MQClientAPIImplTest {
} }
}).when(remotingClient).invokeSync(anyString(), any(RemotingCommand.class), anyLong()); }).when(remotingClient).invokeSync(anyString(), any(RemotingCommand.class), anyLong());
String accessKey = "1234567";
try {
mqClientAPI.deleteAccessConfig(brokerAddr, accessKey, 3 * 1000);
} catch (MQClientException ex) {
}
} }
@Test @Test
......
...@@ -200,9 +200,6 @@ public class DefaultMQConsumerWithTraceTest { ...@@ -200,9 +200,6 @@ public class DefaultMQConsumerWithTraceTest {
@Test @Test
public void testPullMessage_WithTrace_Success() throws InterruptedException, RemotingException, MQBrokerException, MQClientException { public void testPullMessage_WithTrace_Success() throws InterruptedException, RemotingException, MQBrokerException, MQClientException {
traceProducer.getDefaultMQProducerImpl().getmQClientFactory().registerProducer(producerGroupTraceTemp, traceProducer.getDefaultMQProducerImpl()); traceProducer.getDefaultMQProducerImpl().getmQClientFactory().registerProducer(producerGroupTraceTemp, traceProducer.getDefaultMQProducerImpl());
//when(mQClientAPIImpl.getTopicRouteInfoFromNameServer(anyString(), anyLong())).thenReturn(createTopicRoute());
//when(mQClientTraceAPIImpl.getTopicRouteInfoFromNameServer(anyString(), anyLong())).thenReturn(createTraceTopicRoute());
final CountDownLatch countDownLatch = new CountDownLatch(1); final CountDownLatch countDownLatch = new CountDownLatch(1);
final MessageExt[] messageExts = new MessageExt[1]; final MessageExt[] messageExts = new MessageExt[1];
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册