@@ -239,12 +239,12 @@ private void updateQueue(QueueTask qt) throws InterruptedException {
239239 //since payment time is lesser than queuetime it would have already failed..additional check not needed
240240 LOG .trace ("Order " + qt .order .id + ": Queue time for order over, failed.." );
241241 return ;
242- } else if (( qt .taskType .equals (TaskType .Payment ) && !qt .order .paid .equals (PaymentStatus .Trying ) )
243- || ( qt .taskType .equals (TaskType .Messaging ) && (( qt .messageType == 1
244- && !qt .order .messageSent .equals (MessageSent .NoneSent ))
242+ } else if (qt .taskType .equals (TaskType .Payment ) && !qt .order .paid .equals (PaymentStatus .Trying )
243+ || qt .taskType .equals (TaskType .Messaging ) && (qt .messageType == 1
244+ && !qt .order .messageSent .equals (MessageSent .NoneSent )
245245 || qt .order .messageSent .equals (MessageSent .PaymentFail )
246- || qt .order .messageSent .equals (MessageSent .PaymentSuccessful )))
247- || ( qt .taskType .equals (TaskType .EmployeeDb ) && qt .order .addedToEmployeeHandle ) ) {
246+ || qt .order .messageSent .equals (MessageSent .PaymentSuccessful ))
247+ || qt .taskType .equals (TaskType .EmployeeDb ) && qt .order .addedToEmployeeHandle ) {
248248 LOG .trace ("Order " + qt .order .id + ": Not queueing task since task already done.." );
249249 return ;
250250 }
@@ -576,8 +576,8 @@ private void doTasksInQueue() throws Exception {
576576 || qt .order .messageSent .equals (MessageSent .PaymentSuccessful )) {
577577 tryDequeue ();
578578 LOG .trace ("Order " + qt .order .id + ": This messaging task already done, dequeue.." );
579- } else if (( qt .messageType == 1 && (!qt .order .messageSent .equals (MessageSent .NoneSent )
580- || !qt .order .paid .equals (PaymentStatus .Trying )))) {
579+ } else if (qt .messageType == 1 && (!qt .order .messageSent .equals (MessageSent .NoneSent )
580+ || !qt .order .paid .equals (PaymentStatus .Trying ))) {
581581 tryDequeue ();
582582 LOG .trace ("Order " + qt .order .id + ": This messaging task does not need to be done, dequeue.." );
583583 } else if (qt .messageType == 0 ) {
@@ -606,8 +606,7 @@ private void doTasksInQueue() throws Exception {
606606 } else {
607607 Thread .sleep (queueTaskTime / 3 );
608608 tryDoingTasksInQueue ();
609- }
610- return ;
609+ }
611610 }
612611
613612}
0 commit comments