File tree Expand file tree Collapse file tree 3 files changed +4
-8
lines changed
main/java/org/apache/rocketmq/client/trace
test/java/org/apache/rocketmq/client/trace Expand file tree Collapse file tree 3 files changed +4
-8
lines changed Original file line number Diff line number Diff line change 47
47
<groupId >org.apache.commons</groupId >
48
48
<artifactId >commons-lang3</artifactId >
49
49
</dependency >
50
- <dependency >
51
- <groupId >commons-codec</groupId >
52
- <artifactId >commons-codec</artifactId >
53
- </dependency >
54
50
<dependency >
55
51
<groupId >io.opentracing</groupId >
56
52
<artifactId >opentracing-api</artifactId >
Original file line number Diff line number Diff line change 17
17
18
18
package org .apache .rocketmq .client .trace ;
19
19
20
+ import java .nio .charset .StandardCharsets ;
20
21
import java .util .ArrayList ;
21
22
import java .util .List ;
22
- import org .apache .commons .codec .Charsets ;
23
23
import org .apache .rocketmq .common .message .MessageExt ;
24
24
25
25
public class TraceView {
@@ -40,7 +40,7 @@ public class TraceView {
40
40
41
41
public static List <TraceView > decodeFromTraceTransData (String key , MessageExt messageExt ) {
42
42
List <TraceView > messageTraceViewList = new ArrayList <TraceView >();
43
- String messageBody = new String (messageExt .getBody (), Charsets .UTF_8 );
43
+ String messageBody = new String (messageExt .getBody (), StandardCharsets .UTF_8 );
44
44
if (messageBody == null || messageBody .length () <= 0 ) {
45
45
return messageTraceViewList ;
46
46
}
Original file line number Diff line number Diff line change 17
17
18
18
package org .apache .rocketmq .client .trace ;
19
19
20
- import org .apache .commons .codec .Charsets ;
21
20
import org .apache .rocketmq .common .message .MessageExt ;
22
21
import org .apache .rocketmq .common .message .MessageType ;
23
22
import org .junit .Assert ;
24
23
import org .junit .Test ;
25
24
25
+ import java .nio .charset .StandardCharsets ;
26
26
import java .util .List ;
27
27
28
28
public class TraceViewTest {
@@ -46,7 +46,7 @@ public void testDecodeFromTraceTransData() {
46
46
.append (true ).append (TraceConstants .FIELD_SPLITOR )
47
47
.toString ();
48
48
MessageExt message = new MessageExt ();
49
- message .setBody (messageBody .getBytes (Charsets .UTF_8 ));
49
+ message .setBody (messageBody .getBytes (StandardCharsets .UTF_8 ));
50
50
String key = "AC1415116D1418B4AAC217FE1B4E0000" ;
51
51
List <TraceView > traceViews = TraceView .decodeFromTraceTransData (key , message );
52
52
Assert .assertEquals (traceViews .size (), 1 );
You can’t perform that action at this time.
0 commit comments