From e77abe23a61d6c0a0850b9184c03b3aedaa1ba56 Mon Sep 17 00:00:00 2001 From: pengys5 <8082209@qq.com> Date: Wed, 26 Apr 2017 12:08:49 +0800 Subject: [PATCH] no message --- .../worker/globaltrace/GlobalTraceSearchTestCase.java | 2 +- .../collector/worker/httpserver/TestAbstractGetProvider.java | 4 ++-- .../collector/worker/httpserver/TestAbstractPostProvider.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/globaltrace/GlobalTraceSearchTestCase.java b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/globaltrace/GlobalTraceSearchTestCase.java index f6619f33b..e8c243221 100644 --- a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/globaltrace/GlobalTraceSearchTestCase.java +++ b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/globaltrace/GlobalTraceSearchTestCase.java @@ -40,7 +40,7 @@ public class GlobalTraceSearchTestCase { String segment_Data = JsonFileReader.INSTANCE.read(this.getClass().getResource("/").getPath() + "/json/globaltrace/persistence/globaltrace_segment.json"); mockSegment(getResponseFromEs, SegmentIndex.INDEX, SegmentIndex.TYPE_RECORD, segment_1, segment_Data); - GlobalTraceSearchWithGlobalId search = new GlobalTraceSearchWithGlobalId(null, null, null); + GlobalTraceSearchWithGlobalId search = new GlobalTraceSearchWithGlobalId(GlobalTraceSearchWithGlobalId.WorkerRole.INSTANCE, null, null); JsonObject responseObj = new JsonObject(); // search.allocateJob(globalTraceId, responseObj); diff --git a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/httpserver/TestAbstractGetProvider.java b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/httpserver/TestAbstractGetProvider.java index 82ddc918c..16e49e0c7 100644 --- a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/httpserver/TestAbstractGetProvider.java +++ b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/httpserver/TestAbstractGetProvider.java @@ -15,11 +15,11 @@ public class TestAbstractGetProvider extends AbstractGetProvider { @Override public Role role() { - return null; + return TestAbstractGet.WorkerRole.INSTANCE; } @Override public AbstractWorker workerInstance(ClusterWorkerContext clusterContext) { - return new TestAbstractGet(null, null, null); + return new TestAbstractGet(role(), null, null); } } diff --git a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/httpserver/TestAbstractPostProvider.java b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/httpserver/TestAbstractPostProvider.java index 086f65188..e8c01916f 100644 --- a/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/httpserver/TestAbstractPostProvider.java +++ b/skywalking-collector/skywalking-collector-worker/src/test/java/com/a/eye/skywalking/collector/worker/httpserver/TestAbstractPostProvider.java @@ -25,6 +25,6 @@ public class TestAbstractPostProvider extends AbstractPostProvider { @Override public AbstractWorker workerInstance(ClusterWorkerContext clusterContext) { - return new TestAbstractPost(null, null, null); + return new TestAbstractPost(TestAbstractPost.WorkerRole.INSTANCE, null, null); } }