This is an automated email from the ASF dual-hosted git repository. aaronai pushed a commit to branch pr in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 795c53e7e0927b3b97c688659a08245c800807e2 Author: Aaron Ai <[email protected]> AuthorDate: Thu Aug 4 10:27:35 2022 +0800 Remove redundant test --- .../java/impl/producer/ProducerImplTest.java | 25 ---------------------- 1 file changed, 25 deletions(-) diff --git a/java/client/src/test/java/org/apache/rocketmq/client/java/impl/producer/ProducerImplTest.java b/java/client/src/test/java/org/apache/rocketmq/client/java/impl/producer/ProducerImplTest.java index 8b4985c..6822fa9 100644 --- a/java/client/src/test/java/org/apache/rocketmq/client/java/impl/producer/ProducerImplTest.java +++ b/java/client/src/test/java/org/apache/rocketmq/client/java/impl/producer/ProducerImplTest.java @@ -129,12 +129,6 @@ public class ProducerImplTest extends TestBase { producer.stopAsync().awaitTerminated(); } - @Test(expected = IllegalStateException.class) - public void testSendWithoutStart() throws ClientException { - final Message message = fakeMessage(FAKE_TOPIC_0); - producer.send(message); - } - @Test @Ignore public void testSendWithTopicBinding() throws ClientException, ExecutionException, InterruptedException { @@ -180,23 +174,4 @@ public class ProducerImplTest extends TestBase { assertEquals(receipt.getMessageId(), sendReceipt.getMessageId().toString()); shutdown(producerWithoutTopicBinding); } - - @Test(expected = ClientException.class) - @Ignore - public void testSendMessageWithFailure() throws ClientException { - start(producer); - verify(clientManager, times(1)).queryRoute(any(Endpoints.class), any(Metadata.class), - any(QueryRouteRequest.class), any(Duration.class)); - verify(clientManager, times(1)).telemetry(any(Endpoints.class), any(Metadata.class), any(Duration.class), - any(ClientSessionImpl.class)); - final ListenableFuture<RpcInvocation<SendMessageResponse>> future = failureSendMessageResponseFuture(); - when(clientManager.sendMessage(any(Endpoints.class), any(Metadata.class), any(SendMessageRequest.class), - any(Duration.class))).thenReturn(future); - Message message0 = fakeMessage(FAKE_TOPIC_0); - try { - producer.send(message0); - } finally { - shutdown(producer); - } - } } \ No newline at end of file
