Package com.hazelcast.core

Examples of com.hazelcast.core.IdGenerator.newId()

39
40
41
42
43
44
45
46
47
48
49
        ServiceReference reference = context.getServiceReference("com.hazelcast.core.HazelcastInstance");
        HazelcastInstance instance = (HazelcastInstance) context.getService(reference);
        context.ungetService(reference);
        try {
            IdGenerator idGenerator = instance.getIdGenerator("cellar-smaple-generator");
            Long id = idGenerator.newId();
            topic = instance.getTopic("cellar-sample-topic");
            topic.addMessageListener(messageListener);
            topic.publish(new Message("id="+id));
        } catch (Exception ex) {
            ex.printStackTrace();
View Full Code Here
40
41
42
43
44
45
46
47
48
49
50
        IdGenerator idGenerator = createIdGenerator();

        boolean initialized = idGenerator.init(initialValue);
        assertEquals(expected, initialized);

        long newId = idGenerator.newId();
        assertEquals(expectedValue, newId);
    }

    private IdGenerator createIdGenerator() {
        return hz.getIdGenerator("id-" + UUID.randomUUID().toString());
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
    }

    @Test
    public void testInitWhenAlreadyInitialized() {
        IdGenerator idGenerator = createIdGenerator();
        long first = idGenerator.newId();

        boolean initialized = idGenerator.init(10);
        assertFalse(initialized);

        long actual = idGenerator.newId();
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
        long first = idGenerator.newId();

        boolean initialized = idGenerator.init(10);
        assertFalse(initialized);

        long actual = idGenerator.newId();
        assertEquals(first + 1, actual);
    }

    @Test
    public void testNewId_withExplicitInit() {
View Full Code Here
65
66
67
68
69
70
71
72
73
74
75
    @Test
    public void testNewId_withExplicitInit() {
        IdGenerator idGenerator =createIdGenerator();
        assertTrue(idGenerator.init(10));

        long result = idGenerator.newId();
        assertEquals(11, result);
    }

    @Test
    public void testNewId_withoutExplictInit() {
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
    }

    @Test
    public void testNewId_withoutExplictInit() {
        IdGenerator idGenerator = createIdGenerator();
        long result = idGenerator.newId();
        assertEquals(0, result);
    }

    @Test
    public void testGeneratingMultipleBlocks() {
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
    public void testGeneratingMultipleBlocks() {
        IdGenerator idGenerator = createIdGenerator();

        long expected = 0;
        for (int k = 0; k < 3 * IdGeneratorProxy.BLOCK_SIZE; k++) {
            assertEquals(expected, idGenerator.newId());
            expected++;
        }
    }

    @Test
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
    @Test
    public void testDestroy() {
        IdGenerator idGenerator = createIdGenerator();
        String id = idGenerator.getName();
        idGenerator.newId();
        idGenerator.newId();

        idGenerator.destroy();

        IdGenerator newIdGenerator = hz.getIdGenerator(id);
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
    @Test
    public void testDestroy() {
        IdGenerator idGenerator = createIdGenerator();
        String id = idGenerator.getName();
        idGenerator.newId();
        idGenerator.newId();

        idGenerator.destroy();

        IdGenerator newIdGenerator = hz.getIdGenerator(id);
        long actual = newIdGenerator.newId();
View Full Code Here
97
98
99
100
101
102
103
104
105
        idGenerator.newId();

        idGenerator.destroy();

        IdGenerator newIdGenerator = hz.getIdGenerator(id);
        long actual = newIdGenerator.newId();
        assertEquals(0, actual);
    }
}
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.