- schemaContext = context.tryToCreateSchemaContext().get();
- datastore = new InMemoryDOMDataStore("TEST",
- MoreExecutors.sameThreadExecutor());
- datastore.onGlobalContextUpdated(schemaContext);
+ this.schemaContext = context.tryToCreateSchemaContext().get();
+
+ this.dclExecutorService = new TestDCLExecutorService(
+ SpecialExecutors.newBlockingBoundedFastThreadPool(1, 10, "DCL" ));
+
+ this.datastore = new InMemoryDOMDataStore("TEST", this.dclExecutorService);
+ this.datastore.onGlobalContextUpdated(this.schemaContext);
+ }
+
+ @After
+ public void tearDown() {
+ if( this.dclExecutorService != null ) {
+ this.dclExecutorService.shutdownNow();
+ }