Merge pull request #852 from ashanhr/5.3.x

Author: tharindu1st

components/data-bridge/org.wso2.carbon.databridge.core/src/main/java/org/wso2/carbon/databridge/core/internal/queue/EventBlockingQueue.java

@@ -81,9 +81,9 @@ public synchronized void put(EventComposite eventComposite) {
     public EventComposite poll() {
         EventComposite eventComposite = super.poll();
         currentSize.addAndGet(-eventComposite.getSize());
-        if (semaphore.availablePermits() == 0 && ((currentEventCompositeSize + currentSize.get()) < maxSize) || isEmpty()) {
+        if (semaphore.availablePermits() == 0 && (((currentEventCompositeSize + currentSize.get()) < maxSize) || isEmpty())) {
             synchronized (lock) {
-                if (semaphore.availablePermits() == 0 && ((currentEventCompositeSize + currentSize.get()) < maxSize) || isEmpty()) {
+                if (semaphore.availablePermits() == 0 && (((currentEventCompositeSize + currentSize.get()) < maxSize) || isEmpty())) {
                     semaphore.release();
                 }
             }