Rename method name

NitorCreations · Apr 29, 2016 · 897f684 · 897f684
1 parent 2e83bd2
commit 897f684
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/...c/main/java/com/nitorcreations/nflow/engine/internal/executor/ThresholdBlockingQueue.java b/...c/main/java/com/nitorcreations/nflow/engine/internal/executor/ThresholdBlockingQueue.java
@@ -20,7 +20,7 @@ public ThresholdBlockingQueue(int capacity, int notifyThreshHold) {
     queue = new LinkedBlockingQueue<>(capacity);
   }
 
-  public void notifyIf() {
+  public void notifyIfNotFull() {
     int size = queue.size();
     synchronized (this) {
       if (size <= notifyThreshHold) {
@@ -47,7 +47,7 @@ public boolean offer(E e) {
   @Override
   public E poll() {
     E o = queue.poll();
-    notifyIf();
+    notifyIfNotFull();
     return o;
   }
 
@@ -79,14 +79,14 @@ public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedExcepti
   @Override
   public E take() throws InterruptedException {
     E o = queue.take();
-    notifyIf();
+    notifyIfNotFull();
     return o;
   }
 
   @Override
   public E poll(long timeout, TimeUnit unit) throws InterruptedException {
     E o = queue.poll(timeout, unit);
-    notifyIf();
+    notifyIfNotFull();
     return o;
   }
 
@@ -98,14 +98,14 @@ public int remainingCapacity() {
   @Override
   public int drainTo(Collection<? super E> c) {
     int count = queue.drainTo(c);
-    notifyIf();
+    notifyIfNotFull();
     return count;
   }
 
   @Override
   public int drainTo(Collection<? super E> c, int maxElements) {
     int count = queue.drainTo(c, maxElements);
-    notifyIf();
+    notifyIfNotFull();
     return count;
   }
 }
diff --git a/...main/java/com/nitorcreations/nflow/engine/internal/executor/WorkflowInstanceExecutor.java b/...main/java/com/nitorcreations/nflow/engine/internal/executor/WorkflowInstanceExecutor.java
@@ -37,7 +37,7 @@ public void waitUntilQueueSizeLowerThanThreshold(DateTime waitUntil) throws Inte
   }
 
   public void wakeUpDispatcherIfNeeded() {
-    queue.notifyIf();
+    queue.notifyIfNotFull();
   }
 
   public void execute(Runnable runnable) {