File tree Expand file tree Collapse file tree 2 files changed +5
-3
lines changed
component/src/test/java/io/siddhi/extension/store/mongodb Expand file tree Collapse file tree 2 files changed +5
-3
lines changed Original file line number Diff line number Diff line change 18
18
package io .siddhi .extension .store .mongodb ;
19
19
20
20
import io .siddhi .core .SiddhiAppRuntime ;
21
+ import io .siddhi .core .SiddhiAppRuntimeImpl ;
21
22
import io .siddhi .core .SiddhiManager ;
22
23
import io .siddhi .core .exception .SiddhiAppCreationException ;
23
24
import io .siddhi .core .stream .input .InputHandler ;
@@ -291,11 +292,11 @@ public void insertIntoMongoTableTest9() throws InterruptedException {
291
292
}
292
293
293
294
@ Test
294
- public void insertIntoMongoTableTest10 () {
295
+ public void insertIntoMongoTableTest10 () throws InterruptedException {
295
296
log .info ("insertIntoMongoTableTest10 - " +
296
297
"DASC5-967:Unprivileged user attempts to insert events to a MongoDB table successfully" );
297
298
298
- Logger siddhiAppLogger = Logger .getLogger (SiddhiAppRuntime .class );
299
+ Logger siddhiAppLogger = Logger .getLogger (SiddhiAppRuntimeImpl .class );
299
300
UnitTestAppender appender = new UnitTestAppender ();
300
301
siddhiAppLogger .addAppender (appender );
301
302
@@ -316,6 +317,7 @@ public void insertIntoMongoTableTest10() {
316
317
"insert into FooTable;" ;
317
318
SiddhiAppRuntime siddhiAppRuntime = siddhiManager .createSiddhiAppRuntime (streams + query );
318
319
siddhiAppRuntime .start ();
320
+ Thread .sleep (5000 );
319
321
320
322
if (appender .getMessages () != null ) {
321
323
AssertJUnit .assertTrue (appender .getMessages ().contains ("Error in retrieving collection names " +
Original file line number Diff line number Diff line change 45
45
</profiles >
46
46
47
47
<properties >
48
- <siddhi .version>5.0.0 </siddhi .version>
48
+ <siddhi .version>5.1.5 </siddhi .version>
49
49
<siddhi .version.range>[5.0.0,6.0.0)</siddhi .version.range>
50
50
<junit .version>4.12</junit .version>
51
51
<commons .logging.version>1.1.1</commons .logging.version>
You can’t perform that action at this time.
0 commit comments