14
14
* See the License for the specific language governing permissions and
15
15
* limitations under the License.
16
16
*/
17
- package com .alipay .sofa .rpc .event ;
17
+ package com .alipay .sofa .rpc .tracer . sofatracer ;
18
18
19
19
import com .alipay .common .tracer .core .holder .SofaTraceContextHolder ;
20
20
import com .alipay .common .tracer .core .span .SofaTracerSpan ;
21
21
import com .alipay .sofa .rpc .common .RemotingConstants ;
22
- import com .alipay .sofa .rpc .common .RpcOptions ;
23
22
import com .alipay .sofa .rpc .context .RpcInternalContext ;
24
23
import com .alipay .sofa .rpc .core .request .SofaRequest ;
24
+ import com .alipay .sofa .rpc .event .ClientBeforeSendEvent ;
25
+ import com .alipay .sofa .rpc .event .ClientStartInvokeEvent ;
26
+ import com .alipay .sofa .rpc .event .EventBus ;
27
+ import com .alipay .sofa .rpc .event .ServerReceiveEvent ;
25
28
import com .alipay .sofa .rpc .tracer .sofatracer .log .tags .RpcSpanTags ;
26
29
import io .opentracing .tag .Tags ;
27
- import org .junit .AfterClass ;
28
30
import org .junit .Assert ;
29
- import org .junit .BeforeClass ;
30
31
import org .junit .Test ;
31
32
32
33
import java .util .Map ;
41
42
*/
42
43
public class SofaTracerSubscriberTest {
43
44
44
- @ BeforeClass
45
- public static void beforeClass () {
46
- System .getProperties ().put (RpcOptions .DEFAULT_TRACER , "sofaTracer" );
47
- }
48
-
49
45
@ Test
50
46
public void testClientSendAndServerReceiveTracerEvent () {
51
47
SofaRequest sofaRequest = new SofaRequest ();
@@ -85,9 +81,4 @@ public void testClientSendAndServerReceiveTracerEvent() {
85
81
SofaTraceContextHolder .getSofaTraceContext ().clear ();
86
82
}
87
83
88
- @ AfterClass
89
- public static void afterClass () {
90
- System .getProperties ().remove (RpcOptions .DEFAULT_TRACER );
91
- }
92
-
93
84
}
0 commit comments