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