1
14
15 package com.liferay.portal.kernel.cluster.messaging;
16
17 import com.liferay.portal.kernel.cluster.Address;
18 import com.liferay.portal.kernel.cluster.ClusterLinkUtil;
19 import com.liferay.portal.kernel.cluster.Priority;
20 import com.liferay.portal.kernel.log.Log;
21 import com.liferay.portal.kernel.log.LogFactoryUtil;
22 import com.liferay.portal.kernel.messaging.Message;
23 import com.liferay.portal.kernel.messaging.MessageListener;
24
25
31 public class ClusterBridgeMessageListener implements MessageListener {
32
33 public void receive(Message message) {
34
35
37 if (ClusterLinkUtil.isForwardMessage(message)) {
38 return;
39 }
40
41 Address address = ClusterLinkUtil.getAddress(message);
42
43 if (address == null) {
44 if (_log.isInfoEnabled()) {
45 _log.info("Bridging cluster link multicast message " + message);
46 }
47
48 ClusterLinkUtil.sendMulticastMessage(message, _priority);
49 }
50 else {
51 if (_log.isInfoEnabled()) {
52 _log.info(
53 "Bridging cluster link unicast message " + message +
54 " to " + address);
55 }
56
57 ClusterLinkUtil.sendUnicastMessage(address, message, _priority);
58 }
59 }
60
61 public void setPriority(Priority priority) {
62 _priority = priority;
63 }
64
65 private static Log _log = LogFactoryUtil.getLog(
66 ClusterBridgeMessageListener.class);
67
68 private Priority _priority;
69
70 }