From ef1a27ab6c6ee08c9b84c5fa9fa2089ad175d657 Mon Sep 17 00:00:00 2001
From: crusader <crusader@loafle.com>
Date: Fri, 23 Mar 2018 01:10:27 +0900
Subject: [PATCH] ing

---
 servlet/probe/subscriber_handlers.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/servlet/probe/subscriber_handlers.go b/servlet/probe/subscriber_handlers.go
index 30931a8..1ca611c 100644
--- a/servlet/probe/subscriber_handlers.go
+++ b/servlet/probe/subscriber_handlers.go
@@ -25,7 +25,9 @@ func (sh *SubscriberHandlers) OnSubscribe(channel string, message oos.SubscribeM
 	case oos.PROBE:
 		for _, pid := range message.Targets {
 			if soc := sh.GetSocket(pid); nil != soc {
-				soc.WriteMessage(websocket.TextMessage, message.Message)
+				if err := soc.WriteMessageUseWriter(websocket.TextMessage, message.Message); nil != err {
+					logging.Logger().Errorf("OnSubscribe: write error %v", err)
+				}
 			}
 		}
 	default: