Invoke metrics with jmx in NettyRPC by tangjie

maodundexiaowen · Oct 13, 2017 · 76471fe · 76471fe
1 parent b46a90f
commit 76471fe
Show file tree

Hide file tree

Showing 6 changed files with 9 additions and 9 deletions.
diff --git a/docs/ojdbc6.jar b/docs/ojdbc6.jar
diff --git a/src/main/java/com/newlandframework/rpc/event/AbstractInvokeEventBus.java b/src/main/java/com/newlandframework/rpc/event/AbstractInvokeEventBus.java
@@ -53,7 +53,7 @@ public AbstractInvokeEventBus(String moduleName, String methodName) {
 
     public abstract Notification buildNotification(Object oldValue, Object newValue);
 
-    public void nofity(Object oldValue, Object newValue) {
+    public void notify(Object oldValue, Object newValue) {
         Notification notification = buildNotification(oldValue, newValue);
         handler.sendNotification(notification);
     }

diff --git a/src/main/java/com/newlandframework/rpc/event/InvokeFailObserver.java b/src/main/java/com/newlandframework/rpc/event/InvokeFailObserver.java
@@ -45,8 +45,8 @@ public void setError(Throwable error) {
     @Override
     public void update(Observable o, Object arg) {
         if ((AbstractInvokeEventBus.ModuleEvent) arg == AbstractInvokeEventBus.ModuleEvent.INVOKE_FAIL_EVENT) {
-            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_FAIL_EVENT).nofity(super.getVisitor().getInvokeFailCount(), super.getVisitor().incrementInvokeFailCount());
-            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_FAIL_STACKTRACE_EVENT).nofity(null, error);
+            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_FAIL_EVENT).notify(super.getVisitor().getInvokeFailCount(), super.getVisitor().incrementInvokeFailCount());
+            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_FAIL_STACKTRACE_EVENT).notify(null, error);
         }
     }
 }
diff --git a/src/main/java/com/newlandframework/rpc/event/InvokeFilterObserver.java b/src/main/java/com/newlandframework/rpc/event/InvokeFilterObserver.java
@@ -35,7 +35,7 @@ public InvokeFilterObserver(InvokeEventBusFacade facade, ModuleMetricsVisitor vi
     @Override
     public void update(Observable o, Object arg) {
         if ((AbstractInvokeEventBus.ModuleEvent) arg == AbstractInvokeEventBus.ModuleEvent.INVOKE_FILTER_EVENT) {
-            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_FILTER_EVENT).nofity(super.getVisitor().getInvokeFilterCount(), super.getVisitor().incrementInvokeFilterCount());
+            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_FILTER_EVENT).notify(super.getVisitor().getInvokeFilterCount(), super.getVisitor().incrementInvokeFilterCount());
         }
     }
 }
diff --git a/src/main/java/com/newlandframework/rpc/event/InvokeObserver.java b/src/main/java/com/newlandframework/rpc/event/InvokeObserver.java
@@ -35,7 +35,7 @@ public InvokeObserver(InvokeEventBusFacade facade, ModuleMetricsVisitor visitor)
     @Override
     public void update(Observable o, Object arg) {
         if ((AbstractInvokeEventBus.ModuleEvent) arg == AbstractInvokeEventBus.ModuleEvent.INVOKE_EVENT) {
-            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_EVENT).nofity(super.getVisitor().getInvokeCount(), super.getVisitor().incrementInvokeCount());
+            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_EVENT).notify(super.getVisitor().getInvokeCount(), super.getVisitor().incrementInvokeCount());
         }
     }
 }

diff --git a/src/main/java/com/newlandframework/rpc/event/InvokeSuccObserver.java b/src/main/java/com/newlandframework/rpc/event/InvokeSuccObserver.java
@@ -45,10 +45,10 @@ public void setInvokeTimespan(long invokeTimespan) {
     @Override
     public void update(Observable o, Object arg) {
         if ((AbstractInvokeEventBus.ModuleEvent) arg == AbstractInvokeEventBus.ModuleEvent.INVOKE_SUCC_EVENT) {
-            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_SUCC_EVENT).nofity(super.getVisitor().getInvokeSuccCount(), super.getVisitor().incrementInvokeSuccCount());
-            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_TIMESPAN_EVENT).nofity(super.getVisitor().getInvokeTimespan(), invokeTimespan);
-            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_MAX_TIMESPAN_EVENT).nofity(super.getVisitor().getInvokeMaxTimespan(), invokeTimespan);
-            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_MIN_TIMESPAN_EVENT).nofity(super.getVisitor().getInvokeMinTimespan(), invokeTimespan);
+            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_SUCC_EVENT).notify(super.getVisitor().getInvokeSuccCount(), super.getVisitor().incrementInvokeSuccCount());
+            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_TIMESPAN_EVENT).notify(super.getVisitor().getInvokeTimespan(), invokeTimespan);
+            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_MAX_TIMESPAN_EVENT).notify(super.getVisitor().getInvokeMaxTimespan(), invokeTimespan);
+            super.getFacade().fetchEvent(AbstractInvokeEventBus.ModuleEvent.INVOKE_MIN_TIMESPAN_EVENT).notify(super.getVisitor().getInvokeMinTimespan(), invokeTimespan);
         }
     }
 }