redis-lib/src/main/java/com/streamsets/pipeline/stage/origin/redis/BaseRedisSource.java
@Override
  public void destroy() {
    // Clean up any open resources.
    if (null != redisClient) {
      redisClient.disconnect();
      redisClient.close();
      redisClient = null;
    }
    super.destroy();
  }
@Override
  public void destroy() {
    // Clean up any open resources.
    if (null != redisClient) {
      redisClient.disconnect();
      redisClient.close();
      redisClient = null;
    }
    super.destroy();
  }
@ Override public void destroy ( ) { // Clean up any open resources. if ( null != redisClient ) { redisClient . disconnect ( ) ; redisClient . close ( ) ; redisClient = null ; } super . destroy ( ) ; }
{@inheritDoc}
{