payload-processor: add stub

2 files changed, 5 insertions, 5 deletions

diff --git a/src/rest-api/cmd/main.go b/src/rest-api/cmd/main.go
index 6740bea..f6d34e0 100644
--- a/src/rest-api/cmd/main.go
+++ b/src/rest-api/cmd/main.go
@@ -13,18 +13,18 @@ import (
 func main() {
 	rabbitmq_password, ok := os.LookupEnv("RABBITMQ_PASSWORD")
 	if !ok {
-		panic("RABBITMQ_PASSWORD not set")
+		log.Fatal("RABBITMQ_PASSWORD not set")
 	}
 	log.Println("RabbitMQ password", rabbitmq_password)
 	conn, err := amqp.Dial(fmt.Sprintf("amqp://user:%s@rabbitmq:5672/", rabbitmq_password))
 	if err != nil {
-		panic(err)
+		log.Fatal(err)
 	}
 	defer conn.Close()
 
 	ch, err := conn.Channel()
 	if err != nil {
-		panic(err)
+		log.Fatal(err)
 	}
 	defer ch.Close()
 
@@ -37,7 +37,7 @@ func main() {
 		nil,     // arguments
 	)
 	if err != nil {
-		panic(err)
+		log.Fatal(err)
 	}
 	handler := handler.NewHandler(ch, q.Name)
 
diff --git a/src/rest-api/handler/handler.go b/src/rest-api/handler/handler.go
index b5c3ae2..c904ff4 100644
--- a/src/rest-api/handler/handler.go
+++ b/src/rest-api/handler/handler.go
@@ -26,7 +26,7 @@ func NewHandler(ch *amqp.Channel, queueName string) *Handler {
 func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	bytes, err := io.ReadAll(io.Reader(r.Body))
 	if err != nil {
-		panic(err)
+		log.Fatal(err)
 	}
 
 	body := fmt.Sprint("Hello World!", r.RemoteAddr, string(bytes))