diff --git a/stream/ingest_proxy.liq b/stream/ingest_proxy.liq index 351e107..eb5214c 100644 --- a/stream/ingest_proxy.liq +++ b/stream/ingest_proxy.liq @@ -71,13 +71,13 @@ ingest_dequeue_url = "http://ingest:8080/dequeue" harbor.http.register( port=8000, method="POST", "/dequeue", fun(req, resp) -> begin - id = list.assoc(default="", "id", req.query) - if id == "" then + entry_id = list.assoc(default="", "id", req.query) + if entry_id == "" then resp.status_code(400) resp.data("missing id") else body = http.post( - data="", timeout=10.0, "#{ingest_dequeue_url}?id=#{url.encode(id)}" + data="", timeout=10.0, "#{ingest_dequeue_url}?id=#{url.encode(entry_id)}" ) resp.status_code(body.status_code) resp.content_type("application/json; charset=utf-8")