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.Document;
25 import com.liferay.portal.kernel.search.IndexWriter;
26 import com.liferay.portal.kernel.search.messaging.SearchRequest;
27
28
34 public class IndexWriterImpl implements IndexWriter {
35
36 public void addDocument(long companyId, Document doc) {
37 SearchRequest searchRequest = new SearchRequest();
38
39 searchRequest.setCommand(SearchRequest.COMMAND_ADD);
40 searchRequest.setCompanyId(companyId);
41 searchRequest.setDocument(doc);
42
43 MessageBusUtil.sendMessage(
44 DestinationNames.SEARCH_WRITER, searchRequest);
45 }
46
47 public void deleteDocument(long companyId, String uid) {
48 SearchRequest searchRequest = new SearchRequest();
49
50 searchRequest.setCommand(SearchRequest.COMMAND_DELETE);
51 searchRequest.setCompanyId(companyId);
52 searchRequest.setId(uid);
53
54 MessageBusUtil.sendMessage(
55 DestinationNames.SEARCH_WRITER, searchRequest);
56 }
57
58 public void deletePortletDocuments(long companyId, String portletId) {
59 SearchRequest searchRequest = new SearchRequest();
60
61 searchRequest.setCommand(SearchRequest.COMMAND_DELETE_PORTLET_DOCS);
62 searchRequest.setCompanyId(companyId);
63 searchRequest.setId(portletId);
64
65 MessageBusUtil.sendMessage(
66 DestinationNames.SEARCH_WRITER, searchRequest);
67 }
68
69 public void updateDocument(long companyId, String uid, Document doc) {
70 SearchRequest searchRequest = new SearchRequest();
71
72 searchRequest.setCommand(SearchRequest.COMMAND_UPDATE);
73 searchRequest.setCompanyId(companyId);
74 searchRequest.setId(uid);
75 searchRequest.setDocument(doc);
76
77 MessageBusUtil.sendMessage(
78 DestinationNames.SEARCH_WRITER, searchRequest);
79 }
80
81 }