Removed not needed assertNotNull before assertTrue for instanceof
https://stackoverflow.com/questions/2950319/is-null-check-needed-before-calling-instanceof
This commit is contained in:
parent
59d40251c7
commit
5aef2afb45
1 changed files with 12 additions and 14 deletions
|
|
@ -1482,7 +1482,6 @@ public class WorkerTest {
|
||||||
.recordProcessorFactory(recordProcessorFactory)
|
.recordProcessorFactory(recordProcessorFactory)
|
||||||
.config(config)
|
.config(config)
|
||||||
.build();
|
.build();
|
||||||
Assert.assertNotNull(worker.getStreamConfig().getStreamProxy());
|
|
||||||
Assert.assertTrue(worker.getStreamConfig().getStreamProxy() instanceof KinesisProxy);
|
Assert.assertTrue(worker.getStreamConfig().getStreamProxy() instanceof KinesisProxy);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -1496,7 +1495,6 @@ public class WorkerTest {
|
||||||
.config(config)
|
.config(config)
|
||||||
.kinesisProxy(kinesisProxy)
|
.kinesisProxy(kinesisProxy)
|
||||||
.build();
|
.build();
|
||||||
Assert.assertNotNull(worker.getStreamConfig().getStreamProxy());
|
|
||||||
Assert.assertTrue(worker.getStreamConfig().getStreamProxy() instanceof KinesisLocalFileProxy);
|
Assert.assertTrue(worker.getStreamConfig().getStreamProxy() instanceof KinesisLocalFileProxy);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue