Skip to content

Commit 0dc22a1

Browse files
committed
Revert "update send email to async"
This reverts commit 4b4f5a9.
1 parent 4b4f5a9 commit 0dc22a1

File tree

6 files changed

+5
-30
lines changed

6 files changed

+5
-30
lines changed

src/main/java/com/cronos/onlinereview/actions/latedeliverables/SaveLateDeliverableAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -353,7 +353,7 @@ private void sendEmailForUsers(Project project, List<String> recipients, List<St
353353
message.addToAddress(ccRecipient, TCSEmailMessage.CC);
354354
}
355355
message.setContentType("text/html");
356-
ActionsHelper.sendEmail(message);
356+
EmailEngine.send(message);
357357
}
358358

359359
/**

src/main/java/com/cronos/onlinereview/actions/projectdetails/BaseProjectDetailsAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -846,7 +846,7 @@ private void notifyIterativeReviewers(Project project, long submissionId, String
846846
message.addToAddress(recipient, TCSEmailMessage.TO);
847847
}
848848
message.setContentType("text/html");
849-
ActionsHelper.sendEmail(message);
849+
EmailEngine.send(message);
850850
}
851851

852852
/**

src/main/java/com/cronos/onlinereview/actions/projectdetails/ContactManagerAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -187,7 +187,7 @@ public String execute() throws BaseException, ConfigManagerException {
187187
message.setContentType("text/html");
188188

189189
// Send an email
190-
ActionsHelper.sendEmail(message);
190+
EmailEngine.send(message);
191191
setPid(project.getId());
192192

193193
return Constants.SUCCESS_FORWARD_NAME;

src/main/java/com/cronos/onlinereview/phases/ReviewResultNotification.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@
66
import java.text.MessageFormat;
77

88
import com.cronos.onlinereview.external.ExternalUser;
9-
import com.cronos.onlinereview.util.ActionsHelper;
109
import com.topcoder.management.deliverable.Submission;
1110
import com.topcoder.management.deliverable.UploadManager;
1211
import com.topcoder.management.phase.PhaseHandlingException;
@@ -110,7 +109,7 @@ private void sendWinnersEmailForUser(Project project, ExternalUser user, String
110109
message.setBody(emailContent);
111110
message.setFromAddress(winnersEmailFromAddress);
112111
message.setToAddress(user.getEmail(), TCSEmailMessage.TO);
113-
ActionsHelper.sendEmail(message);
112+
EmailEngine.send(message);
114113
}
115114

116115
private Resource getResourceForProjectAndUser(Project project, Long userId) throws PhaseManagementException {

src/main/java/com/cronos/onlinereview/phases/ScreeningResultNotification.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010

1111
import com.cronos.onlinereview.external.ExternalUser;
1212
import com.cronos.onlinereview.external.UserRetrieval;
13-
import com.cronos.onlinereview.util.ActionsHelper;
1413
import com.topcoder.management.deliverable.Submission;
1514
import com.topcoder.management.deliverable.SubmissionStatus;
1615
import com.topcoder.management.deliverable.SubmissionType;
@@ -221,7 +220,7 @@ private void sendEmailForUser(Project project, ExternalUser user, Submission sub
221220
message.setFromAddress(emailFromAddress);
222221
message.setToAddress(user.getEmail(), TCSEmailMessage.TO);
223222
message.setContentType("text/html");
224-
ActionsHelper.sendEmail(message);
223+
EmailEngine.send(message);
225224
}
226225

227226
/**

src/main/java/com/cronos/onlinereview/util/ActionsHelper.java

Lines changed: 0 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,6 @@
2929
import java.util.List;
3030
import java.util.Map;
3131
import java.util.Set;
32-
import java.util.concurrent.ExecutorService;
33-
import java.util.concurrent.Executors;
3432

3533
import com.amazonaws.auth.PropertiesCredentials;
3634
import com.amazonaws.services.s3.AmazonS3Client;
@@ -106,9 +104,6 @@
106104
import com.topcoder.management.scorecard.data.Group;
107105
import com.topcoder.management.scorecard.data.Scorecard;
108106
import com.topcoder.management.scorecard.data.Section;
109-
import com.topcoder.message.email.EmailEngine;
110-
import com.topcoder.message.email.SendingException;
111-
import com.topcoder.message.email.TCSEmailMessage;
112107
import com.topcoder.project.phases.Dependency;
113108
import com.topcoder.project.phases.Phase;
114109
import com.topcoder.project.phases.PhaseStatus;
@@ -128,7 +123,6 @@
128123
import com.topcoder.servlet.request.LocalFileUpload;
129124
import com.topcoder.shared.util.ApplicationServer;
130125
import com.topcoder.shared.util.TCContext;
131-
import com.topcoder.util.config.ConfigManagerException;
132126
import com.topcoder.util.errorhandling.BaseException;
133127
import com.topcoder.util.errorhandling.BaseRuntimeException;
134128
import com.topcoder.util.log.Level;
@@ -228,8 +222,6 @@ public class ActionsHelper {
228222
*/
229223
public static final String LOCAL_STUDIO_STORAGE_NAMESPACE = "com.topcoder.servlet.request.LocalStudioFileUpload";
230224

231-
private static final ExecutorService THREAD_POOL = Executors.newFixedThreadPool(50);
232-
233225
/**
234226
* AWS S3 client
235227
*/
@@ -3886,19 +3878,4 @@ public static String createStudioLocalFilePath(long projectId, long userId, Stri
38863878
buf.append(parameter);
38873879
return buf.toString();
38883880
}
3889-
3890-
public static void sendEmail(final TCSEmailMessage message) {
3891-
THREAD_POOL.execute(new Runnable() {
3892-
@Override
3893-
public void run() {
3894-
try {
3895-
EmailEngine.send(message);
3896-
} catch (ConfigManagerException e) {
3897-
log.log(Level.ERROR, "Send email with config error: " + e.getMessage());
3898-
} catch (SendingException e) {
3899-
log.log(Level.ERROR, "Send email with sending error: " + e.getMessage());
3900-
}
3901-
}
3902-
});
3903-
}
39043881
}

0 commit comments

Comments
 (0)