|
@@ -186,23 +186,13 @@ on_stop(InstId, #{poolname := PoolName}) ->
|
|
|
}),
|
|
}),
|
|
|
emqx_plugin_libs_pool:stop_pool(PoolName).
|
|
emqx_plugin_libs_pool:stop_pool(PoolName).
|
|
|
|
|
|
|
|
-on_query(InstId,
|
|
|
|
|
- {Action, Collection, Filter, Projector},
|
|
|
|
|
- AfterQuery,
|
|
|
|
|
- #{poolname := PoolName} = State) ->
|
|
|
|
|
- Request = {Action, Collection, Filter, Projector},
|
|
|
|
|
- ?TRACE("QUERY", "mongodb_connector_received",
|
|
|
|
|
- #{request => Request, connector => InstId, state => State}),
|
|
|
|
|
- case ecpool:pick_and_do(PoolName,
|
|
|
|
|
- {?MODULE, mongo_query, [Action, Collection, Filter, Projector]},
|
|
|
|
|
- no_handover) of
|
|
|
|
|
on_query(
|
|
on_query(
|
|
|
InstId,
|
|
InstId,
|
|
|
{Action, Collection, Filter, Projector},
|
|
{Action, Collection, Filter, Projector},
|
|
|
AfterQuery,
|
|
AfterQuery,
|
|
|
#{poolname := PoolName} = State
|
|
#{poolname := PoolName} = State
|
|
|
) ->
|
|
) ->
|
|
|
- Request = {Action, Collection, Selector, Projector},
|
|
|
|
|
|
|
+ Request = {Action, Collection, Filter, Projector},
|
|
|
?TRACE(
|
|
?TRACE(
|
|
|
"QUERY",
|
|
"QUERY",
|
|
|
"mongodb_connector_received",
|
|
"mongodb_connector_received",
|
|
@@ -211,7 +201,7 @@ on_query(
|
|
|
case
|
|
case
|
|
|
ecpool:pick_and_do(
|
|
ecpool:pick_and_do(
|
|
|
PoolName,
|
|
PoolName,
|
|
|
- {?MODULE, mongo_query, [Action, Collection, Selector, Projector]},
|
|
|
|
|
|
|
+ {?MODULE, mongo_query, [Action, Collection, Filter, Projector]},
|
|
|
no_handover
|
|
no_handover
|
|
|
)
|
|
)
|
|
|
of
|
|
of
|