Examples of deleteAllMessages()

Examples of org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter.deleteAllMessages()

27
28
29
30
31
32
33
34
35
36
37
    @Override
    protected PersistenceAdapter createPersistenceAdapter(boolean delete) throws Exception {
        KahaDBPersistenceAdapter adapter = new KahaDBPersistenceAdapter();
        adapter.setConcurrentStoreAndDispatchQueues(false);
        adapter.setConcurrentStoreAndDispatchTopics(false);
        adapter.deleteAllMessages();
        return adapter;
    }
   
    public static Test suite() {
        return suite(KahaDBMessagePriorityTest.class);
View Full Code Here

Examples of org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter.deleteAllMessages()

65
66
67
68
69
70
71
72
73
74
75
    protected KahaDBPersistenceAdapter createStore(boolean delete) throws IOException {
        KahaDBPersistenceAdapter kaha = new KahaDBPersistenceAdapter();
        kaha.setJournalMaxFileLength(maxFileLength);
        kaha.setCleanupInterval(5000);
        if (delete) {
            kaha.deleteAllMessages();
        }
        return kaha;
    }

    @Before
View Full Code Here

Examples of org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter.deleteAllMessages()

77
78
79
80
81
82
83
84
85
86
87
        KahaDBPersistenceAdapter kahadb = new KahaDBPersistenceAdapter();
        kahadb.setCheckForCorruptJournalFiles(true);
        kahadb.setCleanupInterval(1000);

        kahadb.deleteAllMessages();
        broker.setPersistenceAdapter(kahadb);
        broker.getSystemUsage().getMemoryUsage().setLimit(1024*1024*100);
        broker.setUseJmx(false);

        return broker;
View Full Code Here

Examples of org.apache.activemq.store.kahadb.KahaDBStore.deleteAllMessages()

41
42
43
44
45
46
47
48
49
50
51
        master.setPersistent(false);
        master.addConnector("tcp://localhost:0");

        KahaDBStore kaha = new KahaDBStore();
        kaha.setDirectory(new File("target/activemq-data/kahadb"));
        kaha.deleteAllMessages();
        master.setPersistenceAdapter(kaha);

        this.master = master;
    }
View Full Code Here

Examples of org.apache.activemq.store.kahadb.KahaDBStore.deleteAllMessages()

50
51
52
53
54
55
56
57
58
59
60
        BrokerService broker = new BrokerService();
        KahaDBStore kaha = new KahaDBStore();
        File directory = new File("target/activemq-data/kahadb");
        IOHelper.deleteChildren(directory);
        kaha.setDirectory(directory);
        kaha.deleteAllMessages();
        broker.setPersistenceAdapter(kaha);
        return broker;
    }

    protected ConnectionFactory createConnectionFactory() {
View Full Code Here

Examples of org.apache.activemq.store.kahadb.KahaDBStore.deleteAllMessages()

59
60
61
62
63
64
65
66
67
68
69
                LOG.info("Test KahaDB class is completed its start()");
            }
        };

        kaha.setDirectory(new File("target/activemq-data/kahadb"));
        kaha.deleteAllMessages();

        broker.setPersistenceAdapter(kaha);
        broker.setUseJmx(true);

        return broker;
View Full Code Here

Examples of org.apache.activemq.store.kahadb.KahaDBStore.deleteAllMessages()

221
222
223
224
225
226
227
228
229
    protected void configurePersistenceAdapter(BrokerService broker) throws IOException {
        File dataFileDir = new File("target/test-amq-data/kahadb/" + broker.getBrokerName());
        KahaDBStore kaha = new KahaDBStore();
        kaha.setDirectory(dataFileDir);
        kaha.deleteAllMessages();
        broker.setPersistenceAdapter(kaha);
    }
}
View Full Code Here

Examples of org.apache.activemq.store.kahadb.KahaDBStore.deleteAllMessages()

59
60
61
62
63
64
65
66
67
68
69
                LOG.info("Test KahaDB class is completed its start()");
            }
        };

        kaha.setDirectory(new File("target/activemq-data/kahadb"));
        kaha.deleteAllMessages();

        broker.setPersistenceAdapter(kaha);
        broker.setUseJmx(true);

        return broker;
View Full Code Here

Examples of org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter.deleteAllMessages()

121
122
123
124
125
126
127
128
129
130
131
    public void prepareBrokerWithMultiStore(boolean deleteAllMessages) throws Exception {

        MultiKahaDBPersistenceAdapter multiKahaDBPersistenceAdapter = new MultiKahaDBPersistenceAdapter();
        if (deleteAllMessages) {
            multiKahaDBPersistenceAdapter.deleteAllMessages();
        }
        ArrayList<FilteredKahaDBPersistenceAdapter> adapters = new ArrayList<FilteredKahaDBPersistenceAdapter>();

        adapters.add(createFilteredKahaDBByDestinationPrefix(PREFIX_DESTINATION_NAME, deleteAllMessages));
        adapters.add(createFilteredKahaDBByDestinationPrefix(PREFIX_DESTINATION_NAME + "2", deleteAllMessages));
View Full Code Here

Examples of org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter.deleteAllMessages()

79
80
81
82
83
84
85
86
87
88
89
    public void prepareBrokerWithMultiStore(boolean deleteAllMessages) throws Exception {

        MultiKahaDBPersistenceAdapter multiKahaDBPersistenceAdapter = new MultiKahaDBPersistenceAdapter();
        if (deleteAllMessages) {
            multiKahaDBPersistenceAdapter.deleteAllMessages();
        }
        ArrayList<FilteredKahaDBPersistenceAdapter> adapters = new ArrayList<FilteredKahaDBPersistenceAdapter>();

        FilteredKahaDBPersistenceAdapter theRest = new FilteredKahaDBPersistenceAdapter();
        theRest.setPersistenceAdapter(createStore(deleteAllMessages));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.