From b6e4be83c7a4bddb56eedadd01e0a344ea429ff1 Mon Sep 17 00:00:00 2001
From: qqeasonchen <qqeasonchen@gmail.com>
Date: Wed, 16 Oct 2019 21:22:09 +0800
Subject: [PATCH] fix unit test

---
 .../rocketmq/client/producer/DefaultMQProducerTest.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java b/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java
index 991a5725..38117535 100644
--- a/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java
+++ b/client/src/test/java/org/apache/rocketmq/client/producer/DefaultMQProducerTest.java
@@ -398,13 +398,13 @@ public class DefaultMQProducerTest {
 
         try {
             producer.request(message, requestCallback, 3 * 1000L);
-            failBecauseExceptionWasNotThrown(RemotingSendRequestException.class);
-        } catch (RemotingSendRequestException e) {
+            failBecauseExceptionWasNotThrown(Exception.class);
+        } catch (Exception e) {
             ConcurrentHashMap<String, RequestResponseFuture> responseMap = RequestFutureTable.getRequestFutureTable();
             assertThat(responseMap).isNotNull();
             for (Map.Entry<String, RequestResponseFuture> entry : responseMap.entrySet()) {
                 RequestResponseFuture future = entry.getValue();
-                future.getRequestCallback().onException(new Throwable());
+                future.getRequestCallback().onException(e);
             }
         }
         countDownLatch.await(3000L, TimeUnit.MILLISECONDS);
-- 
GitLab