worker working

Signed-off-by: Kenneth Reitz <me@kennethreitz.org>

cmd/herald-worker/main.go

@@ -3,24 +3,54 @@ package main
 import "os"
 // import "strings"
 import "fmt"
-import "github.com/mailgun/mailgun-go"
+import "time"
+import "github.com/gocelery/gocelery"
+
+
+func add(a int, b int) int {
+    fmt.Println("hello world")
+    return a + b
+}
 
 
 func main() {
 
     // Setup MailGun environment variables. 
-    var MAILGUN_API_KEY string
-    var MAILGUN_PUBLIC_KEY string
-    var MAILGUN_DOMAIN string
+    // var MAILGUN_API_KEY string
+    // var MAILGUN_PUBLIC_KEY string
+    // var MAILGUN_DOMAIN string
 
-    MAILGUN_API_KEY = os.Getenv("MAILGUN_API_KEY")
-    MAILGUN_PUBLIC_KEY = os.Getenv("MAILGUN_PUBLIC_KEY")
-    MAILGUN_DOMAIN = os.Getenv("MAILGUN_DOMAIN")
-
-    // Initialize MailGun API. 
-    mg := mailgun.NewMailgun(MAILGUN_DOMAIN, MAILGUN_API_KEY, MAILGUN_PUBLIC_KEY)
-    _ = mg
+    // MAILGUN_API_KEY = os.Getenv("MAILGUN_API_KEY")
+    // MAILGUN_PUBLIC_KEY = os.Getenv("MAILGUN_PUBLIC_KEY")
+    // MAILGUN_DOMAIN = os.Getenv("MAILGUN_DOMAIN")
+
+
+    // Setup AMPQ environment variables.
+    var RABBITMQ_BIGWIG_URL string
+
+    RABBITMQ_BIGWIG_URL = os.Getenv("RABBITMQ_BIGWIG_URL")
+
+    // Configure Celery Broker and Client. 
+    celeryBroker := gocelery.NewAMQPCeleryBroker(RABBITMQ_BIGWIG_URL)
+    celeryBackend := gocelery.NewAMQPCeleryBackend(RABBITMQ_BIGWIG_URL)
+    celeryClient, _ := gocelery.NewCeleryClient(celeryBroker, celeryBackend, 2)
+
+    // Configure Celery tasks. 
+    celeryClient.Register("worker.add", add)
+
+    // Start the worker.
+    go celeryClient.StartWorker()
+
+    asyncResult, err := celeryClient.Delay("worker.add", 3, 5)
+    if err != nil {
+        panic(err)
+    }
+
+    _ = asyncResult
+
+
+    // TODO: Main loop here, of checking buildpacks here for status updates.
+    time.Sleep(60 * time.Second)
 
 
-    fmt.Println("hello world")
 }