Skip to content

Commit

Permalink
Fix #3147 : Reset processingStartTime and processingEndTime of a queu…
Browse files Browse the repository at this point in the history
…e message on rescheduling a single task
  • Loading branch information
vrindanayak committed Apr 20, 2021
1 parent 266413c commit 3b50380
Showing 1 changed file with 6 additions and 2 deletions.
Expand Up @@ -40,13 +40,15 @@

package org.dcm4chee.arc.qmgt.impl;

import javax.persistence.criteria.Predicate;
import org.dcm4che3.net.Device;
import org.dcm4chee.arc.conf.ArchiveDeviceExtension;
import org.dcm4chee.arc.conf.QueueDescriptor;
import org.dcm4chee.arc.entity.*;
import org.dcm4chee.arc.event.QueueMessageEvent;
import org.dcm4chee.arc.qmgt.*;
import org.dcm4chee.arc.qmgt.IllegalTaskStateException;
import org.dcm4chee.arc.qmgt.MessageCanceled;
import org.dcm4chee.arc.qmgt.Outcome;
import org.dcm4chee.arc.qmgt.QueueSizeLimitExceededException;
import org.dcm4chee.arc.query.util.MatchTask;
import org.dcm4chee.arc.query.util.QueryBuilder;
import org.dcm4chee.arc.query.util.TaskQueryParam;
Expand Down Expand Up @@ -467,6 +469,8 @@ public void rescheduleTask(String msgId, String queueName, QueueMessageEvent que
entity.setNumberOfFailures(0);
entity.setErrorMessage(null);
entity.setOutcomeMessage(null);
entity.setProcessingStartTime(null);
entity.setProcessingEndTime(null);
rescheduleTask(entity, descriptorOf(entity.getQueueName()), 0L);
updateTaskDeviceName(entity);
}
Expand Down

0 comments on commit 3b50380

Please sign in to comment.