Parameterizing callback is not necessary. Client can use its reader as a reference point, here is example of reading increments only:

    public static void main(String[] args) throws Exception {
        JournalFactory factory = new JournalFactory(args[0]);
        final JournalClient client = new JournalClient(factory);

        final Journal<Price> reader = factory.bulkReader(Price.class, "price-copy");

        client.subscribe(Price.class, null, "price-copy", new TxListener() {
            @Override
            public void onCommit() {
                int count = 0;
                long t = 0;
                for (Price p : reader.incrementBuffered()) {
                    if (count == 0) {
                        t = p.getTimestamp();
                    }
                    count++;
                }
                System.out.println("took: "
                                + (System.currentTimeMillis() - t) 
                                + ", count=" + count);
            }
        });
        client.start();
        System.out.println("Client started");
    }

Parameterize TxListener.onCommit() #4

Description

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions