tree dec4c9e3a8628c8d1866e3b8547b1a8b90167889
parent 1b8da9245e111718acb337bce310ffdef7b30496
author Lari Hotari <lhotari@users.noreply.github.com> 1616860536 +0200
committer GitHub <noreply@github.com> 1616860536 -0700
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJgX1V4CRBK7hj4Ov3rIwAAdHIIAAIzivz7tLSaQKprF+KFdSge
 taVacEBdXsbKmy3PeNRljnvZqTGWjHwJNz48HH8TCxk46kHNGTbzaMZ6AJ7M8vh8
 KQu+cl+xo5m5+i7sHER1y1N7fIYjCK95A0g1raABHezpxwkC06uc8loVW3f7j0EX
 cdVMh5jPm318fW6xAfD+6UOVhXjq51BcIdr7V3fpYsddP2bzsdVK6nyCvKEfwY8L
 SI+1IkU6QBh2zFIYR/RU4pvHPYgaAKAxRDysmBLVEVfk7V8wEDgGukupgEmTgajy
 3yLJGvcQvLH8H/lzCRIX42TNKzf/BvQVmbHTF5zXIQ9Z9z29VceGstp3BwuLnL4=
 =wICG
 -----END PGP SIGNATURE-----
 

Wait for the async broker port listener close operations to complete at shutdown (#9308)

* Wait for closing of ports at shutdown

- add BrokerService.closeAsync and PulsarService.closeAsync
  so that shutdown can handle asynchronous closing operations

* Don't throw checked exceptions from methods returning CompletableFuture

- address review comment

* Set interrupt status when catching InterruptedException

* Catch RuntimeException instead of Exception

* Revert "Catch RuntimeException instead of Exception"

Catching RuntimeExceptions isn't sufficient since checked exceptions
can be thrown in the JVM with solutions like "sneaky throws"

This reverts commit 01b5f6f9ff574e6da2951ec471a532de3dbc67cd.

* Address review comments about exception handling and AtomicReference usage

* Fix checkstyle