Package com.arms.config

## Class KafkaShutdownManager

- java.lang.Object
- - com.arms.config.KafkaShutdownManager

-     @Component
      public class KafkaShutdownManager
      extends java.lang.Object

- - ### Constructor Summary

    Constructors
    Constructor | Description
    --- | ---
    `KafkaShutdownManager​(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)` |

  - ### Method Summary

    All Methods Instance Methods Concrete Methods
    Modifier and Type | Method | Description
    --- | --- | ---
    `void` | `acceptTraffic()` |
    `void` | `refusingTraffic()` |
    `void` | `waitForAWhileFromRefusingTraffic​(org.springframework.boot.availability.AvailabilityChangeEvent<org.springframework.boot.availability.ReadinessState> readiness)` |

    - ### Methods inherited from class java.lang.Object

      `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- - ### Constructor Detail

    - #### KafkaShutdownManager

          public KafkaShutdownManager​(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)

  - ### Method Detail

    - #### refusingTraffic

          public void refusingTraffic()

    - #### acceptTraffic

          public void acceptTraffic()

    - #### waitForAWhileFromRefusingTraffic

          @Async
          @EventListener
          public void waitForAWhileFromRefusingTraffic​(org.springframework.boot.availability.AvailabilityChangeEvent<org.springframework.boot.availability.ReadinessState> readiness)
                                                throws java.lang.InterruptedException

      Throws:
        `java.lang.InterruptedException`