Skip to content

Commit 0429233

Browse files
committed
refactor: 优化透传解析api
1 parent e3aa51a commit 0429233

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/message/transparent/SimpleTransparentMessageCodec.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@
4040
import reactor.core.publisher.Flux;
4141
import reactor.core.publisher.Mono;
4242

43+
import java.nio.charset.Charset;
4344
import java.util.*;
4445
import java.util.function.Function;
4546
import java.util.function.Supplier;
@@ -157,10 +158,14 @@ public ByteBuf payload() {
157158
public Object json() {
158159
return ObjectMappers.parseJson(ByteBufUtil.getBytes(buffer), Object.class);
159160
}
161+
public Object text() {
162+
return new String(ByteBufUtil.getBytes(buffer), Charset.defaultCharset());
163+
}
160164

161165
public Object jsonArray() {
162166
return ObjectMappers.parseJsonArray(ByteBufUtil.getBytes(buffer), Object.class);
163167
}
168+
164169
public Map<String, String> pathVars(String pattern, String path) {
165170
return TopicUtils.getPathVariables(pattern, path);
166171
}

0 commit comments

Comments
 (0)