emqx-extension-examples
emqx-extension-examples copied to clipboard
java in method onMessagePublish() cannot change message payload?
final Message destMsg = Message.newBuilder(request.getMessage()).setPayload(ByteString.copyFrom("11"),Charset.defaultCharset()).build(); ValueResponse reply = ValueResponse.newBuilder().setMessage(destMsg).build();
input message like: {"msg":"hello"}
but output message is same as input message, not the expected value "11",why?