1
14
15 package com.liferay.portal.cache.cluster.clusterlink;
16
17 import com.liferay.portal.kernel.cache.cluster.BasePortalCacheClusterChannel;
18 import com.liferay.portal.kernel.cache.cluster.PortalCacheClusterEvent;
19 import com.liferay.portal.kernel.cluster.ClusterLinkUtil;
20 import com.liferay.portal.kernel.cluster.Priority;
21 import com.liferay.portal.kernel.messaging.Message;
22
23
29 public class ClusterLinkPortalCacheClusterChannel
30 extends BasePortalCacheClusterChannel {
31
32 public ClusterLinkPortalCacheClusterChannel(
33 String destination, Priority priority) {
34
35 _destination = destination;
36 _priority = priority;
37 }
38
39 public void dispatchEvent(PortalCacheClusterEvent portalCacheClusterEvent) {
40 Message message = new Message();
41
42 message.setDestinationName(_destination);
43 message.setPayload(portalCacheClusterEvent);
44
45 ClusterLinkUtil.sendMulticastMessage(message, _priority);
46 }
47
48 private String _destination;
49 private Priority _priority;
50
51 }