import org.apache.nifi.annotation.lifecycle.OnStopped; //导入依赖的package包/类
/**
 * Will destroy the instance of {@link CachingConnectionFactory} and sets
 * 'targetResource' to null;
 */
@OnStopped
public void close() {
    if (this.cachingConnectionFactory != null) {
        this.cachingConnectionFactory.destroy();
    }
    this.targetResource = null;
}
 

import org.apache.nifi.annotation.lifecycle.OnStopped; //导入依赖的package包/类
@OnStopped
public final void closeArango() {
    if (arangoDB != null) {
        getLogger().info("Closing ArangoDB");
        arangoDB.shutdown();
        arangoDB = null;
    }
}
 

import org.apache.nifi.annotation.lifecycle.OnStopped; //导入依赖的package包/类
@OnStopped
public void unregister() {
    if (consumer != null) {
        consumer.unregister(res -> {
            if (res.succeeded()) {
                getLogger().info("The GetEventBus({}) handler un-registration has reached all nodes",new Object[] {consumer.address()});
            } else {
                getLogger().info("GetEventBus({}) un-registration failed!",new Object[] {consumer.address()});
            }
        });
    }
}
 

import org.apache.nifi.annotation.lifecycle.OnStopped; //导入依赖的package包/类
@OnStopped
public void stopConsumer() {
    try {
        RabbitMQFactory.closeConnection(connection, channel);
    } catch (Exception e) {
        getLogger().error("Error closing RabbitMQ connection: {}", new Object[]{e});
        e.printStackTrace();
    }
}
 

import org.apache.nifi.annotation.lifecycle.OnStopped; //导入依赖的package包/类
@OnStopped
public void closeProducer() {
    try {
        RabbitMQFactory.closeConnection(connection, channel);
    } catch (Exception e) {
        getLogger().error("Error closing RabbitMQ connection: {}", new Object[]{e});
        e.printStackTrace();
    }
}
 

import org.apache.nifi.annotation.lifecycle.OnStopped; //导入依赖的package包/类
@OnStopped
public void cleanup() {
    // close all connections
    closeConnections(true);
}
 

import org.apache.nifi.annotation.lifecycle.OnStopped; //导入依赖的package包/类
@OnStopped
public void onStopped() {
    driver.quit();
}
 

import org.apache.nifi.annotation.lifecycle.OnStopped; //导入依赖的package包/类
/**
 * Whenever processor is stopped, remove cached indexes
 */
@OnStopped
public void cleanUp() {
    indexes.clear();
}
 

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

import org.apache.nifi.annotation.lifecycle.OnStopped; //导入依赖的package包/类
@OnStopped
public void stop() {
    scriptingComponentHelper.stop();
}
 

import org.apache.nifi.annotation.lifecycle.OnStopped; //导入依赖的package包/类
@OnStopped
public void closeRedisPool(final ProcessContext context) {
	jedisPool.destroy();
}