未验证 提交 1b757b40 编写于 作者: G gorden5566 提交者: GitHub

[ISSUE #3196] Check if "requestHeader" is null before "requestHeader.getTopic()"

上级 17b9efe1
...@@ -257,8 +257,8 @@ public abstract class AbstractSendMessageProcessor extends AsyncNettyRequestProc ...@@ -257,8 +257,8 @@ public abstract class AbstractSendMessageProcessor extends AsyncNettyRequestProc
try { try {
final SendMessageRequestHeader requestHeader = parseRequestHeader(request); final SendMessageRequestHeader requestHeader = parseRequestHeader(request);
String namespace = NamespaceUtil.getNamespaceFromResource(requestHeader.getTopic());
if (null != requestHeader) { if (null != requestHeader) {
String namespace = NamespaceUtil.getNamespaceFromResource(requestHeader.getTopic());
context.setNamespace(namespace); context.setNamespace(namespace);
context.setProducerGroup(requestHeader.getProducerGroup()); context.setProducerGroup(requestHeader.getProducerGroup());
context.setTopic(requestHeader.getTopic()); context.setTopic(requestHeader.getTopic());
......
...@@ -612,6 +612,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement ...@@ -612,6 +612,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
} }
} }
@Override
public SocketAddress getStoreHost() { public SocketAddress getStoreHost() {
return storeHost; return storeHost;
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册