summaryrefslogtreecommitdiffstats
path: root/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadService.java
diff options
context:
space:
mode:
Diffstat (limited to 'ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadService.java')
-rw-r--r--ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadService.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadService.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadService.java
index 848de63..1b8963f 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadService.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadService.java
@@ -75,7 +75,7 @@ public class TaskThreadService extends Thread {
public CollectMsg receive() {
try {
return queue.poll(100, TimeUnit.MILLISECONDS);
- } catch (InterruptedException e) {
+ } catch (Exception e) {
log.error("queue.poll is error" + StringUtil.getStackTrace(e));
}
return null;
@@ -85,7 +85,7 @@ public class TaskThreadService extends Thread {
public void add(CollectMsg data) {
try {
queue.put(data);
- } catch (InterruptedException e) {
+ } catch (Exception e) {
log.error("queue.put is error" + StringUtil.getStackTrace(e));
}
}