Skip to content

Commit 8e72be5

Browse files
committed
fix: update something
1 parent e349def commit 8e72be5

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

Diff for: eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/ReplyMessageProcessor.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -73,12 +73,12 @@ public ReplyMessageProcessor(EventMeshHTTPServer eventMeshHTTPServer) {
7373

7474
@Override
7575
public void processRequest(ChannelHandlerContext ctx, AsyncContext<HttpCommand> asyncContext) throws Exception {
76-
HttpCommand responseEventMeshCommand;
7776
String localAddress = IPUtils.getLocalAddress();
7877
HttpCommand request = asyncContext.getRequest();
78+
final String channelRemoteAddr = RemotingHelper.parseChannelRemoteAddr(ctx.channel());
7979
cmdLogger.info("cmd={}|{}|client2eventMesh|from={}|to={}", RequestCode.get(Integer.valueOf(request.getRequestCode())),
8080
EventMeshConstants.PROTOCOL_HTTP,
81-
RemotingHelper.parseChannelRemoteAddr(ctx.channel()), localAddress);
81+
channelRemoteAddr, localAddress);
8282

8383
ReplyMessageRequestHeader replyMessageRequestHeader = (ReplyMessageRequestHeader) request.getHeader();
8484

@@ -167,7 +167,6 @@ public void processRequest(ChannelHandlerContext ctx, AsyncContext<HttpCommand>
167167

168168
try {
169169
// body
170-
// omsMsg.setBody(replyMessageRequestBody.getContent().getBytes(EventMeshConstants.DEFAULT_CHARSET));
171170
event = CloudEventBuilder.from(event)
172171
.withSubject(replyTopic)
173172
.withExtension(EventMeshConstants.MSG_TYPE, EventMeshConstants.PERSISTENT)

0 commit comments

Comments
 (0)