import io.netty.util.TimerTask;
import java.net.InetSocketAddress;
import java.util.List;
-import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
+import org.junit.After;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
@Mock
private SchemaResourceManager schemaManager;
@Mock
- private Executor processingExecutor;
- @Mock
private DeviceActionFactory deviceActionFactory;
@Mock
private RemoteDeviceHandler delegate;
@Mock
private EffectiveModelContext schemaContext;
+ private NetconfTopologySchemaAssembler schemaAssembler;
private NetconfNodeHandler handler;
@BeforeClass
@Before
public void before() {
+ schemaAssembler = new NetconfTopologySchemaAssembler(1, 1, 0, TimeUnit.SECONDS);
+
// Instantiate the handler
- handler = new NetconfNodeHandler(clientFactory, timer, BASE_SCHEMAS, schemaManager, processingExecutor,
+ handler = new NetconfNodeHandler(clientFactory, timer, BASE_SCHEMAS, schemaManager, schemaAssembler,
new NetconfClientConfigurationBuilderFactoryImpl(encryptionService, credentialProvider,
sslHandlerFactoryProvider),
deviceActionFactory, delegate, DEVICE_ID, NODE_ID, new NetconfNodeBuilder()
.build(), null);
}
+ @After
+ public void after() {
+ schemaAssembler.close();
+ }
+
@Test
public void successfulOnDeviceConnectedPropagates() throws Exception {
assertSuccessfulConnect();