001
014
015 package com.liferay.portal.pop;
016
017 import com.liferay.portal.kernel.log.Log;
018 import com.liferay.portal.kernel.log.LogFactoryUtil;
019 import com.liferay.portal.kernel.pop.MessageListener;
020 import com.liferay.portal.kernel.pop.MessageListenerException;
021
022 import javax.mail.Message;
023
024
027 public class MessageListenerWrapper implements MessageListener {
028
029 public MessageListenerWrapper(MessageListener listener) {
030 _listener = listener;
031 }
032
033 @Override
034 public boolean accept(String from, String recipient, Message message) {
035 if (_log.isDebugEnabled()) {
036 _log.debug("Listener " + _listener.getClass().getName());
037 _log.debug("From " + from);
038 _log.debug("Recipient " + recipient);
039 }
040
041 boolean value = _listener.accept(from, recipient, message);
042
043 if (_log.isDebugEnabled()) {
044 _log.debug("Accept " + value);
045 }
046
047 return value;
048 }
049
050 @Override
051 public void deliver(String from, String recipient, Message message)
052 throws MessageListenerException {
053
054 if (_log.isDebugEnabled()) {
055 _log.debug("Listener " + _listener.getClass().getName());
056 _log.debug("From " + from);
057 _log.debug("Recipient " + recipient);
058 _log.debug("Message " + message);
059 }
060
061 _listener.deliver(from, recipient, message);
062 }
063
064 @Override
065 public boolean equals(Object obj) {
066 if (this == obj) {
067 return true;
068 }
069
070 if (!(obj instanceof MessageListenerWrapper)) {
071 return false;
072 }
073
074 MessageListenerWrapper listener = (MessageListenerWrapper)obj;
075
076 String id = listener.getId();
077
078 return getId().equals(id);
079 }
080
081 @Override
082 public String getId() {
083 return _listener.getId();
084 }
085
086 @Override
087 public int hashCode() {
088 return _listener.getId().hashCode();
089 }
090
091 private static Log _log = LogFactoryUtil.getLog(
092 MessageListenerWrapper.class);
093
094 private MessageListener _listener;
095
096 }