20
20
21
21
import org .junit .Ignore ;
22
22
import org .junit .Rule ;
23
+ import org .junit .Test ;
23
24
import org .junit .rules .ExpectedException ;
24
25
25
26
import java .io .IOException ;
52
53
import static org .junit .Assert .assertThat ;
53
54
import static org .junit .Assert .assertTrue ;
54
55
import static org .junit .Assert .fail ;
55
-
56
+ @ Ignore
56
57
public class ClusterDriverStubTest
57
58
{
58
59
@ Rule
59
60
public ExpectedException exception = ExpectedException .none ();
60
61
61
62
private static final Config config = Config .build ().withLogging ( new ConsoleLogging ( Level .INFO ) ).toConfig ();
62
63
63
- @ Ignore
64
+ @ Test
64
65
public void shouldDiscoverServers () throws IOException , InterruptedException , StubServer .ForceKilled
65
66
{
66
67
// Given
@@ -82,7 +83,7 @@ public void shouldDiscoverServers() throws IOException, InterruptedException, St
82
83
assertThat ( server .exitStatus (), equalTo ( 0 ) );
83
84
}
84
85
85
- @ Ignore
86
+ @ Test
86
87
public void shouldDiscoverNewServers () throws IOException , InterruptedException , StubServer .ForceKilled
87
88
{
88
89
// Given
@@ -105,7 +106,7 @@ public void shouldDiscoverNewServers() throws IOException, InterruptedException,
105
106
assertThat ( server .exitStatus (), equalTo ( 0 ) );
106
107
}
107
108
108
- @ Ignore
109
+ @ Test
109
110
public void shouldHandleEmptyResponse () throws IOException , InterruptedException , StubServer .ForceKilled
110
111
{
111
112
// Given
@@ -122,7 +123,7 @@ public void shouldHandleEmptyResponse() throws IOException, InterruptedException
122
123
assertThat ( server .exitStatus (), equalTo ( 0 ) );
123
124
}
124
125
125
- @ Ignore
126
+ @ Test
126
127
public void shouldHandleAcquireReadSession () throws IOException , InterruptedException , StubServer .ForceKilled
127
128
{
128
129
// Given
@@ -151,7 +152,7 @@ public String apply( Record record )
151
152
assertThat ( readServer .exitStatus (), equalTo ( 0 ) );
152
153
}
153
154
154
- @ Ignore
155
+ @ Test
155
156
public void shouldRoundRobinReadServers () throws IOException , InterruptedException , StubServer .ForceKilled
156
157
{
157
158
// Given
@@ -185,7 +186,7 @@ public String apply( Record record )
185
186
assertThat ( readServer2 .exitStatus (), equalTo ( 0 ) );
186
187
}
187
188
188
- @ Ignore
189
+ @ Test
189
190
public void shouldThrowSessionExpiredIfReadServerDisappears ()
190
191
throws IOException , InterruptedException , StubServer .ForceKilled
191
192
{
@@ -208,7 +209,7 @@ public void shouldThrowSessionExpiredIfReadServerDisappears()
208
209
assertThat ( server .exitStatus (), equalTo ( 0 ) );
209
210
}
210
211
211
- @ Ignore
212
+ @ Test
212
213
public void shouldThrowSessionExpiredIfWriteServerDisappears ()
213
214
throws IOException , InterruptedException , StubServer .ForceKilled
214
215
{
@@ -231,7 +232,7 @@ public void shouldThrowSessionExpiredIfWriteServerDisappears()
231
232
assertThat ( server .exitStatus (), equalTo ( 0 ) );
232
233
}
233
234
234
- @ Ignore
235
+ @ Test
235
236
public void shouldHandleAcquireWriteSession () throws IOException , InterruptedException , StubServer .ForceKilled
236
237
{
237
238
// Given
@@ -250,7 +251,7 @@ public void shouldHandleAcquireWriteSession() throws IOException, InterruptedExc
250
251
assertThat ( writeServer .exitStatus (), equalTo ( 0 ) );
251
252
}
252
253
253
- @ Ignore
254
+ @ Test
254
255
public void shouldRoundRobinWriteSessions () throws IOException , InterruptedException , StubServer .ForceKilled
255
256
{
256
257
// Given
@@ -276,7 +277,7 @@ public void shouldRoundRobinWriteSessions() throws IOException, InterruptedExcep
276
277
assertThat ( writeServer2 .exitStatus (), equalTo ( 0 ) );
277
278
}
278
279
279
- @ Ignore
280
+ @ Test
280
281
public void shouldRememberEndpoints () throws IOException , InterruptedException , StubServer .ForceKilled
281
282
{
282
283
// Given
@@ -305,7 +306,7 @@ public void shouldRememberEndpoints() throws IOException, InterruptedException,
305
306
assertThat ( readServer .exitStatus (), equalTo ( 0 ) );
306
307
}
307
308
308
- @ Ignore
309
+ @ Test
309
310
public void shouldForgetEndpointsOnFailure () throws IOException , InterruptedException , StubServer .ForceKilled
310
311
{
311
312
// Given
@@ -336,7 +337,7 @@ public void shouldForgetEndpointsOnFailure() throws IOException, InterruptedExce
336
337
assertThat ( server .exitStatus (), equalTo ( 0 ) );
337
338
}
338
339
339
- @ Ignore
340
+ @ Test
340
341
public void shouldRediscoverIfNecessaryOnSessionAcquisition () throws IOException , InterruptedException , StubServer .ForceKilled
341
342
{
342
343
// Given
@@ -366,7 +367,7 @@ public void shouldRediscoverIfNecessaryOnSessionAcquisition() throws IOException
366
367
assertThat ( server .exitStatus (), equalTo ( 0 ) );
367
368
}
368
369
369
- @ Ignore
370
+ @ Test
370
371
public void shouldOnlyGetServersOnce () throws IOException , InterruptedException , StubServer .ForceKilled
371
372
{
372
373
// Given
@@ -412,7 +413,7 @@ public void run()
412
413
assertThat ( server .exitStatus (), equalTo ( 0 ) );
413
414
}
414
415
415
- @ Ignore
416
+ @ Test
416
417
public void shouldFailOnNonDiscoverableServer () throws IOException , InterruptedException , StubServer .ForceKilled
417
418
{
418
419
// When
@@ -435,7 +436,7 @@ public void shouldFailOnNonDiscoverableServer() throws IOException, InterruptedE
435
436
assertThat ( server .exitStatus (), equalTo ( 0 ) );
436
437
}
437
438
438
- @ Ignore
439
+ @ Test
439
440
public void shouldHandleLeaderSwitchWhenWriting ()
440
441
throws IOException , InterruptedException , StubServer .ForceKilled
441
442
{
@@ -477,4 +478,4 @@ String resource( String fileName )
477
478
}
478
479
return resource .getFile ();
479
480
}
480
- }
481
+ }
0 commit comments