|
@@ -147,9 +147,9 @@ create(ResId, Group, ResourceType, Config, Opts) ->
|
|
|
QueryMode = emqx_resource:query_mode(ResourceType, Config, Opts),
|
|
QueryMode = emqx_resource:query_mode(ResourceType, Config, Opts),
|
|
|
case QueryMode of
|
|
case QueryMode of
|
|
|
%% the resource has built-in buffer, so there is no need for resource workers
|
|
%% the resource has built-in buffer, so there is no need for resource workers
|
|
|
- simple_sync ->
|
|
|
|
|
|
|
+ simple_sync_internal_buffer ->
|
|
|
ok;
|
|
ok;
|
|
|
- simple_async ->
|
|
|
|
|
|
|
+ simple_async_internal_buffer ->
|
|
|
ok;
|
|
ok;
|
|
|
%% The resource is a consumer resource, so there is no need for resource workers
|
|
%% The resource is a consumer resource, so there is no need for resource workers
|
|
|
no_queries ->
|
|
no_queries ->
|