|
|
@@ -220,9 +220,10 @@ kafka_bridge_rest_api_helper(Config) ->
|
|
|
BridgeIdUrlEnc = BridgeType ++ UrlEscColon ++ BridgeName,
|
|
|
BridgesParts = ["bridges"],
|
|
|
BridgesPartsIdDeleteAlsoActions = ["bridges", BridgeIdUrlEnc ++ "?also_delete_dep_actions"],
|
|
|
- OpUrlFun = fun(OpName) -> ["bridges", BridgeIdUrlEnc, "operation", OpName] end,
|
|
|
- BridgesPartsOpDisable = OpUrlFun("disable"),
|
|
|
- BridgesPartsOpEnable = OpUrlFun("enable"),
|
|
|
+ OpUrlFun = fun(OpName) -> ["bridges", BridgeIdUrlEnc, OpName] end,
|
|
|
+ EnableFun = fun(Enable) -> ["bridges", BridgeIdUrlEnc, "enable", Enable] end,
|
|
|
+ BridgesPartsOpDisable = EnableFun("false"),
|
|
|
+ BridgesPartsOpEnable = EnableFun("true"),
|
|
|
BridgesPartsOpRestart = OpUrlFun("restart"),
|
|
|
BridgesPartsOpStop = OpUrlFun("stop"),
|
|
|
%% List bridges
|
|
|
@@ -321,10 +322,10 @@ kafka_bridge_rest_api_helper(Config) ->
|
|
|
?assertEqual(0, emqx_resource_metrics:retried_failed_get(ResourceId)),
|
|
|
?assertEqual(0, emqx_resource_metrics:retried_success_get(ResourceId)),
|
|
|
%% Perform operations
|
|
|
- {ok, 200, _} = show(http_post(show(BridgesPartsOpDisable), #{})),
|
|
|
- {ok, 200, _} = show(http_post(show(BridgesPartsOpDisable), #{})),
|
|
|
- {ok, 200, _} = show(http_post(show(BridgesPartsOpEnable), #{})),
|
|
|
- {ok, 200, _} = show(http_post(show(BridgesPartsOpEnable), #{})),
|
|
|
+ {ok, 204, _} = show(http_put(show(BridgesPartsOpDisable), #{})),
|
|
|
+ {ok, 204, _} = show(http_put(show(BridgesPartsOpDisable), #{})),
|
|
|
+ {ok, 204, _} = show(http_put(show(BridgesPartsOpEnable), #{})),
|
|
|
+ {ok, 204, _} = show(http_put(show(BridgesPartsOpEnable), #{})),
|
|
|
{ok, 200, _} = show(http_post(show(BridgesPartsOpStop), #{})),
|
|
|
{ok, 200, _} = show(http_post(show(BridgesPartsOpStop), #{})),
|
|
|
{ok, 200, _} = show(http_post(show(BridgesPartsOpRestart), #{})),
|