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 1e9f1bff32c061f1d4ba9e552deedd0c21723441..b3e14a7fa40c66d2b0d95fbc83fe88800dc34116 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 d87bc4512c560b785c94aa3098cf87a0810a5f4f..fc9a2a9485f904e25222f5d820c826c537ebc1c3 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 d6c4296008af2fd3930c1075691272b92fe27813..7c57678676b183cd50026a45fcece61736f3a22b 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; + } + }