mxsm opened a new issue, #4345:
URL: https://github.com/apache/eventmesh/issues/4345

   ### Search before asking
   
   - [X] I had searched in the 
[issues](https://github.com/apache/eventmesh/issues?q=is%3Aissue) and found no 
similar issues.
   
   
   ### Environment
   
   Windows
   
   ### EventMesh version
   
   master
   
   ### What happened
   
   when I use rust client to publish http EventMesh message without 
requestCode. And then will throw java.lang.NullPointerException
   
![image](https://github.com/apache/eventmesh/assets/15797831/d9ce2b54-1d27-4125-a9c4-0ecda948205e)
   
   
   ### How to reproduce
   
   EventMesh message without requestCode
   
   ### Debug logs
   
   ```java
   2023-08-10 11:42:20,086 DEBUG [pool-4-thread-1] 
ConsumerManager(ConsumerManager.java:209) - grpc client info check
   2023-08-10 11:42:20,086 DEBUG [pool-4-thread-1] 
ConsumerManager(ConsumerManager.java:218) - total number of 
ConsumerGroupClients: 0
   2023-08-10 11:42:26,760 ERROR [eventMesh-http-worker-4] 
AbstractHTTPServer(AbstractHTTPServer.java:450) - 
AbstractHTTPServer.HTTPHandler.channelRead error
   java.lang.NullPointerException: null
        at 
org.apache.eventmesh.runtime.boot.AbstractHTTPServer$HTTPHandler.channelRead(AbstractHTTPServer.java:417)
 [classes/:?]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
 [netty-transport-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
 [netty-transport-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
 [netty-transport-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
 [netty-codec-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
 [netty-transport-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365)
 [netty-transport-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357)
 [netty-transport-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:327)
 [netty-codec-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:299)
 [netty-codec-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379)
 [netty-transport-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.access$600(AbstractChannelHandlerContext.java:61)
 [netty-transport-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext$7.run(AbstractChannelHandlerContext.java:370)
 [netty-transport-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.util.concurrent.AbstractEventExecutor.runTask$$$capture(AbstractEventExecutor.java:174)
 [netty-common-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java)
 [netty-common-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:167)
 [netty-common-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
 [netty-common-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
 [netty-common-4.1.79.Final.jar:4.1.79.Final]
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:503) 
[netty-transport-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
 [netty-common-4.1.79.Final.jar:4.1.79.Final]
        at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 
[netty-common-4.1.79.Final.jar:4.1.79.Final]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
   2023-08-10 11:42:30,073 DEBUG [pool-4-thread-1] 
ConsumerManager(ConsumerManager.java:209) - grpc client info check
   2023-08-10 11:42:30,073 DEBUG [pool-4-thread-1] 
ConsumerManager(ConsumerManager.java:218) - total number of 
ConsumerGroupClients: 0
   ```
   
   ### Are you willing to submit PR?
   
   - [X] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct) *


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to