code: func anyMessageHandler(timer ttime.Timer, client wsclient.ClientServer) func(interface{}) {
  	return func(interface{}) {
  		seelog.Debug("ACS activity occurred")
  		// Reset read deadline as there's activity on the channel
  		if err := client.SetReadDeadline(time.Now().Add(wsRWTimeout)); err != nil {
  			seelog.Warnf("Unable to extend read deadline for ACS connection: %v", err)
  		}
  
  		// Reset heartbeat timer
  		timer.Reset(retry.AddJitter(heartbeatTimeout, heartbeatJitter))
  	}
  }
docs: // anyMessageHandler handles any server message. Any server message means the
  // connection is active and thus the heartbeat disconnect should not occur