From 9442a069a30cac0e8566518d5e5498528003013f Mon Sep 17 00:00:00 2001
From: Anton Kaliaev <anton.kalyaev@gmail.com>
Date: Tue, 28 Mar 2017 13:51:14 +0400
Subject: [PATCH] [tm-monitor] use BaseService.Reset method

---
 tm-monitor/eventmeter/eventmeter.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/tm-monitor/eventmeter/eventmeter.go b/tm-monitor/eventmeter/eventmeter.go
index 82cd7a186..314e039d3 100644
--- a/tm-monitor/eventmeter/eventmeter.go
+++ b/tm-monitor/eventmeter/eventmeter.go
@@ -105,7 +105,6 @@ func NewEventMeter(addr string, unmarshalEvent EventUnmarshalFunc) *EventMeter {
 		timer:          metrics.NewTimer(),
 		receivedPong:   true,
 		unmarshalEvent: unmarshalEvent,
-		quit:           make(chan struct{}),
 		logger:         log.NewNopLogger(),
 	}
 	return em
@@ -121,6 +120,10 @@ func (em *EventMeter) String() string {
 }
 
 func (em *EventMeter) Start() error {
+	if _, err := em.wsc.Reset(); err != nil {
+		return err
+	}
+
 	if _, err := em.wsc.Start(); err != nil {
 		return err
 	}