@Override public void close() throws TimeoutException {
  stop(Duration.ofSeconds(2));
}

@ Override public void close ( ) throws TimeoutException { stop ( Duration . ofSeconds ( 2 ) ) ; }
unsubscribes from the persistent subscription ( using 2 seconds wait time before it should timeout ) .
