Use put() instead of add()

While add() throws an IllegalStateException if the Queue is full, a put()
just waits until there is space left in Queue.

- add "return"
The usage of "return" is encouraged to make sure to stop a thread when it's
interrupted.

See hbz/lobid-resources#980.

Author: dr0i

metafacture-flowcontrol/src/main/java/org/metafacture/flowcontrol/ObjectPipeDecoupler.java

@@ -97,13 +97,17 @@ public <R extends ObjectReceiver<T>> R setReceiver(final R receiver) {
 
     @Override
     public void resetStream() {
-        queue.add(Feeder.BLUE_PILL);
+        try {
+            queue.put(Feeder.BLUE_PILL);
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+        }
     }
 
     @Override
     public void closeStream() {
-        queue.add(Feeder.RED_PILL);
         try {
+            queue.put(Feeder.RED_PILL);
             thread.join();
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
@@ -147,6 +151,7 @@ public void run() {
                 }
             } catch (InterruptedException e) {
                 Thread.currentThread().interrupt();
+                return;
             }
         }
     }