README.md

Author: 胡贵

lts-core/src/main/java/com/lts/job/core/remoting/RemotingClientDelegate.java

@@ -121,6 +121,9 @@ public void invokeAsync(RemotingCommand request, InvokeCallback invokeCallback)
             remotingClient.invokeAsync(jobTracker.getAddress(), request,
                     application.getConfig().getInvokeTimeoutMillis(), invokeCallback);
             this.serverEnable = true;
+            // publish msg
+            EventInfo eventInfo = new EventInfo(EcTopic.NO_JOB_TRACKER_AVAILABLE);
+            application.getEventCenter().publishAsync(eventInfo);
 
         } catch (Throwable e) {
             // 将这个JobTracker移除
@@ -152,6 +155,9 @@ public void invokeOneway(RemotingCommand request)
             remotingClient.invokeOneway(jobTracker.getAddress(), request,
                     application.getConfig().getInvokeTimeoutMillis());
             this.serverEnable = true;
+            // publish msg
+            EventInfo eventInfo = new EventInfo(EcTopic.NO_JOB_TRACKER_AVAILABLE);
+            application.getEventCenter().publishAsync(eventInfo);
 
         } catch (Throwable e) {
             // 将这个JobTracker移除