joshjordan · April 26, 2018 12:46 · Apr 26, 2018 · Apr 26, 2018 · Apr 26, 2018
diff --git a/dump.rdb b/dump.rdb
diff --git a/dump.rdb b/dump.rdb
diff --git a/go-producer.go b/go-producer.go
@@ -7,11 +7,6 @@ import (
 	"github.com/jrallison/go-workers"
 )
 
-//todo: does job name need to match?
-func PrototypeConsumerJob(message *workers.Msg) {}
-
-type myMiddleware struct{}
-
 func main() {
 	workers.Configure(map[string]string{
 		"server":   "localhost:6379",
@@ -21,24 +16,24 @@ func main() {
 	})
 
 	fmt.Println("Enqueuing a job...")
-	workers.Enqueue("myqueue3", "Add", []string{"Bill", "Other thing"})
+	workers.Enqueue("default", "PrototypeConsumerJob", []string{"Bill", time.Now().String()})
 	time.Sleep(1000 * time.Millisecond)
 
 	fmt.Println("Enqueuing a job...")
-	workers.Enqueue("myqueue3", "Add", []string{"Bob", "Other thing"})
+	workers.Enqueue("default", "PrototypeConsumerJob", []string{"Bob", time.Now().String()})
 	time.Sleep(1000 * time.Millisecond)
 
 	fmt.Println("Enqueuing a job...")
-	workers.Enqueue("myqueue3", "Add", []string{"Norbert", "Other thing"})
+	workers.Enqueue("default", "PrototypeConsumerJob", []string{"Norbert", time.Now().String()})
 	time.Sleep(1000 * time.Millisecond)
 
 	fmt.Println("Enqueuing a job...")
-	workers.Enqueue("myqueue3", "Add", []string{"Sherbert", "Other thing"})
+	workers.Enqueue("default", "PrototypeConsumerJob", []string{"Sherbert", time.Now().String()})
 	time.Sleep(1000 * time.Millisecond)
 
 	fmt.Println("Enqueuing a job...")
-	workers.Enqueue("myqueue3", "Add", []string{"Batman", "Other thing"})
+	workers.Enqueue("default", "PrototypeConsumerJob", []string{"Batman", time.Now().String()})
 
-	fmt.Println("Waiting for ruby to pick them up...")
+	fmt.Println("Waiting for ruby to process jobs...")
 	time.Sleep(10 * time.Minute)
 }
diff --git a/ruby-consumer.rb b/ruby-consumer.rb
@@ -1,15 +1,9 @@
 require 'sidekiq'
 
-
-
-# Sidekiq.configure_server do |config|
-#   config.redis = { :namespace => 'other-stuff-filewatcher', :size => 1, :url => 'redis://127.0.0.1:6379'}
-# end
-
 class PrototypeConsumerJob
   include Sidekiq::Worker
 
   def perform(name, other_arg)
-    puts "Received job #{name} with arg: #{other_arg}"
+    puts "Received with string '#{name}' and golang timestamp: #{other_arg}"
   end
 end
diff --git a/Procfile b/Procfile
@@ -0,0 +1,3 @@
+golang: go run go-producer.go
+redis: redis-server
+ruby: sidekiq -r './ruby-consumer.rb'
diff --git a/dump.rdb b/dump.rdb
diff --git a/go-producer.go b/go-producer.go
@@ -0,0 +1,44 @@
+package main
+
+import (
+	"fmt"
+	"time"
+
+	"github.com/jrallison/go-workers"
+)
+
+//todo: does job name need to match?
+func PrototypeConsumerJob(message *workers.Msg) {}
+
+type myMiddleware struct{}
+
+func main() {
+	workers.Configure(map[string]string{
+		"server":   "localhost:6379",
+		"database": "0",
+		"pool":     "30",
+		"process":  "1",
+	})
+
+	fmt.Println("Enqueuing a job...")
+	workers.Enqueue("myqueue3", "Add", []string{"Bill", "Other thing"})
+	time.Sleep(1000 * time.Millisecond)
+
+	fmt.Println("Enqueuing a job...")
+	workers.Enqueue("myqueue3", "Add", []string{"Bob", "Other thing"})
+	time.Sleep(1000 * time.Millisecond)
+
+	fmt.Println("Enqueuing a job...")
+	workers.Enqueue("myqueue3", "Add", []string{"Norbert", "Other thing"})
+	time.Sleep(1000 * time.Millisecond)
+
+	fmt.Println("Enqueuing a job...")
+	workers.Enqueue("myqueue3", "Add", []string{"Sherbert", "Other thing"})
+	time.Sleep(1000 * time.Millisecond)
+
+	fmt.Println("Enqueuing a job...")
+	workers.Enqueue("myqueue3", "Add", []string{"Batman", "Other thing"})
+
+	fmt.Println("Waiting for ruby to pick them up...")
+	time.Sleep(10 * time.Minute)
+}
diff --git a/ruby-consumer.rb b/ruby-consumer.rb
@@ -0,0 +1,15 @@
+require 'sidekiq'
+
+
+
+# Sidekiq.configure_server do |config|
+#   config.redis = { :namespace => 'other-stuff-filewatcher', :size => 1, :url => 'redis://127.0.0.1:6379'}
+# end
+
+class PrototypeConsumerJob
+  include Sidekiq::Worker
+
+  def perform(name, other_arg)
+    puts "Received job #{name} with arg: #{other_arg}"
+  end
+end