From 1c53e626419b61147779b72cec7a48ce0ffbddee Mon Sep 17 00:00:00 2001
From: Tomasz Lelek <tomekl007@gmail.com>
Date: Tue, 25 Apr 2017 09:44:59 +0200
Subject: [PATCH] Bael 845 transfer queue (#1727)

* BAEL-845 tranferqueue article

* BAEL-845 m to m example

* BAEL-845 move code to test

* BAEL-845 use tryTransfer

* BAEL-845 proper if logic

* BAEL-845 proper test

* BAEL-845 robust test

* BAEL-856 invert logic
---
 .../src/main/java/com/baeldung/transferqueue/Producer.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/core-java/src/main/java/com/baeldung/transferqueue/Producer.java b/core-java/src/main/java/com/baeldung/transferqueue/Producer.java
index c9edc69e33..c6edc99bb5 100644
--- a/core-java/src/main/java/com/baeldung/transferqueue/Producer.java
+++ b/core-java/src/main/java/com/baeldung/transferqueue/Producer.java
@@ -22,11 +22,11 @@ public class Producer implements Runnable {
             try {
                 System.out.println("Producer: " + name + " is waiting to transfer...");
                 boolean added = transferQueue.tryTransfer("A" + i, 4000, TimeUnit.MILLISECONDS);
-                if (!added) {
-                    System.out.println("can not add an element due to the timeout");
-                } else {
+                if (added) {
                     numberOfProducedMessages.incrementAndGet();
                     System.out.println("Producer: " + name + " transferred element: A" + i);
+                } else {
+                    System.out.println("can not add an element due to the timeout");
                 }
             } catch (InterruptedException e) {
                 e.printStackTrace();