未验证 提交 c983d850 编写于 作者: wu-sheng's avatar wu-sheng 提交者: GitHub

Fix miss change of envoy receiver. (#2844)

上级 2cdbe83f
...@@ -21,6 +21,7 @@ package org.apache.skywalking.oap.server.receiver.envoy; ...@@ -21,6 +21,7 @@ package org.apache.skywalking.oap.server.receiver.envoy;
import org.apache.skywalking.oap.server.core.CoreModule; import org.apache.skywalking.oap.server.core.CoreModule;
import org.apache.skywalking.oap.server.core.server.GRPCHandlerRegister; import org.apache.skywalking.oap.server.core.server.GRPCHandlerRegister;
import org.apache.skywalking.oap.server.library.module.*; import org.apache.skywalking.oap.server.library.module.*;
import org.apache.skywalking.oap.server.receiver.sharing.server.SharingServerModule;
import org.apache.skywalking.oap.server.telemetry.TelemetryModule; import org.apache.skywalking.oap.server.telemetry.TelemetryModule;
/** /**
...@@ -50,7 +51,7 @@ public class EnvoyMetricReceiverProvider extends ModuleProvider { ...@@ -50,7 +51,7 @@ public class EnvoyMetricReceiverProvider extends ModuleProvider {
} }
@Override public void start() throws ServiceNotProvidedException, ModuleStartException { @Override public void start() throws ServiceNotProvidedException, ModuleStartException {
GRPCHandlerRegister service = getManager().find(CoreModule.NAME).provider().getService(GRPCHandlerRegister.class); GRPCHandlerRegister service = getManager().find(SharingServerModule.NAME).provider().getService(GRPCHandlerRegister.class);
service.addHandler(new MetricServiceGRPCHandler(getManager())); service.addHandler(new MetricServiceGRPCHandler(getManager()));
service.addHandler(new AccessLogServiceGRPCHandler(getManager(), config)); service.addHandler(new AccessLogServiceGRPCHandler(getManager(), config));
} }
...@@ -60,6 +61,6 @@ public class EnvoyMetricReceiverProvider extends ModuleProvider { ...@@ -60,6 +61,6 @@ public class EnvoyMetricReceiverProvider extends ModuleProvider {
} }
@Override public String[] requiredModules() { @Override public String[] requiredModules() {
return new String[] {TelemetryModule.NAME, CoreModule.NAME}; return new String[] {TelemetryModule.NAME, CoreModule.NAME, SharingServerModule.NAME};
} }
} }
...@@ -52,6 +52,6 @@ public class IstioTelemetryReceiverProvider extends ModuleProvider { ...@@ -52,6 +52,6 @@ public class IstioTelemetryReceiverProvider extends ModuleProvider {
} }
@Override public String[] requiredModules() { @Override public String[] requiredModules() {
return new String[] {TelemetryModule.NAME, CoreModule.NAME, MeshReceiverModule.NAME}; return new String[] {TelemetryModule.NAME, CoreModule.NAME, MeshReceiverModule.NAME, SharingServerModule.NAME};
} }
} }
\ No newline at end of file
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册