Java 类javax.enterprise.context.Destroyed 实例源码

/**
 * When the deployment is unloaded unregister for recovery
 *
 * @param init a javax.servlet.ServletContext
 */
void disableRecovery(@Observes @Destroyed(ApplicationScoped.class) Object init) {
    assert lraRecoveryModule != null;

    Implementations.uninstall();
    RecoveryManager.manager().removeModule(lraRecoveryModule, false);
    lraRecoveryModule = null;

    if (LRALogger.logger.isDebugEnabled())
        LRALogger.logger.debugf("LRAServicve.disableRecovery%n");    }

void shutdown(@Observes @Destroyed(ApplicationScoped.class) Object event) {
    System.out.println(
          " _____ _       _     _                     \n"
        + "|   __| |_ _ _| |_ _| |___ _ _ _ ___       \n"
        + "|__   |   | | |  _| . | . | | | |   |_ _ _ \n"
        + "|_____|_|_|___|_| |___|___|_____|_|_|_|_|_|");
}

public void destroy(@Observes @Destroyed(ApplicationScoped.class) Object ignore) {
    log.debugf("Destroying [%s]", this.getClass().getName());
    if (feedSessionListenerProducer != null) {
        wsEndpoints.getFeedSessions().removeWsSessionListenerProducer(feedSessionListenerProducer);
    }
    if (uiClientSessionListenerProducer != null) {
        wsEndpoints.getUiClientSessions().removeWsSessionListenerProducer(uiClientSessionListenerProducer);
    }
}

public void destroy(@Observes @Destroyed(ApplicationScoped.class) Object init) {
    if (localCacheManager != null) {
        localCacheManager.stop();
    }
    if (cacheManager != null) {
        cacheManager.stop();
    }
    if (cacheManagerForIndexableCaches != null) {
        cacheManagerForIndexableCaches.stop();
    }
}

void shutdown(@Observes @Destroyed(ApplicationScoped.class) Object event) {
    System.out.println(
          " _____ _       _     _                     \n"
        + "|   __| |_ _ _| |_ _| |___ _ _ _ ___       \n"
        + "|__   |   | | |  _| . | . | | | |   |_ _ _ \n"
        + "|_____|_|_|___|_| |___|___|_____|_|_|_|_|_|");
}

public void processApplicationScopedDestroyed(
        @Observes @Destroyed(ApplicationScoped.class) ServletContext payload) {
    logger.info("destroyed the ApplicationBean");
    applicationBean.incrementCounter();
}

public void processDependentScopedDestroyed(@Observes @Destroyed(ApplicationScoped.class) ServletContext payload) {
    logger.info("destroyed the DependentBean");
}

void observeRequestDestroyed(@Observes @Destroyed(RequestScoped.class) Object event) {
    log.tracef("observeRequestDestroyed, event=%s", event);
}

public void shutdown(@Observes @Destroyed(ApplicationScoped.class) Object doesntMatter) {
    this.cacheManager.destroyCache(CONFIGURATION);
    this.cachingProvider.close();
}

public void destroy(@Observes @Destroyed(ApplicationScoped.class) Object ignore) {
    log.debugf("Destroying [%s]", this.getClass().getName());
    this.uiClientSessions.destroy();
    this.feedSessions.destroy();
}

public void destroy(@Observes @Destroyed(ApplicationScoped.class) Object init) {
    producer.close();
}

public void destroy(@Observes @Destroyed(ApplicationScoped.class) Object init) {
    consumer.shutdown();
}

public void destroy(@Observes @Destroyed(ApplicationScoped.class) Object init) {
    subscription.unsubscribe();
}

public void destroy(@Observes @Destroyed(ApplicationScoped.class) Object init) {
    Log.log(Level.FINEST, this, "CDI Shutting down kafka polling thread");
    pollingThread.cancel(true);
    Log.log(Level.FINEST, this, "CDI Closing kafka consumer.");
    consumer.close();
}

public void afterDestroyed(@Observes @Destroyed(ApplicationScoped.class) Object event) {
    future.cancel(false);
}

public void shutdown(@Observes @Destroyed(ApplicationScoped.class) Object doesntMatter) {
    this.cachingProvider.close();
}