001
014
015 package com.liferay.portlet.blogs.messaging;
016
017 import com.liferay.portal.kernel.messaging.BaseMessageListener;
018 import com.liferay.portal.kernel.messaging.Message;
019 import com.liferay.portlet.blogs.linkback.LinkbackConsumer;
020 import com.liferay.portlet.blogs.linkback.LinkbackConsumerUtil;
021 import com.liferay.portlet.blogs.util.LinkbackProducerUtil;
022
023
027 public class LinkbackMessageListener extends BaseMessageListener {
028
029 @Override
030 protected void doReceive(Message message) throws Exception {
031 _linkbackConsumer.verifyNewTrackbacks();
032
033 LinkbackProducerUtil.sendQueuedPingbacks();
034 }
035
036 private final LinkbackConsumer _linkbackConsumer =
037 LinkbackConsumerUtil.getLinkbackConsumer();
038
039 }