Sockets who need to redial to redis also need to subscribe again

pote · Jul 1, 2016 · 3a8ac3d · 3a8ac3d
1 parent 9c209ec
commit 3a8ac3d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/VERSION.go b/VERSION.go
@@ -1,3 +1,3 @@
 package main
 
-const VERSION = "0.1.2"
+const VERSION = "0.1.3"
diff --git a/socket.go b/socket.go
@@ -78,6 +78,7 @@ func (s *Socket) ListenToRedis() {
 		case error:
 			rConn.Close()
 			rConn = redis.PubSubConn{Conn: RedisPool.Get()}
+			rConn.Subscribe(s.redisChannels()...)
 		}
 	}
 }