001
014
015 package com.liferay.portal.cache.cluster.clusterlink;
016
017 import com.liferay.portal.kernel.cache.cluster.BasePortalCacheClusterChannel;
018 import com.liferay.portal.kernel.cache.cluster.PortalCacheClusterEvent;
019 import com.liferay.portal.kernel.cluster.ClusterLinkUtil;
020 import com.liferay.portal.kernel.cluster.Priority;
021 import com.liferay.portal.kernel.messaging.Message;
022
023
026 public class ClusterLinkPortalCacheClusterChannel
027 extends BasePortalCacheClusterChannel {
028
029 public ClusterLinkPortalCacheClusterChannel(
030 String destination, Priority priority) {
031
032 _destination = destination;
033 _priority = priority;
034 }
035
036 public void dispatchEvent(PortalCacheClusterEvent portalCacheClusterEvent) {
037 Message message = new Message();
038
039 message.setDestinationName(_destination);
040 message.setPayload(portalCacheClusterEvent);
041
042 ClusterLinkUtil.sendMulticastMessage(message, _priority);
043 }
044
045 private String _destination;
046 private Priority _priority;
047
048 }