Merge pull request #202 from maxekman/ISSUE-201/redigo-version

ISSUE-201 / Use gomodule/redigo instead of garyburd/redigo
looplab · Mar 21, 2018 · e1bbbab · e1bbbab
2 parents d026aa3 + 00effb7
commit e1bbbab
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 15 deletions.
diff --git a/Gopkg.lock b/Gopkg.lock
diff --git a/Gopkg.toml b/Gopkg.toml
@@ -30,8 +30,8 @@
   version = "1.12.49"
 
 [[constraint]]
-  name = "github.com/garyburd/redigo"
-  version = "1.6.0"
+  name = "github.com/gomodule/redigo"
+  version = "2.0.0"
 
 [[constraint]]
   name = "github.com/gorhill/cronexpr"

diff --git a/publisher/redis/publisher.go b/publisher/redis/publisher.go
@@ -22,8 +22,8 @@ import (
 	"strings"
 	"time"
 
-	"github.com/garyburd/redigo/redis"
 	"github.com/globalsign/mgo/bson"
+	"github.com/gomodule/redigo/redis"
 	"github.com/jpillora/backoff"
 
 	eh "github.com/looplab/eventhorizon"
@@ -188,7 +188,7 @@ func (b *EventPublisher) recv(delay *backoff.Backoff) error {
 
 	for {
 		switch m := pubSubConn.Receive().(type) {
-		case redis.PMessage:
+		case redis.Message:
 			if err := b.handleMessage(m); err != nil {
 				log.Println("eventpublisher: error publishing:", err)
 			}
@@ -216,7 +216,7 @@ func (b *EventPublisher) recv(delay *backoff.Backoff) error {
 	}
 }
 
-func (b *EventPublisher) handleMessage(msg redis.PMessage) error {
+func (b *EventPublisher) handleMessage(msg redis.Message) error {
 	// Manually decode the raw BSON event.
 	data := bson.Raw{
 		Kind: 3,