diff --git a/tm-monitor/eventmeter/eventmeter.go b/tm-monitor/eventmeter/eventmeter.go
index 82cd7a18..314e039d 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
 	}