From b558204c508f27eb47dfade6eed6ec2280877fda Mon Sep 17 00:00:00 2001
From: Acexy <acexy@thankjava.com>
Date: Mon, 10 Sep 2018 15:26:56 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8D=87=E7=BA=A7java-toolkit=20>=201.0.9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                       |  2 +-
 .../wqq/core/event/MsgPollEvent.java          |  2 +-
 .../wqq/core/request/aop/DoRequest.java       | 20 +++++++++----------
 3 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/pom.xml b/pom.xml
index c6d9733..9b1adb7 100644
--- a/pom.xml
+++ b/pom.xml
@@ -19,7 +19,7 @@
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
 
-		<fast-toolkit.version>1.0.6</fast-toolkit.version>
+		<fast-toolkit.version>1.0.9</fast-toolkit.version>
 		<httpasyncclient.version>4.1.3</httpasyncclient.version>
 		<fastjson.version>1.2.47</fastjson.version>
 		<org.slf4j.version>1.7.25</org.slf4j.version>
diff --git a/src/main/java/com/thankjava/wqq/core/event/MsgPollEvent.java b/src/main/java/com/thankjava/wqq/core/event/MsgPollEvent.java
index 8aadcc5..a348e06 100644
--- a/src/main/java/com/thankjava/wqq/core/event/MsgPollEvent.java
+++ b/src/main/java/com/thankjava/wqq/core/event/MsgPollEvent.java
@@ -88,7 +88,7 @@ private boolean doExceptionCheck(PullMsgStatus pullMsgStatus) {
             // 重置监控数据
             session.resetMonitoringData();
             try {
-                Method method = ReflectHelper.getMethod(loginAction, "beginLogin");
+                Method method = ReflectHelper.getMethod(LoginAction.class, "beginLogin");
                 int retryTimes = ConfigParams.AUTO_RE_LOGIN_RETRY_MAX_TIME;
                 while (retryTimes > 0) {
                     boolean flag = (boolean) ReflectHelper.invokeMethod(loginAction, method);
diff --git a/src/main/java/com/thankjava/wqq/core/request/aop/DoRequest.java b/src/main/java/com/thankjava/wqq/core/request/aop/DoRequest.java
index 554bbcc..d8e51e5 100644
--- a/src/main/java/com/thankjava/wqq/core/request/aop/DoRequest.java
+++ b/src/main/java/com/thankjava/wqq/core/request/aop/DoRequest.java
@@ -16,7 +16,7 @@
 public class DoRequest {
 
     private static final String proxyMethodName = "buildRequestParams";
-    
+
     private static Logger logger = LoggerFactory.getLogger(DoRequest.class);
 
     private static AsyncHttpClient asyncHttpClient = BaseHttpService.asyncHttpClient;
@@ -32,28 +32,28 @@ public AopParam doRequest(AopParam aopParam) {
         // 执行buildRequestParams 得到请求的参数体
         Object proxyInstance = aopParam.getProxyInstance();
 
-        Method method = ReflectHelper.getMethod(proxyInstance, proxyMethodName);
+        Method method = ReflectHelper.getMethod(proxyInstance.getClass(), proxyMethodName);
         AsyncRequest asyncRequest = (AsyncRequest) ReflectHelper.invokeMethod(proxyInstance, method);
-        
+
         if (listener != null) {
             // 如果传递了listener 则通过listener的方式回调返回
             try {
                 listener.onListener(new ActionListener((asyncHttpClient.syncRequestWithSession(asyncRequest))));
             } catch (Throwable e) {
-            	logger.error("http request error", e);
+                logger.error("http request error", e);
                 listener.onListener(new ActionListener());
             }
 
         } else {
 
-        	try {
+            try {
                 aopParam.setResult(asyncHttpClient.syncRequestWithSession(asyncRequest));
-        	}catch (Throwable e) {
-        		aopParam.setResult(null);
-        		logger.error("http request error", e);
-			}
+            } catch (Throwable e) {
+                aopParam.setResult(null);
+                logger.error("http request error", e);
+            }
         }
-        
+
         // 通过普通的方式返回结果
         return aopParam;
     }