Package org.apache.ace.repository.ext.impl

Examples of org.apache.ace.repository.ext.impl.FilebasedBackupRepository

274
275
276
277
278
279
280
     */
    private CachedRepository getCachedRepositoryFromPreferences(User user, Repository repository) throws IOException {
        long mostRecentVersion = m_repositoryPrefs.getLong("version", CachedRepositoryImpl.UNCOMMITTED_VERSION);
        File current = getFileFromPreferences(PREFS_LOCAL_FILE_CURRENT);
        File backup = getFileFromPreferences(PREFS_LOCAL_FILE_BACKUP);
        return new CachedRepositoryImpl(user, repository, new FilebasedBackupRepository(current, backup), mostRecentVersion);
    }
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
            String fileRoot = FILE_ROOT + File.separator + customer + File.separator + name + File.separator;

            File local = getFile(fileRoot + "local");
            File backup = getFile(fileRoot + "backup");
            m_backup = new FilebasedBackupRepository(local, backup);
           
            m_properties = getFile(fileRoot + "properties");
           
            m_repoFilter = "(&(customer=" + customer + ")(name=" + name + "))";
        }
View Full Code Here
515
516
517
518
519
520
521
     * @throws IOException
     */
    private BackupRepository getBackupFromPreferences(Preferences repositoryPrefs) throws IOException {
        File current = getFileFromPreferences(repositoryPrefs, PREFS_LOCAL_FILE_CURRENT);
        File backup = getFileFromPreferences(repositoryPrefs, PREFS_LOCAL_FILE_BACKUP);
        return new FilebasedBackupRepository(current, backup);
    }
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
        File current = File.createTempFile("testFilebasedBackupRepository", null);
        File backup = File.createTempFile("testFilebasedBackupRepository", null);
        current.deleteOnExit();
        backup.deleteOnExit();

        FilebasedBackupRepository rep = new FilebasedBackupRepository(current, backup);

        byte[] testContent = new byte[] {'i', 'n', 'i', 't', 'i', 'a', 'l'};

        // write initial content
        rep.write(new ByteArrayInputStream(testContent));

        // read initial content
        InputStream input = rep.read();
        byte[] inputBytes = AdminTestUtil.copy(input);
        assert AdminTestUtil.byteArraysEqual(inputBytes, testContent) : "We got something different than 'initial' from read: " + new String(inputBytes);

        // backup what's in the repository
        rep.backup();

        // write new content
        byte[] newTestContent = new byte[] {'n', 'e', 'w'};
        rep.write(new ByteArrayInputStream(newTestContent));

        // read current content
        input = rep.read();
        inputBytes = AdminTestUtil.copy(input);
        assert AdminTestUtil.byteArraysEqual(inputBytes, newTestContent) : "We got something different than 'new' from read: " + new String(inputBytes);

        // revert to previous (initial) content
        rep.restore();

        // read current content
        input = rep.read();
        inputBytes = AdminTestUtil.copy(input);
        assert AdminTestUtil.byteArraysEqual(inputBytes, testContent) : "We got something different than 'initial' from read: " + new String(inputBytes);
    }
View Full Code Here
436
437
438
439
440
441
442
443
444
445
446
            String name = getNotNull(settings, NAME, "RepositoryName not configured.");
            String customer = getNotNull(settings, CUSTOMER, "RepositoryCustomer not configured.");

            // create the remote repository and set it.
            try {
                BackupRepository backup = new FilebasedBackupRepository(File.createTempFile("currentrepository", null), File.createTempFile("backuprepository", null));

                // We always create the remote repository. If we can create a backup repository, we will wrap a CachedRepository
                // around it.
                m_directRepository = new RemoteRepository(new URL(url), customer, name);
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
            String fileRoot = FILE_ROOT + File.separator + customer + File.separator + name + File.separator;

            File local = getFile(fileRoot + "local");
            File backup = getFile(fileRoot + "backup");
            m_backup = new FilebasedBackupRepository(local, backup);

            m_properties = getFile(fileRoot + "properties");

            m_repoFilter = "(&(customer=" + customer + ")(name=" + name + "))";
        }
View Full Code Here
558
559
560
561
562
563
564
     * @throws IOException
     */
    private BackupRepository getBackupFromPreferences(Preferences repositoryPrefs) throws IOException {
        File current = getFileFromPreferences(repositoryPrefs, PREFS_LOCAL_FILE_CURRENT);
        File backup = getFileFromPreferences(repositoryPrefs, PREFS_LOCAL_FILE_BACKUP);
        return new FilebasedBackupRepository(current, backup);
    }
View Full Code Here
489
490
491
492
493
494
495
496
497
498
499
                }
            }
           
            // create the remote repository and set it.
            try {
                BackupRepository backup = new FilebasedBackupRepository(File.createTempFile("currentrepository", null), File.createTempFile("backuprepository", null));

                // We always create the remote repository. If we can create a backup repository, we will wrap a CachedRepository
                // around it.
                m_directRepository = new RemoteRepository(new URL(url), customer, name);
View Full Code Here
592
593
594
595
596
597
598
599
600
601
602
            //create the remote repository and set it.
            try {
                BackupRepository backup = null;
                try {
                    backup = new FilebasedBackupRepository(File.createTempFile("currentrepository", null), File.createTempFile("backuprepository", null));
                }
                catch (Exception e) {
                    m_log.log(LogService.LOG_WARNING, "Unable to create temporary files for FilebasedBackupRepository");
                }
View Full Code Here
501
502
503
504
505
506
507
     * @throws IOException
     */
    private BackupRepository getBackupFromPreferences(Preferences repositoryPrefs) throws IOException {
        File current = getFileFromPreferences(repositoryPrefs, PREFS_LOCAL_FILE_CURRENT);
        File backup = getFileFromPreferences(repositoryPrefs, PREFS_LOCAL_FILE_BACKUP);
        return new FilebasedBackupRepository(current, backup);
    }
View Full Code Here
TOP

Related Classes of org.apache.ace.repository.ext.impl.FilebasedBackupRepository

  • org.apache.ace.client.repository.impl.FilebasedBackupRepositoryTest
  • org.apache.ace.client.repository.impl.RepositoryAdminImpl
  • org.apache.ace.client.repositoryuseradmin.impl.RepositoryUserAdminImpl
  • org.apache.ace.configurator.useradmin.task.UpdateUserAdminTask
  • org.apache.ace.deployment.provider.repositorybased.RepositoryBasedProvider
  • java.io.ByteArrayInputStream
  • java.io.FileInputStream
  • java.io.FileOutputStream
  • java.io.IOException
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.