1
19
20 package com.liferay.portal.search;
21
22 import com.liferay.portal.kernel.messaging.DestinationNames;
23 import com.liferay.portal.kernel.messaging.MessageBusUtil;
24 import com.liferay.portal.kernel.search.IndexSearcher;
25 import com.liferay.portal.kernel.search.IndexWriter;
26 import com.liferay.portal.kernel.search.SearchEngine;
27 import com.liferay.portal.kernel.search.messaging.SearchRequest;
28
29
35 public class SearchEngineImpl implements SearchEngine {
36
37 public String getName() {
38 throw new UnsupportedOperationException();
39 }
40
41 public IndexSearcher getSearcher() {
42 return _searcher;
43 }
44
45 public IndexWriter getWriter() {
46 return _writer;
47 }
48
49 public boolean isRegistered() {
50 throw new UnsupportedOperationException();
51 }
52
53 public void register(String name) {
54 SearchRequest searchRequest = new SearchRequest();
55
56 searchRequest.setCommand(SearchRequest.COMMAND_REGISTER);
57 searchRequest.setId(name);
58
59 MessageBusUtil.sendMessage(
60 DestinationNames.SEARCH_WRITER, searchRequest);
61 }
62
63 public void setSearcher(IndexSearcher searcher) {
64 _searcher = searcher;
65 }
66
67 public void setWriter(IndexWriter writer) {
68 _writer = writer;
69 }
70
71 public void unregister(String fromName) {
72 SearchRequest searchRequest = new SearchRequest();
73
74 searchRequest.setCommand(SearchRequest.COMMAND_UNREGISTER);
75 searchRequest.setId(fromName);
76
77 MessageBusUtil.sendMessage(
78 DestinationNames.SEARCH_WRITER, searchRequest);
79 }
80
81 private IndexSearcher _searcher;
82 private IndexWriter _writer;
83
84 }