1
19
20 package com.liferay.mail.messaging;
21
22 import com.liferay.portal.kernel.log.Log;
23 import com.liferay.portal.kernel.log.LogFactoryUtil;
24 import com.liferay.portal.kernel.mail.MailMessage;
25 import com.liferay.portal.kernel.messaging.Message;
26 import com.liferay.portal.kernel.messaging.MessageListener;
27 import com.liferay.portal.kernel.util.ArrayUtil;
28 import com.liferay.portal.kernel.util.MethodInvoker;
29 import com.liferay.portal.kernel.util.MethodWrapper;
30 import com.liferay.portal.util.PropsKeys;
31 import com.liferay.portal.util.PropsUtil;
32 import com.liferay.util.mail.MailEngine;
33
34 import javax.mail.internet.InternetAddress;
35
36
42 public class MailMessageListener implements MessageListener {
43
44 public void receive(Message message) {
45 try {
46 doReceive(message);
47 }
48 catch (Exception e) {
49 _log.error("Unable to process message " + message, e);
50 }
51 }
52
53 public void doMailMessage(MailMessage mailMessage) throws Exception {
54 InternetAddress[] auditTrail = InternetAddress.parse(
55 PropsUtil.get(PropsKeys.MAIL_AUDIT_TRAIL));
56
57 if (auditTrail.length > 0) {
58 InternetAddress[] bcc = mailMessage.getBCC();
59
60 if (bcc != null) {
61 InternetAddress[] allBCC = new InternetAddress[
62 bcc.length + auditTrail.length];
63
64 ArrayUtil.combine(bcc, auditTrail, allBCC);
65
66 mailMessage.setBCC(allBCC);
67 }
68 else {
69 mailMessage.setBCC(auditTrail);
70 }
71 }
72
73 MailEngine.send(mailMessage);
74 }
75
76 public void doMethodWrapper(MethodWrapper methodWrapper) throws Exception {
77 MethodInvoker.invoke(methodWrapper);
78 }
79
80 public void doReceive(Message message) throws Exception {
81 Object payload = message.getPayload();
82
83 if (payload instanceof MailMessage) {
84 doMailMessage((MailMessage)payload);
85 }
86 else if (payload instanceof MethodWrapper) {
87 doMethodWrapper((MethodWrapper)payload);
88 }
89 }
90
91 private static Log _log = LogFactoryUtil.getLog(MailMessageListener.class);
92
93 }