1   /**
2    * Copyright (c) 2000-2009 Liferay, Inc. All rights reserved.
3    *
4    * The contents of this file are subject to the terms of the Liferay Enterprise
5    * Subscription License ("License"). You may not use this file except in
6    * compliance with the License. You can obtain a copy of the License by
7    * contacting Liferay, Inc. See the License for the specific language governing
8    * permissions and limitations under the License, including but not limited to
9    * distribution rights of the Software.
10   *
11   * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
12   * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
13   * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
14   * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
15   * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
16   * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
17   * SOFTWARE.
18   */
19  
20  package com.liferay.portal.search.lucene.messaging;
21  
22  import com.liferay.portal.kernel.log.Log;
23  import com.liferay.portal.kernel.log.LogFactoryUtil;
24  import com.liferay.portal.kernel.messaging.Message;
25  import com.liferay.portal.kernel.messaging.MessageListener;
26  import com.liferay.portal.kernel.messaging.sender.MessageSender;
27  import com.liferay.portal.kernel.search.Hits;
28  import com.liferay.portal.kernel.search.messaging.SearchRequest;
29  import com.liferay.portal.search.lucene.LuceneSearchEngineUtil;
30  
31  /**
32   * <a href="LuceneReaderMessageListener.java.html"><b><i>View Source</i></b></a>
33   *
34   * @author Bruno Farache
35   *
36   */
37  public class LuceneReaderMessageListener implements MessageListener {
38  
39      public LuceneReaderMessageListener(MessageSender messageSender) {
40          _messageSender = messageSender;
41      }
42  
43      public void receive(Message message) {
44          try {
45              doReceive(message);
46          }
47          catch (Exception e) {
48              _log.error("Unable to process message " + message, e);
49          }
50      }
51  
52      public void doReceive(Message message) throws Exception {
53          Object payload = message.getPayload();
54  
55          if (!LuceneSearchEngineUtil.isRegistered() ||
56              !(payload instanceof SearchRequest)) {
57  
58              return;
59          }
60  
61          SearchRequest searchRequest = (SearchRequest)payload;
62  
63          String command = searchRequest.getCommand();
64  
65          if (command.equals(SearchRequest.COMMAND_INDEX_ONLY)) {
66              doCommandIndexOnly(message);
67          }
68          else if (command.equals(SearchRequest.COMMAND_SEARCH)) {
69              doCommandSearch(message, searchRequest);
70          }
71      }
72  
73      protected void doCommandIndexOnly(Message message)
74          throws Exception {
75  
76          Boolean indexReadOnly = Boolean.valueOf(
77              LuceneSearchEngineUtil.isIndexReadOnly());
78  
79          message.setPayload(indexReadOnly);
80  
81          _messageSender.send(message.getResponseDestination(), message);
82      }
83  
84      protected void doCommandSearch(Message message, SearchRequest searchRequest)
85          throws Exception {
86  
87          Hits hits = LuceneSearchEngineUtil.search(
88              searchRequest.getCompanyId(), searchRequest.getQuery(),
89              searchRequest.getSorts(), searchRequest.getStart(),
90              searchRequest.getEnd());
91  
92          message.setPayload(hits);
93  
94          _messageSender.send(message.getResponseDestination(), message);
95      }
96  
97      private static Log _log =
98          LogFactoryUtil.getLog(LuceneReaderMessageListener.class);
99  
100     private MessageSender _messageSender;
101 
102 }