Package org.agilewiki.jfile.transactions.db

Examples of org.agilewiki.jfile.transactions.db.OpenDbFile.send()

36
37
38
39
40
41
42
43
44
45
46
        AggregateTransaction aggregateIncrementTransaction =
                IncrementIntegerTransactionFactory.at(factoryMailbox, "counter");

        IMDB db1 = new IMDB(mailboxFactory, factory, directoryPath);
        db1.clearDirectory();
        openDbFile.send(future, db1);
        TransactionAggregator transactionAggregator1 = db1.getTransactionAggregator();

        TransactionAggregatorDriver transactionAggregatorDriver =
                new TransactionAggregatorDriver();
        transactionAggregatorDriver.initialize(mailboxFactory.createAsyncMailbox(), transactionAggregator1);
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
                GetIntegerTransactionFactory.at(factoryMailbox, "counter");

        System.out.println("db1");
        IMDB db1 = new IMDB(mailboxFactory, factory, directoryPath);
        db1.clearDirectory();
        openDbFile.send(future, db1);
        System.out.println("online");
        TransactionAggregator transactionAggregator1 = db1.getTransactionAggregator();
        aggregateIncrementTransaction.sendEvent(transactionAggregator1);
        int total1 = (Integer) aggregateGetTransaction.send(future, transactionAggregator1);
        assertEquals(1, total1);
View Full Code Here
46
47
48
49
50
51
52
53
54
55
56
        assertEquals(1, total1);
        db1.closeDbFile();

        System.out.println("db2");
        IMDB db2 = new IMDB(mailboxFactory, factory, directoryPath);
        openDbFile.send(future, db2);
        System.out.println("online");
        TransactionAggregator transactionAggregator2 = db2.getTransactionAggregator();
        aggregateIncrementTransaction.sendEvent(transactionAggregator2);
        aggregateIncrementTransaction.sendEvent(transactionAggregator2);
        int total2 = (Integer) aggregateGetTransaction.send(future, transactionAggregator2);
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
        assertEquals(3, total2);
        db2.closeDbFile();

        System.out.println("db3");
        IMDB db3 = new IMDB(mailboxFactory, factory, directoryPath);
        openDbFile.send(future, db3);
        System.out.println("online");
        TransactionAggregator transactionAggregator3 = db3.getTransactionAggregator();
        aggregateIncrementTransaction.sendEvent(transactionAggregator3);
        aggregateIncrementTransaction.sendEvent(transactionAggregator3);
        aggregateAddTransaction.sendEvent(transactionAggregator3);
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.