[incubator-skywalking] branch prometheus updated: Fix a test case.

[wu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch prometheus
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git


The following commit(s) were added to refs/heads/prometheus by this push:
     new 1155c17  Fix a test case.
1155c17 is described below

commit 1155c170437bdbf7355fbae1692ac6efea216fcc
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Tue Jan 8 09:57:05 2019 +0800

    Fix a test case.
---
 .../remote/client/RemoteClientManagerTestCase.java | 28 ++++++++++++++++++++++
 1 file changed, 28 insertions(+)

diff --git a/oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/remote/client/RemoteClientManagerTestCase.java b/oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/remote/client/RemoteClientManagerTestCase.java
index 54b6cb7..4b6317b 100644
--- a/oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/remote/client/RemoteClientManagerTestCase.java
+++ b/oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/remote/client/RemoteClientManagerTestCase.java
@@ -22,6 +22,8 @@ import java.util.*;
 import org.apache.skywalking.oap.server.core.CoreModule;
 import org.apache.skywalking.oap.server.core.cluster.*;
 import org.apache.skywalking.oap.server.core.remote.annotation.StreamDataClassGetter;
+import org.apache.skywalking.oap.server.telemetry.TelemetryModule;
+import org.apache.skywalking.oap.server.telemetry.api.*;
 import org.apache.skywalking.oap.server.testing.module.*;
 import org.junit.*;
 
@@ -47,6 +49,32 @@ public class RemoteClientManagerTestCase {
         StreamDataClassGetter streamDataClassGetter = mock(StreamDataClassGetter.class);
         coreModuleDefine.provider().registerServiceImplementation(StreamDataClassGetter.class, streamDataClassGetter);
 
+        MetricCreator metricCreator = mock(MetricCreator.class);
+        when(metricCreator.createGauge(any(), any(), any(), any())).thenReturn(new GaugeMetric() {
+            @Override public void inc() {
+
+            }
+
+            @Override public void inc(double value) {
+
+            }
+
+            @Override public void dec() {
+
+            }
+
+            @Override public void dec(double value) {
+
+            }
+
+            @Override public void setValue(double value) {
+
+            }
+        });
+        ModuleDefineTesting telemetryModuleDefine = new ModuleDefineTesting();
+        moduleManager.put(TelemetryModule.NAME, telemetryModuleDefine);
+        telemetryModuleDefine.provider().registerServiceImplementation(MetricCreator.class, metricCreator);
+
         RemoteClientManager clientManager = new RemoteClientManager(moduleManager);
 
         when(clusterNodesQuery.queryRemoteNodes()).thenReturn(groupOneInstances());