|
|
@@ -302,9 +302,7 @@ query_resource(Config, Request) ->
|
|
|
Name = ?config(cassa_name, Config),
|
|
|
BridgeType = ?config(cassa_bridge_type, Config),
|
|
|
BridgeV2Id = emqx_bridge_v2:id(BridgeType, Name),
|
|
|
- ConnectorResId = emqx_connector_resource:resource_id(
|
|
|
- cassandra, <<"connector_emqx_bridge_cassandra_SUITE">>
|
|
|
- ),
|
|
|
+ ConnectorResId = emqx_connector_resource:resource_id(BridgeType, Name),
|
|
|
emqx_resource:query(BridgeV2Id, Request, #{
|
|
|
timeout => 1_000, connector_resource_id => ConnectorResId
|
|
|
}).
|
|
|
@@ -315,9 +313,7 @@ query_resource_async(Config, Request) ->
|
|
|
Ref = alias([reply]),
|
|
|
AsyncReplyFun = fun(Result) -> Ref ! {result, Ref, Result} end,
|
|
|
BridgeV2Id = emqx_bridge_v2:id(BridgeType, Name),
|
|
|
- ConnectorResId = emqx_connector_resource:resource_id(
|
|
|
- cassandra, <<"connector_emqx_bridge_cassandra_SUITE">>
|
|
|
- ),
|
|
|
+ ConnectorResId = emqx_connector_resource:resource_id(BridgeType, Name),
|
|
|
Return = emqx_resource:query(BridgeV2Id, Request, #{
|
|
|
timeout => 500,
|
|
|
async_reply_fun => {AsyncReplyFun, []},
|