diff --git a/server/probe_servlet.go b/server/probe_servlet.go
index fa6325f..e50769f 100644
--- a/server/probe_servlet.go
+++ b/server/probe_servlet.go
@@ -26,7 +26,7 @@ type probeServlet struct {
 
 func (s *probeServlet) IsCanConnect(ctx *fasthttp.RequestCtx) bool {
 	var buf []byte
-	if buf = ctx.Request.Header.Peek(ProbeHeader_ProbeKey); nil != buf {
+	if buf = ctx.Request.Header.Peek(ProbeHeader_ProbeKey); nil == buf {
 		return false
 	}
 	probeKey := string(buf)
diff --git a/subscribe/redis.go b/subscribe/redis.go
index fee2c61..bafc6fa 100644
--- a/subscribe/redis.go
+++ b/subscribe/redis.go
@@ -9,8 +9,8 @@ import (
 
 func Subscribe(ctx context.Context, redisConn redis.Conn) {
 	s := ofs_redis.New(ctx, redisConn)
-	probeS := newProbeSubscriberHandler(ctx, "probe")
-	authS := newAuthSubscriberHandler(ctx, "auth")
+	probeS := newProbeSubscriberHandler(ctx, "/probe")
+	authS := newAuthSubscriberHandler(ctx, "/auth")
 
 	s.Subscribe(probeS)
 	s.Subscribe(authS)