Repository: incubator-rocketmq Updated Branches: refs/heads/develop d7decc84a -> e05a445b2
Logging on exception when producing a response. Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/e05a445b Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/e05a445b Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/e05a445b Branch: refs/heads/develop Commit: e05a445b213a52d9b45196bf3e56716b45e9853a Parents: d7decc8 Author: shtykh_roman <[email protected]> Authored: Tue Mar 14 14:23:25 2017 +0900 Committer: shtykh_roman <[email protected]> Committed: Tue Mar 14 14:23:25 2017 +0900 ---------------------------------------------------------------------- .../org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/e05a445b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java ---------------------------------------------------------------------- diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java index 8bf48ac..e35316d 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java @@ -220,6 +220,7 @@ public class AdminBrokerProcessor implements NettyRequestProcessor { response.setRemark(null); ctx.writeAndFlush(response); } catch (Exception e) { + log.error("Failed to produce a proper response", e); } TopicConfig topicConfig = new TopicConfig(requestHeader.getTopic()); @@ -231,6 +232,7 @@ public class AdminBrokerProcessor implements NettyRequestProcessor { this.brokerController.getTopicConfigManager().updateTopicConfig(topicConfig); this.brokerController.registerBrokerAll(false, true); + return null; }
