From 54b3dd8718de037b34628d41a44d7404d57bffc3 Mon Sep 17 00:00:00 2001 From: JimMoen Date: Sat, 18 Sep 2021 15:57:36 +0800 Subject: [PATCH] fix(mgmt_api): update listener on specific node. --- apps/emqx_management/src/emqx_mgmt_api_listeners.erl | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/apps/emqx_management/src/emqx_mgmt_api_listeners.erl b/apps/emqx_management/src/emqx_mgmt_api_listeners.erl index 9e9372058..375bd258f 100644 --- a/apps/emqx_management/src/emqx_mgmt_api_listeners.erl +++ b/apps/emqx_management/src/emqx_mgmt_api_listeners.erl @@ -248,8 +248,13 @@ crud_listener_by_id_on_node(get, #{bindings := #{id := Id, node := Node}}) -> Listener -> {200, format(Listener)} end; -crud_listener_by_id_on_node(put, #{bindings := #{id := Id, node := Node, body := Conf}}) -> - return_listeners(emqx_mgmt:update_listener(atom(Node), Id, Conf)); +crud_listener_by_id_on_node(put, #{bindings := #{id := Id, node := Node}, body := Conf}) -> + case emqx_mgmt:update_listener(atom(Node), Id, Conf) of + {error, Reason} -> + {500, #{code => 'UNKNOW_ERROR', message => err_msg(Reason)}}; + Listener -> + {200, format(Listener)} + end; crud_listener_by_id_on_node(delete, #{bindings := #{id := Id, node := Node}}) -> case emqx_mgmt:remove_listener(atom(Node), Id) of ok -> {200};