1 package com.github.jonasrutishauser.transactional.event.api;
2
3 import static org.junit.jupiter.api.Assertions.assertEquals;
4
5 import java.util.Optional;
6
7 import org.junit.jupiter.api.Test;
8
9 class MPConfigurationTest {
10
11 @Test
12 void defaultValues() {
13 Configuration testee = new MPConfiguration();
14
15 assertEquals(Configuration.DEFAULT_ALL_IN_USE_INTERVAL, testee.getAllInUseInterval());
16 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL, testee.getMaxDispatchInterval());
17 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL / 2, testee.getInitialDispatchInterval());
18 assertEquals(Configuration.DEFAULT_TABLE_NAME, testee.getTableName());
19 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxAquire());
20 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxConcurrentDispatching());
21 }
22
23 @Test
24 void configuredAllInUseInterval() {
25 MPConfiguration testee = new MPConfiguration();
26 testee.allInUseInterval = Optional.of(Integer.valueOf(42));
27
28 assertEquals(42, testee.getAllInUseInterval());
29 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL, testee.getMaxDispatchInterval());
30 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL / 2, testee.getInitialDispatchInterval());
31 assertEquals(Configuration.DEFAULT_TABLE_NAME, testee.getTableName());
32 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxAquire());
33 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxConcurrentDispatching());
34 }
35
36 @Test
37 void configuredMaxDispatcherInterval() {
38 MPConfiguration testee = new MPConfiguration();
39 testee.maxDispatchInterval = Optional.of(Integer.valueOf(13));
40
41 assertEquals(Configuration.DEFAULT_ALL_IN_USE_INTERVAL, testee.getAllInUseInterval());
42 assertEquals(13, testee.getMaxDispatchInterval());
43 assertEquals(6, testee.getInitialDispatchInterval());
44 assertEquals(Configuration.DEFAULT_TABLE_NAME, testee.getTableName());
45 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxAquire());
46 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxConcurrentDispatching());
47 }
48
49 @Test
50 void configuredInitialDispatchInterval() {
51 MPConfiguration testee = new MPConfiguration();
52 testee.initialDispatchInterval = Optional.of(Integer.valueOf(42));
53
54 assertEquals(Configuration.DEFAULT_ALL_IN_USE_INTERVAL, testee.getAllInUseInterval());
55 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL, testee.getMaxDispatchInterval());
56 assertEquals(42, testee.getInitialDispatchInterval());
57 assertEquals(Configuration.DEFAULT_TABLE_NAME, testee.getTableName());
58 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxAquire());
59 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxConcurrentDispatching());
60 }
61
62 @Test
63 void configuredTableName() {
64 MPConfiguration testee = new MPConfiguration();
65 testee.tableName = Optional.of("someTable");
66
67 assertEquals(Configuration.DEFAULT_ALL_IN_USE_INTERVAL, testee.getAllInUseInterval());
68 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL, testee.getMaxDispatchInterval());
69 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL / 2, testee.getInitialDispatchInterval());
70 assertEquals("someTable", testee.getTableName());
71 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxAquire());
72 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxConcurrentDispatching());
73 }
74
75 @Test
76 void configuredMaxAquire() {
77 MPConfiguration testee = new MPConfiguration();
78 testee.maxAquire = Optional.of(Integer.valueOf(7));
79
80 assertEquals(Configuration.DEFAULT_ALL_IN_USE_INTERVAL, testee.getAllInUseInterval());
81 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL, testee.getMaxDispatchInterval());
82 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL / 2, testee.getInitialDispatchInterval());
83 assertEquals(Configuration.DEFAULT_TABLE_NAME, testee.getTableName());
84 assertEquals(7, testee.getMaxAquire());
85 assertEquals(Configuration.DEFAULT_MAX_CONCURRENT_DISPATCHING, testee.getMaxConcurrentDispatching());
86 }
87
88 @Test
89 void configuredMaxConcurrentDispatching() {
90 MPConfiguration testee = new MPConfiguration();
91 testee.maxConcurrentDispatching = Optional.of(Integer.valueOf(7));
92
93 assertEquals(Configuration.DEFAULT_ALL_IN_USE_INTERVAL, testee.getAllInUseInterval());
94 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL, testee.getMaxDispatchInterval());
95 assertEquals(Configuration.DEFAULT_MAX_DISPATCHER_INTERVAL / 2, testee.getInitialDispatchInterval());
96 assertEquals(Configuration.DEFAULT_TABLE_NAME, testee.getTableName());
97 assertEquals(7, testee.getMaxAquire());
98 assertEquals(7, testee.getMaxConcurrentDispatching());
99 }
100
101 }