fix pusher

This commit is contained in:
anlicheng 2025-04-07 15:36:19 +08:00
parent 49d251f95f
commit 9237371034
2 changed files with 5 additions and 2 deletions

View File

@ -62,7 +62,10 @@ start_link() ->
{stop, Reason :: term()} | ignore).
init([]) ->
Size = get_pool_size(),
TaskPids = lists:map(fun(_) -> dimension_task:start_link() end, lists:seq(1, Size)),
TaskPids = lists:map(fun(_) ->
{ok, Pid} = dimension_task:start_link(),
Pid
end, lists:seq(1, Size)),
lager:debug("[dimension_apn_pusher] pool_size: ~p, task_pids: ~p", [Size, TaskPids]),
{ok, #state{task_pids = TaskPids}}.

View File

@ -12,7 +12,7 @@
{pools, [
%% 推送设置
{apns_pool,
[{size, 10}, {max_overflow, 20}, {worker_module, dimension_apn_worker}],
[{size, 1}, {max_overflow, 2}, {worker_module, dimension_apn_worker}],
[
{connection_opts, [
{apple_host, "api.sandbox.push.apple.com"},