@@ -82,77 +82,77 @@ public void after() {
8282 SofaTracerConfiguration .setProperty (SofaTracerConfiguration .STAT_LOG_INTERVAL , "" );
8383 }
8484
85- // @Test
86- // public void testTracer() throws Exception {
87- // RegistryConfig registryConfig = new RegistryConfig();
88- // ApplicationConfig config = new ApplicationConfig();
89- // config.setName("test-server");
90- // registryConfig.setAddress("N/A");
91- // //The service caller connects to the registry and sets the properties.
92- // ReferenceConfig<DubboService> reference = new ReferenceConfig<>();
93- // reference.setInterface(DubboService.class);
94- // reference.setRegistry(registryConfig);
95- // reference.setUrl(address);
96- // reference.setVersion("1.0");
97- // reference.setGroup("tracer");
98- // reference.setFilter("dubboSofaTracerFilter");
99- // reference.setApplication(config);
100- // reference.setAsync(true);
101- // DubboService service = reference.get();
102- // Assert.assertEquals(service.echoStr("sofa-tarcer"), null);
103- // Object o = RpcContext.getContext().getFuture().get();
104- // Assert.assertTrue(o.toString().equalsIgnoreCase("sofa-tarcer"));
105- //
106- // Thread.sleep(500);
107- // //wait for async output
108- // List<String> serverContent = FileUtils.readLines(new File(
109- // logDirectoryPath + File.separator
110- // + DubboLogEnum.DUBBO_SERVER_DIGEST.getDefaultLogName()));
111- // Assert.assertTrue(serverContent.size() == 1);
112- // String jsonData = serverContent.get(0);
113- // JSONObject json = JSON.parseObject(jsonData);
114- // Assert.assertEquals(json.getString(CommonSpanTags.SERVICE),
115- // "com.alipay.sofa.tracer.plugins.dubbo.service.DubboService");
116- // Assert.assertEquals(json.getString(CommonSpanTags.LOCAL_APP), "test-server");
117- // Assert.assertEquals(json.getString("spanId"), "0");
118- // Assert.assertEquals(json.getString(CommonSpanTags.METHOD), "echoStr");
119- // Assert.assertEquals(json.getString(CommonSpanTags.PROTOCOL), "dubbo");
120- // Assert.assertEquals(json.getString("span.kind"), "server");
121- //
122- // //wait for async output
123- // List<String> clientContents = FileUtils.readLines(new File(
124- // logDirectoryPath + File.separator
125- // + DubboLogEnum.DUBBO_CLIENT_DIGEST.getDefaultLogName()));
126- //
127- // Assert.assertTrue(clientContents.size() == 1);
128- // String clientData = clientContents.get(0);
129- // JSONObject clientJson = JSON.parseObject(clientData);
130- //
131- // Assert.assertEquals(clientJson.getString(CommonSpanTags.SERVICE),
132- // "com.alipay.sofa.tracer.plugins.dubbo.service.DubboService");
133- // Assert.assertEquals(clientJson.getString(CommonSpanTags.LOCAL_APP), "test-server");
134- // Assert.assertEquals(clientJson.getString("spanId"), "0");
135- // Assert.assertEquals(clientJson.getString(CommonSpanTags.METHOD), "echoStr");
136- // Assert.assertEquals(clientJson.getString(CommonSpanTags.PROTOCOL), "dubbo");
137- // Assert.assertEquals(clientJson.getString("span.kind"), "client");
138- //
139- // Thread.sleep(500);
140- //
141- // //wait for async output
142- // List<String> clientStatContents = FileUtils
143- // .readLines(new File(logDirectoryPath + File.separator
144- // + DubboLogEnum.DUBBO_CLIENT_STAT.getDefaultLogName()));
145- //
146- // Assert.assertTrue(clientStatContents.size() == 1);
147- //
148- // //wait for async output
149- // List<String> serverStatContents = FileUtils
150- // .readLines(new File(logDirectoryPath + File.separator
151- // + DubboLogEnum.DUBBO_SERVER_STAT.getDefaultLogName()));
152- //
153- // Assert.assertTrue(serverStatContents.size() == 1);
154- //
155- // }
85+ // @Test
86+ // public void testTracer() throws Exception {
87+ // RegistryConfig registryConfig = new RegistryConfig();
88+ // ApplicationConfig config = new ApplicationConfig();
89+ // config.setName("test-server");
90+ // registryConfig.setAddress("N/A");
91+ // //The service caller connects to the registry and sets the properties.
92+ // ReferenceConfig<DubboService> reference = new ReferenceConfig<>();
93+ // reference.setInterface(DubboService.class);
94+ // reference.setRegistry(registryConfig);
95+ // reference.setUrl(address);
96+ // reference.setVersion("1.0");
97+ // reference.setGroup("tracer");
98+ // reference.setFilter("dubboSofaTracerFilter");
99+ // reference.setApplication(config);
100+ // reference.setAsync(true);
101+ // DubboService service = reference.get();
102+ // Assert.assertEquals(service.echoStr("sofa-tarcer"), null);
103+ // Object o = RpcContext.getContext().getFuture().get();
104+ // Assert.assertTrue(o.toString().equalsIgnoreCase("sofa-tarcer"));
105+ //
106+ // Thread.sleep(500);
107+ // //wait for async output
108+ // List<String> serverContent = FileUtils.readLines(new File(
109+ // logDirectoryPath + File.separator
110+ // + DubboLogEnum.DUBBO_SERVER_DIGEST.getDefaultLogName()));
111+ // Assert.assertTrue(serverContent.size() == 1);
112+ // String jsonData = serverContent.get(0);
113+ // JSONObject json = JSON.parseObject(jsonData);
114+ // Assert.assertEquals(json.getString(CommonSpanTags.SERVICE),
115+ // "com.alipay.sofa.tracer.plugins.dubbo.service.DubboService");
116+ // Assert.assertEquals(json.getString(CommonSpanTags.LOCAL_APP), "test-server");
117+ // Assert.assertEquals(json.getString("spanId"), "0");
118+ // Assert.assertEquals(json.getString(CommonSpanTags.METHOD), "echoStr");
119+ // Assert.assertEquals(json.getString(CommonSpanTags.PROTOCOL), "dubbo");
120+ // Assert.assertEquals(json.getString("span.kind"), "server");
121+ //
122+ // //wait for async output
123+ // List<String> clientContents = FileUtils.readLines(new File(
124+ // logDirectoryPath + File.separator
125+ // + DubboLogEnum.DUBBO_CLIENT_DIGEST.getDefaultLogName()));
126+ //
127+ // Assert.assertTrue(clientContents.size() == 1);
128+ // String clientData = clientContents.get(0);
129+ // JSONObject clientJson = JSON.parseObject(clientData);
130+ //
131+ // Assert.assertEquals(clientJson.getString(CommonSpanTags.SERVICE),
132+ // "com.alipay.sofa.tracer.plugins.dubbo.service.DubboService");
133+ // Assert.assertEquals(clientJson.getString(CommonSpanTags.LOCAL_APP), "test-server");
134+ // Assert.assertEquals(clientJson.getString("spanId"), "0");
135+ // Assert.assertEquals(clientJson.getString(CommonSpanTags.METHOD), "echoStr");
136+ // Assert.assertEquals(clientJson.getString(CommonSpanTags.PROTOCOL), "dubbo");
137+ // Assert.assertEquals(clientJson.getString("span.kind"), "client");
138+ //
139+ // Thread.sleep(500);
140+ //
141+ // //wait for async output
142+ // List<String> clientStatContents = FileUtils
143+ // .readLines(new File(logDirectoryPath + File.separator
144+ // + DubboLogEnum.DUBBO_CLIENT_STAT.getDefaultLogName()));
145+ //
146+ // Assert.assertTrue(clientStatContents.size() == 1);
147+ //
148+ // //wait for async output
149+ // List<String> serverStatContents = FileUtils
150+ // .readLines(new File(logDirectoryPath + File.separator
151+ // + DubboLogEnum.DUBBO_SERVER_STAT.getDefaultLogName()));
152+ //
153+ // Assert.assertTrue(serverStatContents.size() == 1);
154+ //
155+ // }
156156
157157 private void cleanFile () {
158158 DubboLogEnum [] dubboLogEnums = DubboLogEnum .values ();
0 commit comments