Skip to content
Snippets Groups Projects
Commit 8ad66591 authored by brinn's avatar brinn
Browse files

Refactor r28616.

SVN: 28617
parent 5dc7aa95
No related branches found
No related tags found
No related merge requests found
......@@ -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");
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment