From 33e583b7dd043030fad9ef3bcf9d6745ef4b7a64 Mon Sep 17 00:00:00 2001
From: xujingfeng <jingfeng.xjf@alibaba-inc.com>
Date: Wed, 22 May 2019 17:03:41 +0800
Subject: [PATCH] add onResponse note for async invocation

---
 .../main/java/com/aliware/tianchi/TestClientFilter.java    | 5 +++++
 .../main/java/com/aliware/tianchi/CallbackServiceImpl.java | 7 +++----
 .../main/java/com/aliware/tianchi/TestServerFilter.java    | 6 ++++++
 3 files changed, 14 insertions(+), 4 deletions(-)

diff --git a/workspace-gateway/src/main/java/com/aliware/tianchi/TestClientFilter.java b/workspace-gateway/src/main/java/com/aliware/tianchi/TestClientFilter.java
index 1e9f1bf..b3e14a7 100644
--- a/workspace-gateway/src/main/java/com/aliware/tianchi/TestClientFilter.java
+++ b/workspace-gateway/src/main/java/com/aliware/tianchi/TestClientFilter.java
@@ -27,4 +27,9 @@ public class TestClientFilter implements Filter {
         }
 
     }
+
+    @Override
+    public Result onResponse(Result result, Invoker<?> invoker, Invocation invocation) {
+        return result;
+    }
 }
diff --git a/workspace-provider/src/main/java/com/aliware/tianchi/CallbackServiceImpl.java b/workspace-provider/src/main/java/com/aliware/tianchi/CallbackServiceImpl.java
index d87bc45..fc9a2a9 100644
--- a/workspace-provider/src/main/java/com/aliware/tianchi/CallbackServiceImpl.java
+++ b/workspace-provider/src/main/java/com/aliware/tianchi/CallbackServiceImpl.java
@@ -11,11 +11,10 @@ import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * @author daofeng.xjf
- *
+ * <p>
  * 服务端回调服务
  * 可选接口
  * 用户可以基于此服务，实现服务端向客户端动态推送的功能
- *
  */
 public class CallbackServiceImpl implements CallbackService {
 
@@ -26,14 +25,14 @@ public class CallbackServiceImpl implements CallbackService {
                 if (!listeners.isEmpty()) {
                     for (Map.Entry<String, CallbackListener> entry : listeners.entrySet()) {
                         try {
-                            entry.getValue().receiveServerMsg(new Date().toString());
+                            entry.getValue().receiveServerMsg(System.getProperty("quota") + " " + new Date().toString());
                         } catch (Throwable t1) {
                             listeners.remove(entry.getKey());
                         }
                     }
                 }
             }
-        }, 5000, 5000);
+        }, 0, 5000);
     }
 
     private Timer timer = new Timer();
diff --git a/workspace-provider/src/main/java/com/aliware/tianchi/TestServerFilter.java b/workspace-provider/src/main/java/com/aliware/tianchi/TestServerFilter.java
index d6c4296..7c57678 100644
--- a/workspace-provider/src/main/java/com/aliware/tianchi/TestServerFilter.java
+++ b/workspace-provider/src/main/java/com/aliware/tianchi/TestServerFilter.java
@@ -27,4 +27,10 @@ public class TestServerFilter implements Filter {
         }
 
     }
+
+    @Override
+    public Result onResponse(Result result, Invoker<?> invoker, Invocation invocation) {
+        return result;
+    }
+
 }
-- 
GitLab