|
|
@ -164,10 +164,8 @@ class Core {
|
|
|
|
" group=" + group +
|
|
|
|
" group=" + group +
|
|
|
|
" retry=" + retry);
|
|
|
|
" retry=" + retry);
|
|
|
|
|
|
|
|
|
|
|
|
if (ifolder != null && !ifolder.isOpen()) {
|
|
|
|
if (ifolder != null && !ifolder.isOpen())
|
|
|
|
state.error(new FolderClosedException(ifolder));
|
|
|
|
|
|
|
|
break;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Fetch most recent copy of message
|
|
|
|
// Fetch most recent copy of message
|
|
|
|
EntityMessage message = null;
|
|
|
|
EntityMessage message = null;
|
|
|
@ -510,8 +508,6 @@ class Core {
|
|
|
|
|
|
|
|
|
|
|
|
if (ops.size() == 0)
|
|
|
|
if (ops.size() == 0)
|
|
|
|
state.batchCompleted(folder.id, priority, sequence);
|
|
|
|
state.batchCompleted(folder.id, priority, sequence);
|
|
|
|
else
|
|
|
|
|
|
|
|
state.error(new FolderClosedException(ifolder));
|
|
|
|
|
|
|
|
} finally {
|
|
|
|
} finally {
|
|
|
|
Log.i(folder.name + " end process state=" + state + " pending=" + ops.size());
|
|
|
|
Log.i(folder.name + " end process state=" + state + " pending=" + ops.size());
|
|
|
|
}
|
|
|
|
}
|
|
|
|