From 8188e06730a8a38b50edb560c8874c0ea5671311 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Fri, 14 Nov 2025 17:06:39 +0800 Subject: [PATCH] fix http endpoint --- apps/iot/src/endpoint/endpoint_http.erl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/apps/iot/src/endpoint/endpoint_http.erl b/apps/iot/src/endpoint/endpoint_http.erl index fe9a8b6..bf9615c 100644 --- a/apps/iot/src/endpoint/endpoint_http.erl +++ b/apps/iot/src/endpoint/endpoint_http.erl @@ -99,7 +99,8 @@ handle_info({next_data, Id, Metric}, State = #state{buffer = Buffer, endpoint = {ok, RespBody} = hackney:body(ClientRef), hackney:close(ClientRef), lager:debug("[endpoint_http] url: ~p, http_code: ~p, response is: ~p", [Url, HttpCode, RespBody]), - {noreply, State}; + NBuffer = endpoint_buffer:ack(Id, Buffer), + {noreply, State#state{buffer = NBuffer}}; {error, Reason} -> lager:warning("[endpoint_http] url: ~p, get error: ~p", [Url, Reason]), {noreply, State}