fix more

emc-mongoose · Sep 5, 2016 · aa1a39e · aa1a39e
1 parent 95fc66a
commit aa1a39e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/emc/mongoose/core/impl/load/executor/LoadExecutorBase.java b/src/main/java/com/emc/mongoose/core/impl/load/executor/LoadExecutorBase.java
@@ -680,7 +680,7 @@ public void put(final T item)
 			if(nodeBalancer != null) {
 				nodeBalancer.markTaskStart(nextNodeAddr);
 			}
-		} catch(final InterruptedException | RejectedExecutionException e) {
+		} catch(final InterruptedException e) {
 			if(!isInterrupted.get()) {
 				countRej.incrementAndGet();
 				LogUtil.exception(LOG, Level.DEBUG, e, "Rejected the I/O task {}", ioTask);
@@ -738,6 +738,7 @@ public int put(final List<T> srcBuff, final int from, final int to)
 			if(srcLimit > 0) {
 				countRej.addAndGet(srcLimit);
 				LOG.debug(Markers.MSG, "Rejected {} I/O tasks", srcLimit);
+				throw new RejectedExecutionException();
 			}
 			n = 0;
 		}