diff options
Diffstat (limited to 'ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/messagemgr/MessageChannel.java')
-rw-r--r-- | ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/messagemgr/MessageChannel.java | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/messagemgr/MessageChannel.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/messagemgr/MessageChannel.java index 7ee159e..30d61d6 100644 --- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/messagemgr/MessageChannel.java +++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/messagemgr/MessageChannel.java @@ -18,6 +18,7 @@ package org.onap.vfc.nfvo.emsdriver.messagemgr; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.TimeUnit; +import java.io.IOException; public class MessageChannel { @@ -26,17 +27,17 @@ public class MessageChannel { public MessageChannel(int size) { if (size > 0) { - queue = new LinkedBlockingQueue<Object>(size); + queue = new LinkedBlockingQueue<>(size); } else { - queue = new LinkedBlockingQueue<Object>(); + queue = new LinkedBlockingQueue<>(); } } public MessageChannel() { - queue = new LinkedBlockingQueue<Object>(); + queue = new LinkedBlockingQueue<>(); } - public void put(Object msg) throws InterruptedException { + public void put(Object msg) throws IOException { while (!queue.offer(msg)) { queue.poll(); } |