提交 b9404f6a 编写于 作者: P pengys5

Throw UnexpectedException when invoke deserialize or serialize method in...

Throw UnexpectedException when invoke deserialize or serialize method in GC,CPU,MEMORY,MEMORY POOL data define.
上级 5012a9bc
package org.skywalking.apm.collector.agentjvm.worker.cpu.define;
import org.skywalking.apm.collector.core.framework.UnexpectedException;
import org.skywalking.apm.collector.remote.grpc.proto.RemoteData;
import org.skywalking.apm.collector.stream.worker.impl.data.Attribute;
import org.skywalking.apm.collector.stream.worker.impl.data.AttributeType;
......@@ -26,11 +27,11 @@ public class CpuMetricDataDefine extends DataDefine {
}
@Override public Object deserialize(RemoteData remoteData) {
return null;
throw new UnexpectedException("cpu metric data did not need send to remote worker.");
}
@Override public RemoteData serialize(Object object) {
return null;
throw new UnexpectedException("cpu metric data did not need send to remote worker.");
}
public static class CpuMetric implements Transform<CpuMetric> {
......
package org.skywalking.apm.collector.agentjvm.worker.gc.define;
import org.skywalking.apm.collector.core.framework.UnexpectedException;
import org.skywalking.apm.collector.remote.grpc.proto.RemoteData;
import org.skywalking.apm.collector.stream.worker.impl.data.Attribute;
import org.skywalking.apm.collector.stream.worker.impl.data.AttributeType;
......@@ -28,11 +29,11 @@ public class GCMetricDataDefine extends DataDefine {
}
@Override public Object deserialize(RemoteData remoteData) {
return null;
throw new UnexpectedException("gc metric data did not need send to remote worker.");
}
@Override public RemoteData serialize(Object object) {
return null;
throw new UnexpectedException("gc metric data did not need send to remote worker.");
}
public static class GCMetric implements Transform<GCMetric> {
......
package org.skywalking.apm.collector.agentjvm.worker.memory.define;
import org.skywalking.apm.collector.core.framework.UnexpectedException;
import org.skywalking.apm.collector.remote.grpc.proto.RemoteData;
import org.skywalking.apm.collector.stream.worker.impl.data.Attribute;
import org.skywalking.apm.collector.stream.worker.impl.data.AttributeType;
......@@ -30,11 +31,11 @@ public class MemoryMetricDataDefine extends DataDefine {
}
@Override public Object deserialize(RemoteData remoteData) {
return null;
throw new UnexpectedException("memory metric data did not need send to remote worker.");
}
@Override public RemoteData serialize(Object object) {
return null;
throw new UnexpectedException("memory metric data did not need send to remote worker.");
}
public static class MemoryMetric implements Transform<MemoryMetric> {
......
package org.skywalking.apm.collector.agentjvm.worker.memorypool.define;
import org.skywalking.apm.collector.core.framework.UnexpectedException;
import org.skywalking.apm.collector.remote.grpc.proto.RemoteData;
import org.skywalking.apm.collector.stream.worker.impl.data.Attribute;
import org.skywalking.apm.collector.stream.worker.impl.data.AttributeType;
......@@ -31,11 +32,11 @@ public class MemoryPoolMetricDataDefine extends DataDefine {
}
@Override public Object deserialize(RemoteData remoteData) {
return null;
throw new UnexpectedException("memory pool metric data did not need send to remote worker.");
}
@Override public RemoteData serialize(Object object) {
return null;
throw new UnexpectedException("memory pool metric data did not need send to remote worker.");
}
public static class MemoryPoolMetric implements Transform<MemoryPoolMetric> {
......
package org.skywalking.apm.collector.core.framework;
/**
* @author pengys5
*/
public class UnexpectedException extends RuntimeException {
public UnexpectedException(String message) {
super(message);
}
}
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册