From 31bf0af3ed1a1048d13fcbf17c386cabf6b73e37 Mon Sep 17 00:00:00 2001
From: shtykh_roman <rshtykh@yahoo.com>
Date: Tue, 14 Mar 2017 14:23:25 +0900
Subject: [PATCH] Logging on exception when producing a response.

---
 .../apache/rocketmq/broker/processor/AdminBrokerProcessor.java  | 2 ++
 1 file changed, 2 insertions(+)

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 8bf48acc..e35316d6 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;
     }
 
-- 
GitLab