001
014
015 package com.liferay.portal.kernel.messaging;
016
017 import com.liferay.portal.kernel.messaging.sender.SingleDestinationMessageSender;
018
019
022 public class BridgingMessageListener implements MessageListener {
023
024 public BridgingMessageListener() {
025 }
026
027
030 public BridgingMessageListener(
031 SingleDestinationMessageSender singleDestinationMessageSender) {
032
033 _singleDestinationMessageSender = singleDestinationMessageSender;
034 }
035
036 @Override
037 public void receive(Message message) {
038 _singleDestinationMessageSender.send(message);
039 }
040
041 public void setSingleDestinationMessageSender(
042 SingleDestinationMessageSender singleDestinationMessageSender) {
043
044 _singleDestinationMessageSender = singleDestinationMessageSender;
045 }
046
047 private SingleDestinationMessageSender _singleDestinationMessageSender;
048
049 }