From c16fac96426156be8d5a6529c3ee7f092c5f5615 Mon Sep 17 00:00:00 2001
From: Janne Koschinski <janne@kuschku.de>
Date: Sun, 18 Mar 2018 03:19:25 +0100
Subject: [PATCH] Fixed a minor issue
---
main.go | 28 +++++++++++++++-------------
1 file changed, 15 insertions(+), 13 deletions(-)
diff --git a/main.go b/main.go
index 94ee77c..f07d64e 100644
--- a/main.go
+++ b/main.go
@@ -68,23 +68,25 @@ func processImage(config *Config, client *redis.Client, value string) {
}
func main() {
- config := NewConfigFromEnv()
+ go func() {
+ config := NewConfigFromEnv()
- imagick.Initialize()
- defer imagick.Terminate()
+ imagick.Initialize()
+ defer imagick.Terminate()
- client := redis.NewClient(&redis.Options{
- Addr: config.Redis.Address,
- Password: config.Redis.Password,
- })
+ client := redis.NewClient(&redis.Options{
+ Addr: config.Redis.Address,
+ Password: config.Redis.Password,
+ })
- for {
- element := client.BLPop(0, fmt.Sprintf("queue:%s", config.ImageQueue))
- if len(element.Val()) == 2 {
- value := element.Val()[1]
- go processImage(&config, client, value)
+ for {
+ element := client.BLPop(0, fmt.Sprintf("queue:%s", config.ImageQueue))
+ if len(element.Val()) == 2 {
+ value := element.Val()[1]
+ go processImage(&config, client, value)
+ }
}
- }
+ }()
http.HandleFunc("/healthz", func(w http.ResponseWriter, r *http.Request) {
w.Write([]byte("OK"))
--
GitLab