diff --git a/lib-ee/emqx_ee_connector/src/emqx_ee_connector.app.src b/lib-ee/emqx_ee_connector/src/emqx_ee_connector.app.src index 3ed460492..702b9ff09 100644 --- a/lib-ee/emqx_ee_connector/src/emqx_ee_connector.app.src +++ b/lib-ee/emqx_ee_connector/src/emqx_ee_connector.app.src @@ -1,6 +1,6 @@ {application, emqx_ee_connector, [ {description, "EMQX Enterprise connectors"}, - {vsn, "0.1.13"}, + {vsn, "0.1.14"}, {registered, []}, {applications, [ kernel, diff --git a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_redis.erl b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_redis.erl index 4ce96d5c7..7eb3ec322 100644 --- a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_redis.erl +++ b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_redis.erl @@ -44,7 +44,9 @@ on_start(InstId, #{command_template := CommandTemplate} = Config) -> end. on_stop(InstId, #{conn_st := RedisConnSt}) -> - emqx_connector_redis:on_stop(InstId, RedisConnSt). + emqx_connector_redis:on_stop(InstId, RedisConnSt); +on_stop(InstId, undefined = _State) -> + emqx_connector_redis:on_stop(InstId, undefined). on_get_status(InstId, #{conn_st := RedisConnSt}) -> emqx_connector_redis:on_get_status(InstId, RedisConnSt).