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: