diff --git a/storage/ping/stream.go b/storage/ping/stream.go index 346fe84..48e8d6b 100644 --- a/storage/ping/stream.go +++ b/storage/ping/stream.go @@ -51,7 +51,7 @@ func (p *pingStream) Put(ctx context.Context, msg message.Message) error { nUrl = "http:" + nUrl } if p.method == http.MethodGet { - _, err = p.httpClient.Get(nUrl) + resp, err = p.httpClient.Get(nUrl) } else { resp, err = p.httpClient.Post(nUrl, p.contentType, strings.NewReader(msg.JSON())) }