Changing submit to execute in different providers for exception throwing
Change-Id: I2d93b365640e3be48de913e1a069d5f5a53eb303
diff --git a/providers/snmp/device/src/main/java/org/onosproject/provider/snmp/device/impl/SnmpDeviceProvider.java b/providers/snmp/device/src/main/java/org/onosproject/provider/snmp/device/impl/SnmpDeviceProvider.java
index 51e5fd1..316b3ba 100644
--- a/providers/snmp/device/src/main/java/org/onosproject/provider/snmp/device/impl/SnmpDeviceProvider.java
+++ b/providers/snmp/device/src/main/java/org/onosproject/provider/snmp/device/impl/SnmpDeviceProvider.java
@@ -92,7 +92,7 @@
protected ComponentConfigService cfgService;
private final ExecutorService deviceBuilder = Executors
- .newFixedThreadPool(1, groupedThreads("onos/snmp", "device-creator"));
+ .newFixedThreadPool(1, groupedThreads("onos/snmp", "device-creator", log));
// Delay between events in ms.
private static final int EVENTINTERVAL = 5;
@@ -140,7 +140,7 @@
try {
snmpDeviceMap
.entrySet().stream().forEach((deviceEntry) -> {
- deviceBuilder.submit(new DeviceCreator(deviceEntry.getValue(), false));
+ deviceBuilder.execute(new DeviceCreator(deviceEntry.getValue(), false));
});
deviceBuilder.awaitTermination(1000, TimeUnit.MILLISECONDS);
} catch (InterruptedException e) {
@@ -184,9 +184,9 @@
device.getDeviceState().name()}
);
if (device.isActive()) {
- deviceBuilder.submit(new DeviceCreator(device, true));
+ deviceBuilder.execute(new DeviceCreator(device, true));
} else {
- deviceBuilder.submit(new DeviceCreator(device, false));
+ deviceBuilder.execute(new DeviceCreator(device, false));
}
}
}