001
014
015 package com.liferay.portal.kernel.messaging;
016
017 import com.liferay.portal.kernel.util.SetUtil;
018
019 import java.util.List;
020 import java.util.Set;
021
022
025 public class GlobalMessageBusEventListener implements MessageBusEventListener {
026
027 @Override
028 public void destinationAdded(Destination destination) {
029 if (!_ignoredDestinations.contains(destination.getName())) {
030 destination.register(_messageListener);
031 }
032 }
033
034 @Override
035 public void destinationRemoved(Destination destination) {
036 if (!_ignoredDestinations.contains(destination.getName())) {
037 destination.unregister(_messageListener);
038 }
039 }
040
041 public void setIgnoredDestinations(List<String> ignoredDestinations) {
042 _ignoredDestinations = SetUtil.fromList(ignoredDestinations);
043 }
044
045 public void setMessageListener(MessageListener messageListener) {
046 _messageListener = messageListener;
047 }
048
049 private Set<String> _ignoredDestinations;
050 private MessageListener _messageListener;
051
052 }