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 destinationName, Priority priority) {
031
032 _destinationName = destinationName;
033 _priority = priority;
034 }
035
036 @Override
037 public void dispatchEvent(PortalCacheClusterEvent portalCacheClusterEvent) {
038 Message message = new Message();
039
040 message.setDestinationName(_destinationName);
041 message.setPayload(portalCacheClusterEvent);
042
043 ClusterLinkUtil.sendMulticastMessage(message, _priority);
044 }
045
046 private String _destinationName;
047 private Priority _priority;
048
049 }