import org.apache.nifi.annotation.lifecycle.OnDisabled; //导入依赖的package包/类
@OnDisabled
public void shutdown() {
    this.closed = true;

    CommsSession commsSession;
    while ((commsSession = queue.poll()) != null) {
        try (final DataOutputStream dos = new DataOutputStream(commsSession.getOutputStream())) {
            dos.writeUTF("close");
            dos.flush();
            commsSession.close();
        } catch (final IOException e) { /* empty */ }
    }
    if (logger.isDebugEnabled() && getIdentifier() != null) {
        logger.debug("Closed {}", new Object[]{getIdentifier()});
    }
}
 

import org.apache.nifi.annotation.lifecycle.OnDisabled; //导入依赖的package包/类
@OnDisabled
public void shutdownServer() {
    if (httpServer != null) {
        httpServer.close(res -> {
            if (res.succeeded()) {
                getLogger().info("server stopped");
            } else {
                getLogger().error("server stop failed!");
            }
        });
    }
    if (eventBus != null) {
        eventBus.close(res -> {
            if (res.succeeded()) {
                getLogger().info("eventBus closed");
            } else {
                getLogger().error("eventBus close failed!");
            }
        });
    }
    if (vertx != null) {
        vertx.close();
    }
}
 

import org.apache.nifi.annotation.lifecycle.OnDisabled; //导入依赖的package包/类
@OnDisabled
public void shutdown() {
    if (cache != null) {
        cache.removeAll();
    }
    cache = null;
}
 

import org.apache.nifi.annotation.lifecycle.OnDisabled; //导入依赖的package包/类
@OnDisabled
public void stop() throws IOException {
    stopServer();

    cache.removeAll();
    cache = null;
}
 

import org.apache.nifi.annotation.lifecycle.OnDisabled; //导入依赖的package包/类
@OnDisabled
public void onDisabled() {
    try {
        mongoClient.close();
    } catch (final Exception e) {
        throw new ProcessException(e);
    }
}
 

import org.apache.nifi.annotation.lifecycle.OnDisabled; //导入依赖的package包/类
@OnDisabled
public void shutdown() {
    try {
        driver.close();
    } catch (final Neo4jException e) {
        throw new ProcessException(e);
    }
}
 

import org.apache.nifi.annotation.lifecycle.OnDisabled; //导入依赖的package包/类
/**
 *
 */
@OnDisabled
public void disable() {
    this.connectionFactory = null;
    this.configured = false;
}
 

import org.apache.nifi.annotation.lifecycle.OnDisabled; //导入依赖的package包/类
@OnDisabled
public void shutdown() {
    if (connector != null) {
        connector = null;
    }
}
 

import org.apache.nifi.annotation.lifecycle.OnDisabled; //导入依赖的package包/类
@OnDisabled
public void shutdown() {

}