diff --git a/common/source/java/ch/systemsx/cisd/common/io/QueuePersister.java b/common/source/java/ch/systemsx/cisd/common/io/QueuePersister.java
index 3f68b7b9b0a6603a37892a1f6ae1d5e1a462af42..ffb39148788c643058a025c2c6361d76faf74342 100644
--- a/common/source/java/ch/systemsx/cisd/common/io/QueuePersister.java
+++ b/common/source/java/ch/systemsx/cisd/common/io/QueuePersister.java
@@ -440,11 +440,8 @@ public class QueuePersister<E> implements IQueuePersister<E>
         {
             try
             {
-                if (randomAccessFile.getFD().valid() == false)
-
-                {
-                    this.randomAccessFile = new RandomAccessFile(queueFile, "rw");
-                } else if (false == randomAccessFile.getChannel().isOpen())
+                if (randomAccessFile.getFD().valid() == false
+                        || false == randomAccessFile.getChannel().isOpen())
                 {
                     this.randomAccessFile = new RandomAccessFile(queueFile, "rw");
                 }