Emit error in case of error

QuesmaOrg · Dec 27, 2024 · 2ef3e94 · 2ef3e94
1 parent 1d9daba
commit 2ef3e94
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/quesma/frontend_connectors/basic_http_frontend_connector.go b/quesma/frontend_connectors/basic_http_frontend_connector.go
@@ -6,6 +6,7 @@ package frontend_connectors
 import (
 	"bytes"
 	"context"
+	"errors"
 	"io"
 	"net/http"
 	"quesma/clickhouse"
@@ -135,8 +136,7 @@ func (h *BasicHTTPFrontendConnector) Listen() error {
 	h.mutex.Lock()
 	defer h.mutex.Unlock()
 	if h.listener != nil {
-		// TODO handle this gracefully and return correct error
-		return nil
+		return errors.New("listener already started")
 	}
 	h.listener = &http.Server{}
 	h.listener.Addr = h.endpoint