diff --git a/Gopkg.lock b/Gopkg.lock
index ca37ed0e..3e6b7fac 100644
--- a/Gopkg.lock
+++ b/Gopkg.lock
@@ -47,15 +47,6 @@
   revision = "ab772a0ae5d958feb51cba2a65eca3911882d791"
   version = "v1.12.49"
 
-[[projects]]
-  name = "github.com/garyburd/redigo"
-  packages = [
-    "internal",
-    "redis"
-  ]
-  revision = "a69d19351219b6dd56f274f96d85a7014a2ec34e"
-  version = "v1.6.0"
-
 [[projects]]
   branch = "master"
   name = "github.com/globalsign/mgo"
@@ -88,6 +79,15 @@
   ]
   revision = "1e59b77b52bf8e4b449a57e6f79f21226d571845"
 
+[[projects]]
+  name = "github.com/gomodule/redigo"
+  packages = [
+    "internal",
+    "redis"
+  ]
+  revision = "9c11da706d9b7902c6da69c592f75637793fe121"
+  version = "v2.0.0"
+
 [[projects]]
   name = "github.com/googleapis/gax-go"
   packages = ["."]
@@ -264,6 +264,6 @@
 [solve-meta]
   analyzer-name = "dep"
   analyzer-version = 1
-  inputs-digest = "9fdd3c3ded4443f813738b1bc38c8f2e391c6a3a0e106c449d18ad321b188087"
+  inputs-digest = "d32ce59a7520539566be1b1b0928d65378136c8ba41873d8f85d85afa1db956e"
   solver-name = "gps-cdcl"
   solver-version = 1
diff --git a/Gopkg.toml b/Gopkg.toml
index 016f06e1..c79bd6b7 100644
--- 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
index 6b3957a6..b40eec4a 100644
--- 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,