kubernetesClient = new DefaultKubernetesClient()
updateFlag = new AtomicBoolean(true)

void watch() {
 println("Start watching")
 kubernetesClient.events().inNamespace(namespaceName).watch(new Watcher < Event > () {
  @Override  void eventReceived(Action action, Event resource) {
   // println("Event " + action.name() + " " + resource.toString())
   updateFlag.set(true)
  }
  @Override  void onClose(KubernetesClientException cause) {
   println("Watcher close due to " + cause)  watch()
  }
 })
}