class RedisConnect implements CacheCloseable {

    private final StatefulConnection<String, String> connection;

    public RedisConnect(StatefulConnection<String, String> connection) {
        this.connection = connection;
    }

    @Override
    public void close() {<FILL_FUNCTION_BODY>}

    public StatefulConnection<String, String> getConnection() {
        return connection;
    }
}

        try {
            if (connection != null) {
                connection.closeAsync();
            }
        } catch (Exception e) {
            log.error("[connection common cache] close redis connect error: {}", e.getMessage());
        }
    
<no_super_class>