1
22
23 package com.liferay.portal.search.lucene.messaging;
24
25 import com.liferay.portal.kernel.messaging.Message;
26 import com.liferay.portal.kernel.messaging.MessageBusUtil;
27 import com.liferay.portal.kernel.messaging.MessageListener;
28 import com.liferay.portal.kernel.search.Hits;
29 import com.liferay.portal.kernel.search.messaging.SearchRequest;
30 import com.liferay.portal.kernel.util.Validator;
31 import com.liferay.portal.search.lucene.LuceneSearchEngineUtil;
32
33 import org.apache.commons.logging.Log;
34 import org.apache.commons.logging.LogFactory;
35
36
42 public class LuceneReaderMessageListener implements MessageListener {
43
44 public void receive(Object message) {
45 try {
46 doReceive((Message)message);
47 }
48 catch (Exception e) {
49 _log.error("Unable to process message " + message, e);
50 }
51 }
52
53 public void receive(String message) {
54 throw new UnsupportedOperationException();
55 }
56
57 public void doReceive(Message message) throws Exception {
58 String responseDestination = message.getResponseDestination();
59 String responseId = message.getResponseId();
60
61 SearchRequest searchRequest = (SearchRequest)message.getRequestValue();
62
63 String command = searchRequest.getCommand();
64
65 if (command.equals(SearchRequest.COMMAND_INDEX_ONLY) &&
66 Validator.isNotNull(responseDestination) &&
67 Validator.isNotNull(responseId)) {
68
69 doCommandIndexOnly(message);
70 }
71 else if (command.equals(SearchRequest.COMMAND_SEARCH) &&
72 Validator.isNotNull(responseDestination) &&
73 Validator.isNotNull(responseId)) {
74
75 doCommandSearch(message, searchRequest);
76 }
77 }
78
79 protected void doCommandIndexOnly(Message message)
80 throws Exception {
81
82 boolean indexOnly = LuceneSearchEngineUtil.isIndexReadOnly();
83
84 message.setResponseValue(Boolean.valueOf(indexOnly));
85
86 MessageBusUtil.sendMessage(message.getResponseDestination(), message);
87 }
88
89 protected void doCommandSearch(Message message, SearchRequest searchRequest)
90 throws Exception {
91
92 Hits hits = LuceneSearchEngineUtil.search(
93 searchRequest.getCompanyId(), searchRequest.getQuery(),
94 searchRequest.getSort(), searchRequest.getStart(),
95 searchRequest.getEnd());
96
97 message.setResponseValue(hits);
98
99 MessageBusUtil.sendMessage(message.getResponseDestination(), message);
100 }
101
102 private static Log _log =
103 LogFactory.getLog(LuceneReaderMessageListener.class);
104
105 }