diff --git a/include/neuron/errcodes.h b/include/neuron/errcodes.h index d7ea6dc0..1abaea0c 100644 --- a/include/neuron/errcodes.h +++ b/include/neuron/errcodes.h @@ -46,16 +46,17 @@ typedef enum { NEU_ERR_DUPLICATE_PASSWORD = 1013, NEU_ERR_COMMAND_EXECUTION_FAILED = 1014, - NEU_ERR_NODE_EXIST = 2002, - NEU_ERR_NODE_NOT_EXIST = 2003, - NEU_ERR_NODE_SETTING_INVALID = 2004, - NEU_ERR_NODE_SETTING_NOT_FOUND = 2005, - NEU_ERR_NODE_NOT_READY = 2006, - NEU_ERR_NODE_IS_RUNNING = 2007, - NEU_ERR_NODE_NOT_RUNNING = 2008, - NEU_ERR_NODE_IS_STOPED = 2009, - NEU_ERR_NODE_NAME_TOO_LONG = 2010, - NEU_ERR_NODE_NOT_ALLOW_DELETE = 2011, + NEU_ERR_NODE_EXIST = 2002, + NEU_ERR_NODE_NOT_EXIST = 2003, + NEU_ERR_NODE_SETTING_INVALID = 2004, + NEU_ERR_NODE_SETTING_NOT_FOUND = 2005, + NEU_ERR_NODE_NOT_READY = 2006, + NEU_ERR_NODE_IS_RUNNING = 2007, + NEU_ERR_NODE_NOT_RUNNING = 2008, + NEU_ERR_NODE_IS_STOPED = 2009, + NEU_ERR_NODE_NAME_TOO_LONG = 2010, + NEU_ERR_NODE_NOT_ALLOW_DELETE = 2011, + NEU_ERR_NODE_NOT_ALLOW_SUBSCRIBE = 2012, NEU_ERR_GROUP_ALREADY_SUBSCRIBED = 2101, NEU_ERR_GROUP_NOT_SUBSCRIBE = 2102, diff --git a/src/core/manager_internal.c b/src/core/manager_internal.c index ccd43e88..f5f3dca9 100644 --- a/src/core/manager_internal.c +++ b/src/core/manager_internal.c @@ -192,6 +192,11 @@ int neu_manager_subscribe(neu_manager_t *manager, const char *app, return NEU_ERR_NODE_NOT_EXIST; } + if (0 == strcmp(app, "monitor")) { + // filter out monitor node + return NEU_ERR_NODE_NOT_ALLOW_SUBSCRIBE; + } + ret = neu_adapter_driver_group_exist((neu_adapter_driver_t *) adapter, group); if (ret != NEU_ERR_SUCCESS) { diff --git a/src/utils/http.c b/src/utils/http.c index 3d253ae0..b150ce70 100644 --- a/src/utils/http.c +++ b/src/utils/http.c @@ -314,6 +314,7 @@ int neu_http_response(nng_aio *aio, neu_err_code_e code, char *content) case NEU_ERR_BODY_IS_WRONG: case NEU_ERR_PARAM_IS_WRONG: case NEU_ERR_NODE_SETTING_INVALID: + case NEU_ERR_NODE_NOT_ALLOW_SUBSCRIBE: case NEU_ERR_LIBRARY_INFO_INVALID: case NEU_ERR_LICENSE_INVALID: case NEU_ERR_GROUP_PARAMETER_INVALID: