From fb71acaaa5d3bb2135ce06d5e958724874b9f350 Mon Sep 17 00:00:00 2001
From: crusader <crusader@loafle.com>
Date: Fri, 13 Oct 2017 14:32:56 +0900
Subject: [PATCH] ing

---
 server/probe_servlet.go | 2 +-
 subscribe/redis.go      | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

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)