1   /**
2    * Copyright (c) 2000-2009 Liferay, Inc. All rights reserved.
3    *
4    * The contents of this file are subject to the terms of the Liferay Enterprise
5    * Subscription License ("License"). You may not use this file except in
6    * compliance with the License. You can obtain a copy of the License by
7    * contacting Liferay, Inc. See the License for the specific language governing
8    * permissions and limitations under the License, including but not limited to
9    * distribution rights of the Software.
10   *
11   * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
12   * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
13   * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
14   * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
15   * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
16   * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
17   * SOFTWARE.
18   */
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  /**
37   * <a href="MailMessageListener.java.html"><b><i>View Source</i></b></a>
38   *
39   * @author Brian Wing Shun Chan
40   *
41   */
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  }