29
29
30
30
import org .springframework .integration .support .MessageBuilder ;
31
31
import org .springframework .jdbc .core .JdbcTemplate ;
32
- import org .springframework .jdbc .core .RowMapper ;
33
32
import org .springframework .jdbc .datasource .embedded .EmbeddedDatabase ;
34
33
import org .springframework .jdbc .datasource .embedded .EmbeddedDatabaseBuilder ;
35
34
import org .springframework .jdbc .datasource .embedded .EmbeddedDatabaseType ;
36
35
37
36
/**
38
37
* @author Gunnar Hillert
38
+ * @author Artem Bilan
39
39
*/
40
40
public class JdbcMessageStoreRegionTests {
41
41
42
42
private static EmbeddedDatabase dataSource ;
43
+
43
44
private JdbcTemplate jdbcTemplate ;
44
45
45
46
private JdbcMessageStore messageStore1 ;
47
+
46
48
private JdbcMessageStore messageStore2 ;
47
49
48
50
@ BeforeClass
49
51
public static void setupDatabase () {
50
52
dataSource = new EmbeddedDatabaseBuilder ()
51
53
.setType (EmbeddedDatabaseType .H2 )
54
+ .addScript ("classpath:/org/springframework/integration/jdbc/schema-drop-h2.sql" )
52
55
.addScript ("classpath:/org/springframework/integration/jdbc/schema-h2.sql" )
53
56
.build ();
54
57
}
@@ -76,7 +79,7 @@ public void afterTest() {
76
79
}
77
80
78
81
@ Test
79
- public void testVerifyMessageCount () throws Exception {
82
+ public void testVerifyMessageCount () {
80
83
81
84
messageStore1 .addMessage (MessageBuilder .withPayload ("payload1" ).build ());
82
85
messageStore1 .addMessage (MessageBuilder .withPayload ("payload2" ).build ());
@@ -90,7 +93,7 @@ public void testVerifyMessageCount() throws Exception {
90
93
}
91
94
92
95
@ Test
93
- public void testInsertNullRegion () throws Exception {
96
+ public void testInsertNullRegion () {
94
97
95
98
try {
96
99
messageStore1 .setRegion (null );
@@ -104,7 +107,7 @@ public void testInsertNullRegion() throws Exception {
104
107
}
105
108
106
109
@ Test
107
- public void testVerifyMessageGroupCount () throws Exception {
110
+ public void testVerifyMessageGroupCount () {
108
111
109
112
messageStore1 .addMessageToGroup ("group1" , MessageBuilder .withPayload ("payload1" ).build ());
110
113
messageStore1 .addMessageToGroup ("group2" , MessageBuilder .withPayload ("payload2" ).build ());
@@ -123,28 +126,28 @@ public void testVerifyMessageGroupCount() throws Exception {
123
126
}
124
127
125
128
@ Test
126
- public void testRegionSetToMessageGroup () throws Exception {
129
+ public void testRegionSetToMessageGroup () {
127
130
128
131
messageStore1 .addMessageToGroup ("group1" , MessageBuilder .withPayload ("payload1" ).build ());
129
132
130
133
List <String > regions = jdbcTemplate .query ("Select * from INT_MESSAGE_GROUP where REGION = 'region1'" ,
131
- (RowMapper < String >) ( rs , rowNum ) -> rs .getString ("REGION" ));
134
+ (rs , rowNum ) -> rs .getString ("REGION" ));
132
135
133
136
assertThat (regions .size ()).isEqualTo (1 );
134
137
assertThat (regions .get (0 )).isEqualTo ("region1" );
135
138
136
139
messageStore2 .addMessageToGroup ("group1" , MessageBuilder .withPayload ("payload1" ).build ());
137
140
138
141
List <String > regions2 = jdbcTemplate .query ("Select * from INT_MESSAGE_GROUP where REGION = 'region2'" ,
139
- (RowMapper < String >) ( rs , rowNum ) -> rs .getString ("REGION" ));
142
+ (rs , rowNum ) -> rs .getString ("REGION" ));
140
143
141
144
assertThat (regions2 .size ()).isEqualTo (1 );
142
145
assertThat (regions2 .get (0 )).isEqualTo ("region2" );
143
146
144
147
}
145
148
146
149
@ Test
147
- public void testRemoveMessageGroup () throws Exception {
150
+ public void testRemoveMessageGroup () {
148
151
149
152
messageStore1 .addMessageToGroup ("group1" , MessageBuilder .withPayload ("payload1" ).build ());
150
153
messageStore1 .addMessageToGroup ("group2" , MessageBuilder .withPayload ("payload2" ).build ());
@@ -158,4 +161,5 @@ public void testRemoveMessageGroup() throws Exception {
158
161
assertThat (messageStore2 .getMessageGroupCount ()).isEqualTo (2 );
159
162
160
163
}
164
+
161
165
}
0 commit comments