nav[aria-label="Primary Navigation"] { padding: 0; & ul { list-style: none; width: 100%; display: flex; flex-direction: row; justify-content: start; align-items: start; gap: 30px; padding: 0; & li { margin: 0; } & ul li { list-style: none; } } }

As we transition to the new Hyland Community, some post links may be temporarily disrupted as we finalize redirects. We apologize for the inconvenience and are working to resolve this as quickly as possible. Details.

How to integrate Apache SOLR with Alfresco?

dynamolalit

Hi,

For my project, we are using Liferay as Front End 5.2.3 & Alfresco 3.2r as CMS.I have a business requirement to integrate Apache SOLR to both of these so that a user of portal can search Liferay as well as Alfresco content single handedly on a portlet in Liferay.

As a part of it, i need to integrate SOLR with Alfresco.How can i do it? :roll:

As SOLR is based on Lucene & Alfresco also uses Lucene indexes so can I expose Alfresco indexes to SOLR so that it can be in sync with SOLR .

Is it possible ??? Can SOLR get leverage from existing Alfresco Lucene indexes in any way?

Or every time a content is created in repository, SOLR indexes needs to be updated? If so , how can it be done?

Would appreciate for any help/suggestion.

Find more posts tagged with

Comments

dynamolalit

Hi,

For my project, we are using Liferay as Front End 5.2.3 & Alfresco 3.2r as CMS.I have a business requirement to integrate Apache SOLR to both of these so that a user of portal can search Liferay as well as Alfresco content single handedly on a portlet in Liferay.

As a part of it, i need to integrate SOLR with Alfresco.How can i do it? :roll:

As SOLR is based on Lucene & Alfresco also uses Lucene indexes so can I expose Alfresco indexes to SOLR so that it can be in sync with SOLR .

Is it possible ??? Can SOLR get leverage from existing Alfresco Lucene indexes in any way?

Or every time a content is created in repository, SOLR indexes needs to be updated? If so , how can it be done?

Would appreciate for any help/suggestion.

Any help please!!

jpfi

hi,
integration alfresco lucene index into a solr system is a very hard task. Your main problem will be handling with permissions, because permissions are not synchronized to lucene index.
I've implemented another solution as part of of customisation project:
- custom aspect solrIndexable: marker aspect
- a bunch of custom policies that post metadata to solr (OnContentUpdate, On PropertiesUpdated etc.)

cheers, jan

dynamolalit

Hi Jan,

Thanks for your reply.

Can you please elaborate a bit more on your approach especially on

a bunch of custom policies that post metadata to solr (OnContentUpdate, On PropertiesUpdated etc.)

How can i post metadata to Solr?

What i can assume is that once content is approved, i can create a xml containing content metadata & share it with solr thus solr can index the xml & use it!Or may be something like this. :idea:

Is it possible?

dynamolalit

Hi,

I managed to post content to SOLR from Alfresco using command cURL.

http://curl.haxx.se/

Once content is approved under workflow, i am forming an XML using DOM parser & posting this well formed XML using cURL command.

Here is source for the same:

KMReviewProcessAction.java from where I am posting XML to SOLR.

/**
&nbsp;&nbsp;&nbsp; * Method to form XML to post to SOLR.
&nbsp;&nbsp;&nbsp; * @param nodeRef
&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;@SuppressWarnings("unchecked")
&nbsp;&nbsp;&nbsp;public void formSolrXml(NodeRef nodeRef){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Inside formSolrXml with noderef "+nodeRef);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Node contentNode = new Node(nodeRef);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String repoPath = Utils.generateURL(FacesContext.getCurrentInstance(), contentNode, URLMode.WEBDAV);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//logger.debug("repoPath "+repoPath);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String webdavUrl = alfServerIp+repoPath;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("webdavUrl in formSolrXml() : "+webdavUrl);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String noderef = nodeRef.toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String[] tempNodeRef = noderef.split("SpacesStore/");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String contentUuid = tempNodeRef[1];
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String curlPreSyntax = "curl ";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String curlPostSyntax = "/solr/update -F commit=true -F stream.file=@";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//Create an XML using XMLFormationBean & pass it to SOLR.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;XmlFormationBean xmlFormationBean = new XmlFormationBean();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName statusQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}contentStatus");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName ownerQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}originalOwner");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName ratingQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}contentRating");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName nameQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}name");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName coAuthorQname = QName.createQName("{{http://www.xxxx.com/model/km/content/1.0}coauthor");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName titleQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}title");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName descriptionQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}description");&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName authorQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}author");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cName = nodeService.getProperty(nodeRef, nameQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Name in formSolrXml : "+cName);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cStatus = nodeService.getProperty(nodeRef, statusQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Status in formSolrXml : "+cStatus);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cOwner = nodeService.getProperty(nodeRef, ownerQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Owner in formSolrXml :&nbsp; "+cOwner);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cRating = nodeService.getProperty(nodeRef, ratingQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Rating in formSolrXml :&nbsp; "+cRating);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cCoAuthor = ".";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cCoAuthor = nodeService.getProperty(nodeRef, coAuthorQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}catch (NullPointerException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cCoAuthor = ".";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content CoAuthor in formSolrXml : "+cCoAuthor);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cTitle = nodeService.getProperty(nodeRef, titleQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Title in formSolrXml :&nbsp; "+cTitle);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cDesc = ".";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cDesc = nodeService.getProperty(nodeRef, descriptionQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}catch (NullPointerException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cDesc = ".";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Description in formSolrXml :&nbsp; "+cDesc);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cAuthor = ".";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cAuthor = nodeService.getProperty(nodeRef, authorQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}catch (NullPointerException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cAuthor = ".";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Author in formSolrXml :&nbsp; "+cAuthor);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cType =&nbsp; getContentMimeType(nodeRef);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Type in formSolrXml :&nbsp; "+cType);&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Collection<NodeRef> categories = (Collection<NodeRef>)nodeService.getProperty(nodeRef, ContentModel.PROP_CATEGORIES);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Iterator itr11 =&nbsp; categories.iterator();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;while(itr11.hasNext()){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;NodeRef catNodeRef = (NodeRef) itr11.next();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String category = Repository.getNameForNode(nodeService, catNodeRef);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("category name in formSolrXml : "+category);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;categoryList.add(category);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}catch (NullPointerException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.error("Error while retrieving categories in formSolrXml : "+e.getMessage());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//InputStream iStream = (InputStream) contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;contentService = services.getContentService();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ContentReader reader = contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (reader != null && reader.exists())
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // get the transformer
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ContentTransformer transformer = contentService.getTransformer(reader.getMimetype(), MimetypeMap.MIMETYPE_TEXT_PLAIN);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // is this transformer good enough?
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (transformer != null)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // We have a transformer that is fast enough
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ContentWriter writer = contentService.getTempWriter();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; writer.setMimetype(MimetypeMap.MIMETYPE_TEXT_PLAIN);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;transformer.transform(reader, writer);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // point the reader to the new-written content
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; reader = writer.getReader();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Check that the reader is a view onto something concrete
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (!reader.exists())
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; throw new ContentIOException("The transformation did not write any content, yet: \n"
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; + "&nbsp;&nbsp; transformer:&nbsp;&nbsp;&nbsp;&nbsp; " + transformer + "\n" + "&nbsp;&nbsp; temp writer:&nbsp;&nbsp;&nbsp;&nbsp; " + writer);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; content = reader.getContentString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; catch (ContentIOException e)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }


&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("Content as a string for SOLR indexing !! :&nbsp; "+content);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //Forming XML.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String finalFileName =&nbsp; xmlFormationBean.formXmlFromContent(contentUuid,content, cType, cAuthor, cCoAuthor, cTitle, cOwner, categoryList, cDesc, cStatus, cRating, cName, solrFileLoc,webdavUrl);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("finalFileName in KMReviewProcessAction : "+finalFileName);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//Deploying to SOLR.Check for content type.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String curlCommand = curlPreSyntax + solrServIp + curlPostSyntax;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(cType.equalsIgnoreCase("application/pdf")){ &nbsp;&nbsp;&nbsp;//PDF
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;curlCommand += finalFileName;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else if(cType.equalsIgnoreCase("application/msword")){ &nbsp;&nbsp;&nbsp;// Word
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;curlCommand += finalFileName;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else if(cType.equalsIgnoreCase("application/vnd.excel")){ &nbsp;&nbsp;&nbsp;//Excel
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;curlCommand += finalFileName;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else if(cType.equalsIgnoreCase("application/vnd.powerpoint")){ &nbsp;&nbsp;&nbsp;// Powerpoint
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;curlCommand += finalFileName;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else if(cType.equalsIgnoreCase("text/plain")){ &nbsp;&nbsp;&nbsp;//Text
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;curlCommand += finalFileName;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else if(cType.equalsIgnoreCase("text/html")){&nbsp;&nbsp;&nbsp;//HTML
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;curlCommand += finalFileName;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else if(cType.equalsIgnoreCase("text/xml")){&nbsp;&nbsp;&nbsp;//XML
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;curlCommand += finalFileName;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.debug("Calling Curl command for content type : "+cType+" : "+curlCommand);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Runtime systemShell = Runtime.getRuntime();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; //Process output = systemShell.exec(curlCommand);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; //int outputCode = output.exitValue();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; systemShell.exec(curlCommand);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; logger.debug("Curl command called correctly for : "+cName);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} catch (IOException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Document named "+cName +" could not indexed");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;e.printStackTrace();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;}
‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍

XmlFormationBean.java forming XML.


public class XmlFormationBean {

&nbsp;&nbsp;&nbsp;private static final Log logger = LogFactory.getLog(XmlFormationBean.class);
&nbsp;&nbsp;&nbsp;private String add = "add";
&nbsp;&nbsp;&nbsp;private String doc = "doc";
&nbsp;&nbsp;&nbsp;private String field = "field";
&nbsp;&nbsp;&nbsp;private String fieldName = "name";
&nbsp;&nbsp;&nbsp;private String id = "id";
&nbsp;&nbsp;&nbsp;private String text = "text";
&nbsp;&nbsp;&nbsp;private String type = "content_type";
&nbsp;&nbsp;&nbsp;private String author = "author";
&nbsp;&nbsp;&nbsp;private String coAuthor = "coAuthor";
&nbsp;&nbsp;&nbsp;private String title = "title";
&nbsp;&nbsp;&nbsp;private String owner = "owner";
&nbsp;&nbsp;&nbsp;private String description = "description";
&nbsp;&nbsp;&nbsp;private String url = "link";
&nbsp;&nbsp;&nbsp;private String category = "category";
&nbsp;&nbsp;&nbsp;private String rating = "rating";
&nbsp;&nbsp;&nbsp;private String lastModified = "last_modified";
&nbsp;&nbsp;&nbsp;private String cdataStartTag = "<![CDATA[";
&nbsp;&nbsp;&nbsp;private String cdataEndTag = "]]>";
&nbsp;&nbsp;&nbsp;private String tilde = "~";
&nbsp;&nbsp;&nbsp;private String cap = "^";
&nbsp;&nbsp;&nbsp;// private String keywords = "keywords";

&nbsp;&nbsp;&nbsp;/**
&nbsp;&nbsp;&nbsp; * Method forming XML with passed parameters. 
&nbsp;&nbsp;&nbsp; * It returns the full file path of XML to be posted to SOLR using cURL.
&nbsp;&nbsp;&nbsp; * Text content is tagged in <![CDATA[]]> tag for XML transformation.
&nbsp;&nbsp;&nbsp; * 
&nbsp;&nbsp;&nbsp; * @param contentUuid
&nbsp;&nbsp;&nbsp; * @param passedContent
&nbsp;&nbsp;&nbsp; * @param contentType
&nbsp;&nbsp;&nbsp; * @param contentAuthor
&nbsp;&nbsp;&nbsp; * @param contentCoAuthor
&nbsp;&nbsp;&nbsp; * @param contentTitle
&nbsp;&nbsp;&nbsp; * @param contentOwner
&nbsp;&nbsp;&nbsp; * @param contentCategories
&nbsp;&nbsp;&nbsp; * @param contentDescription
&nbsp;&nbsp;&nbsp; * @param contentUrl
&nbsp;&nbsp;&nbsp; * @param contentStatus
&nbsp;&nbsp;&nbsp; * @param contentRating
&nbsp;&nbsp;&nbsp; * @param contentName
&nbsp;&nbsp;&nbsp; * @return fileNameToReturn.
&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;public String formXmlFromContent(String contentUuid, String passedContent,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String contentType, String contentAuthor, String contentCoAuthor,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String contentTitle, String contentOwner,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;List<String> contentCategories, String contentDescription,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String contentStatus, String contentRating,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String contentName, String solrFileLoc, String webdavUrl) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String nameOfContent = contentName;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String xmlExt = ".xml";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String forwardSlash = "/";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Inside formXmlFromContent() with nameOfContent : "
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;+ nameOfContent);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String fileNameToReturn = null;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cleanContent = passedContent.replaceAll("\\P{ASCII}+", ""); 

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DocumentBuilderFactory docBuilderFactory = DocumentBuilderFactory
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.newInstance();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DocumentBuilder docBuilder = docBuilderFactory.newDocumentBuilder();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Document document = docBuilder.newDocument();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element rootElement = document.createElement(add);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element docElement = document.createElement(doc);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element idField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;idField.setAttribute(fieldName, id);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;idField.appendChild(document.createTextNode(contentUuid));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(idField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element titleField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;titleField.setAttribute(fieldName, title);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;titleField.appendChild(document.createTextNode(contentTitle));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(titleField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element descriptionField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;descriptionField.setAttribute(fieldName, description);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;descriptionField.appendChild(document
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.createTextNode(contentDescription));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(descriptionField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element authorField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;authorField.setAttribute(fieldName, author);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;authorField.appendChild(document.createTextNode(contentAuthor));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(authorField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Iterator<String> catItr = contentCategories.iterator();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;while (catItr.hasNext()) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String contentCategory = catItr.next();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("contentCategory " + contentCategory);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element categoryField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;categoryField.setAttribute(fieldName, category);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;categoryField.appendChild(document
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.createTextNode(contentCategory));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(categoryField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element typeField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;typeField.setAttribute(fieldName, type);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;typeField.appendChild(document.createTextNode(getMimetypeForSolrSearch(contentType)));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(typeField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element coAuthorField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;coAuthorField.setAttribute(fieldName, coAuthor);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;coAuthorField.appendChild(document.createTextNode(contentCoAuthor));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(coAuthorField);&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element contentField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;contentField.setAttribute(fieldName, text);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//CDATASection contentCdata = document.createCDATASection(passedContent);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//contentCdata.deleteData(contentCdata.get, count)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;contentField.appendChild(document.createCDATASection(cleanContent));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(contentField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//logger.debug("Content text : "+contentField.getTextContent());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element lastModifiedField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;lastModifiedField.setAttribute(fieldName, lastModified);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;lastModifiedField.appendChild(document
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.createTextNode(getLastModifiedDate()));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(lastModifiedField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;/*
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; * Commented out for future. String docKeywords = " "; Element
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; * keywordsField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; * keywordsField.setAttribute(fieldName, keywords);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; * keywordsField.appendChild(document.createTextNode(docKeywords));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; * docElement.appendChild(keywordsField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element ownerField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ownerField.setAttribute(fieldName, owner);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ownerField.appendChild(document.createTextNode(contentOwner));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(ownerField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element ratingField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ratingField.setAttribute(fieldName, rating);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ratingField.appendChild(document.createTextNode(contentRating));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(ratingField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Element urlField = document.createElement(field);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;urlField.setAttribute(fieldName, url);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;urlField.appendChild(document.createTextNode(webdavUrl));
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;docElement.appendChild(urlField);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;rootElement.appendChild(docElement);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;document.appendChild(rootElement);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//Element contentText = document.getElementById("text");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//String tempContent = contentText.getTextContent();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//String cdataContent = cdataStartTag + tempContent +cdataEndTag;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//contentText.setTextContent(cdataContent);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;DOMSource source = new DOMSource(document);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;fileNameToReturn = solrFileLoc + forwardSlash + contentUuid + xmlExt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;File file = new File(fileNameToReturn);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Result result = new StreamResult(file);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Transformer xformer = TransformerFactory.newInstance()
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.newTransformer();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;xformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "yes");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;xformer.setOutputProperty(OutputKeys.ENCODING, "UTF-16");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// xformer.setOutputProperty(OutputKeys.STANDALONE, "yes");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;xformer.transform(source, result);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} catch (Exception e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.error("Error while forming XML in formXmlFromContent() : "
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;+ e.getMessage());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;e.printStackTrace();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("fileNameToReturn in&nbsp; formXmlFromContent() : "&nbsp;&nbsp;&nbsp;+ fileNameToReturn);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return fileNameToReturn;
&nbsp;&nbsp;&nbsp;}

&nbsp;&nbsp;&nbsp;/**
&nbsp;&nbsp;&nbsp; * Method to get Last Modified date as per SOLR specified format i.e "yyyy-MM-dd'T'HH:mm:ss'Z'".
&nbsp;&nbsp;&nbsp; * @return formattedDate.
&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;public String getLastModifiedDate() {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// logger.debug("Inside getLastModifiedDate()");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Calendar lastModDate = Calendar.getInstance();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;lastModDate.setTime(new Date());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;SimpleDateFormat format = new SimpleDateFormat(
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;"yyyy-MM-dd'T'HH:mm:ss'Z'");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String formattedDate = format.format(lastModDate.getTime());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("formattedDate in getLastModifiedDate() : "
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;+ formattedDate);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return formattedDate;
&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;/** 
&nbsp;&nbsp;&nbsp; * Method to get simplified Mimetype for a content to be indexed with SOLR.
&nbsp;&nbsp;&nbsp; * @param contentType
&nbsp;&nbsp;&nbsp; * @return simplified Mimetype.
&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;public String getMimetypeForSolrSearch(String contentType){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String result = null;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if(contentType.equalsIgnoreCase("application/pdf")){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;result = "pdf";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}else if(contentType.equalsIgnoreCase("application/msword")){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;result = "word";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}else if(contentType.equalsIgnoreCase("application/vnd.excel")){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;result = "excel";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}else if(contentType.equalsIgnoreCase("application/vnd.powerpoint")){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;result = "powerpoint";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}else if(contentType.equalsIgnoreCase("text/plain")){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;result = "text";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}else if(contentType.equalsIgnoreCase("text/html")){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;result = "html";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}else if(contentType.equalsIgnoreCase("text/xml")){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;result = "xml";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Mimetype in getMimetpyeForSolr() " +result);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;return result;
&nbsp;&nbsp;&nbsp;}
}

‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍

This seems to be kind of workaround but at the same time i am looking for other better alternatives, if any.

jpfi

Hi,
there is a nice SOLR client API in java: http://wiki.apache.org/solr/Solrj that I'm using
best, jan

dynamolalit

Hi Jan,

Thanks for you reply.

I got good amount of help from SOLRJ.Below is my utility for posting XML file to SOLR.

SolrPostContentUtility.java :

package com.xxxx.alfresco.km.bpm;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.Reader;
import java.io.StringReader;
import java.io.StringWriter;
import java.io.UnsupportedEncodingException;
import java.io.Writer;
import java.net.HttpURLConnection;
import java.net.ProtocolException;
import java.net.URL;

import org.apache.log4j.Logger;

import com.xxxx.alfresco.km.property.KmPropertyReader;

/**
 * Utility class for posting XML file to SOLR server.
 * For a given well-formed XML, it posts the data of file to 
 * SOLR server & get response back.
 */
public class SolrPostContentUtility {
&nbsp;&nbsp;&nbsp;
&nbsp; private static Logger logger = Logger.getLogger(SolrPostContentUtility.class); 
&nbsp; public static final String POST_ENCODING = "UTF-8";
&nbsp; private static final String SOLR_OK_RESPONSE_EXCERPT = "<int name=\"status\">0</int>";
&nbsp; private String solrServIp = null;
&nbsp; private URL solrUrl = null;
&nbsp; 
&nbsp; /**
&nbsp;&nbsp; * Constructs an instance for posting data to the specified SOLR URL.
&nbsp;&nbsp; */
&nbsp; public SolrPostContentUtility() {
&nbsp;&nbsp;&nbsp; try{
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;KmPropertyReader kmPropertyReader = new KmPropertyReader();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; solrServIp = kmPropertyReader.getProperty("solr.server.ip");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("solrServIp in SolrPostContentUtility : "+solrServIp);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; URL passedSolrUrl = new URL(solrServIp);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; solrUrl = passedSolrUrl;
&nbsp;&nbsp;&nbsp; }catch (Exception e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.error("Error while reading property in SolrPostContentUtility : "+e.getMessage());
&nbsp;&nbsp;&nbsp;}
&nbsp; }

&nbsp; /**
&nbsp;&nbsp; * Method posting XML to SOLR & returning number of content posted successfully.
&nbsp;&nbsp; * @param fullyQldFileName
&nbsp;&nbsp; */
&nbsp; public int postXmlToSolr(String fullyQldFileName){
&nbsp;&nbsp;&nbsp;&nbsp; int result = 0;//0 for normal & 1 for error.
&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("Entering postXmlToSolr() with file name : "+fullyQldFileName);
&nbsp;&nbsp;&nbsp; try {&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;result = postFileToSolr(fullyQldFileName);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //Checking for response
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;if(result == 0){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("Committing Solr index changes after successful posting of data.");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; final StringWriter sw = new StringWriter();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; commit(sw);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; warnIfNotExpectedResponse(sw.toString(),SOLR_OK_RESPONSE_EXCERPT);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else if(result == 1){
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; logger.error("Could not commit Solr index changes due to error.");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp; } catch(IOException ioe) {
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.error("Unexpected IOException in postXmlToSolr() : " + ioe);
&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp; logger.debug("result in postXmlToSolr() : "+result);&nbsp; 
&nbsp;&nbsp;&nbsp; return result;
&nbsp; }
 
 
/**
 * Method to post XML file to SOLR.
 * It takes file name & passes it with StringWriter object to postFile().
 * @param fileName
 * @return
 * @throws IOException
 */
public int postFileToSolr(String fileName) throws IOException {
&nbsp;&nbsp;&nbsp;logger.debug("Entering postFileToSolr() with file name : "+fileName);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; int result = 0;//0 for normal & 1 for error.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; File srcFile = new File(fileName);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; final StringWriter sw = new StringWriter();&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (srcFile.canRead()) {
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; //logger.debug("File name to be posted to SOLR server in postFileToSolr() : " + srcFile.getName());
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; result = postFile(srcFile, sw);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; warnIfNotExpectedResponse(sw.toString(),SOLR_OK_RESPONSE_EXCERPT);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } else {
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; logger.error("Cannot read input file in postFileToSolr() : " + srcFile);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("result in postFileToSolr() : "+result);&nbsp; 
&nbsp;&nbsp;&nbsp; return result;
&nbsp; }
&nbsp; 
&nbsp; /**
&nbsp;&nbsp; * Opens the file and posts it's contents to the solrUrl,
&nbsp;&nbsp; * writes to response to output.
&nbsp;&nbsp; * XML should be formed using a real parser e.g. DOM & should be well-formed.
&nbsp;&nbsp; * @throws UnsupportedEncodingException 
&nbsp;&nbsp; */
&nbsp; public int postFile(File file, Writer output) 
&nbsp;&nbsp;&nbsp; throws FileNotFoundException, UnsupportedEncodingException {
&nbsp;&nbsp;&nbsp;logger.debug("Entering postFile() ");
&nbsp;&nbsp;&nbsp;int result = 0;//0 for normal & 1 for error.
&nbsp;&nbsp;&nbsp; Reader reader = new InputStreamReader(new FileInputStream(file),POST_ENCODING);
&nbsp;&nbsp;&nbsp; try {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; result = postDataToSolr(reader, output);
&nbsp;&nbsp;&nbsp; } finally {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(reader != null) reader.close();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (IOException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; throw new PostException("IOException while closing file in postFile()", e);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp; logger.debug("result in postFile() : "+result);&nbsp; 
&nbsp;&nbsp;&nbsp; return result;
&nbsp; }

&nbsp; /**
&nbsp;&nbsp; * Reads data from the data reader and posts it to solr,
&nbsp;&nbsp; * writes to the response to output
&nbsp;&nbsp; */
&nbsp; public int postDataToSolr(Reader data, Writer output) {
&nbsp;&nbsp;&nbsp;logger.debug("Entering postDataToSolr() ");
&nbsp;&nbsp;&nbsp; HttpURLConnection urlc = null;
&nbsp;&nbsp;&nbsp; int result = 0; //0 for normal & 1 for error.
&nbsp;&nbsp;&nbsp; try {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; urlc = (HttpURLConnection) solrUrl.openConnection();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; urlc.setRequestMethod("POST");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (ProtocolException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; throw new PostException("Shouldn't happen: HttpURLConnection doesn't support POST??", e);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; urlc.setDoOutput(true);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; urlc.setDoInput(true);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; urlc.setUseCaches(false);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; urlc.setAllowUserInteraction(false);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; urlc.setRequestProperty("Content-type", "text/xml; charset=" + POST_ENCODING);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; OutputStream out = urlc.getOutputStream();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Writer writer = new OutputStreamWriter(out, POST_ENCODING);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; pipeDataToSolr(data, writer);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; writer.close();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (IOException e) {
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; result = 1;//error.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; throw new PostException("IOException while posting data in postDataToSolr() ", e);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(out!=null) out.close();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; InputStream in = urlc.getInputStream();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Reader reader = new InputStreamReader(in);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; pipeDataToSolr(reader, output);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; reader.close();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (IOException e) {
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; result = 1;//error.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; throw new PostException("IOException while reading response in postDataToSolr()", e);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } finally {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(in!=null) in.close();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp; } catch (IOException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; result = 1;//error.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.error("Solr returned an error in postDataToSolr() : " + urlc.getResponseMessage());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; } catch (IOException f) { }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.error("Connection error while connecting to SOLR server in postDataToSolr() : " + e);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp; } finally {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(urlc != null){
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; urlc.disconnect();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp; logger.debug("result in postDataToSolr() : "+result); 
&nbsp;&nbsp;&nbsp; return result;
&nbsp; }

&nbsp; /**
&nbsp;&nbsp; * Pipes everything from the reader to the writer via a buffer
&nbsp;&nbsp; */
&nbsp; private static void pipeDataToSolr(Reader reader, Writer writer) throws IOException {
&nbsp;&nbsp;&nbsp;logger.debug("Entering pipeDataToSolr() ");
&nbsp;&nbsp;&nbsp; char[] buf = new char[1024];
&nbsp;&nbsp;&nbsp; int read = 0;
&nbsp;&nbsp;&nbsp; while ( (read = reader.read(buf) ) >= 0) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; writer.write(buf, 0, read);
&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp; writer.flush();
&nbsp; }
&nbsp; 
&nbsp; /**
&nbsp;&nbsp; * Custom Exception class for utility.
&nbsp;&nbsp; */
&nbsp; private class PostException extends RuntimeException {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;private static final long serialVersionUID = 1L;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;PostException(String reason,Throwable cause) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; super(reason + " POST URL = " + solrUrl ,cause);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp; 
&nbsp; /** Check what SOLR replied to a POST, and complain if it's not what we expected.
&nbsp;&nbsp; * Parse the response and check it XMLwise, here we just check it as an unparsed String&nbsp; 
&nbsp;&nbsp; */
&nbsp; static void warnIfNotExpectedResponse(String actual,String expected) {
&nbsp;&nbsp;&nbsp; if(actual.indexOf(expected) < 0) {
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.error("Unexpected response from Solr: '" + actual + "' does not contain '" + expected + "'");
&nbsp;&nbsp;&nbsp; }
&nbsp; }&nbsp; 

&nbsp; /**
&nbsp;&nbsp; * Does a simple commit operation 
&nbsp;&nbsp; */
&nbsp; public void commit(Writer output) throws IOException {
&nbsp;&nbsp;&nbsp;logger.debug("Entering commit()");
&nbsp;&nbsp;&nbsp; postDataToSolr(new StringReader("<commit/>"), output);
&nbsp; }&nbsp;&nbsp;&nbsp;&nbsp; 
}
‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍

KMSolrSearchActionHandler.java invoking utility :

package com.xxxx.alfresco.km.bpm;

import java.io.File;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import javax.faces.context.FacesContext;

import org.alfresco.model.ContentModel;
import org.alfresco.repo.content.MimetypeMap;
import org.alfresco.repo.content.transform.ContentTransformer;
import org.alfresco.repo.workflow.jbpm.JBPMSpringActionHandler;
import org.alfresco.service.ServiceRegistry;
import org.alfresco.service.cmr.repository.ContentData;
import org.alfresco.service.cmr.repository.ContentIOException;
import org.alfresco.service.cmr.repository.ContentReader;
import org.alfresco.service.cmr.repository.ContentService;
import org.alfresco.service.cmr.repository.ContentWriter;
import org.alfresco.service.cmr.repository.NodeRef;
import org.alfresco.service.cmr.repository.NodeService;
import org.alfresco.service.namespace.QName;
import org.alfresco.web.bean.repository.Node;
import org.alfresco.web.bean.repository.Repository;
import org.alfresco.web.ui.common.Utils;
import org.alfresco.web.ui.common.Utils.URLMode;
import org.apache.log4j.Logger;
import org.jbpm.context.exe.ContextInstance;
import org.jbpm.graph.exe.ExecutionContext;
import org.springframework.beans.factory.BeanFactory;

import com.xxxx.alfresco.km.property.KmPropertyReader;

/**
 * @author Lalit Jangra
 * Class to handle SOLR integration with Alfresco.
 * Once content is approved & moved back to original upload location,
 * it will check for 'cm:contentStatus' property of content.
 * If it is set to 'approved', another workflow named 'SolrSearchWF' is triggered.
 * This workflow will extract all required metadata properties from content noderef &
 * form an XML to be posted to SOLR along with content as text string.
 * Finally XML will be posted to SOLR using SOLR Content Post Utility.
 */
public class KMSolrSearchActionHandler extends JBPMSpringActionHandler{
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;private static final long serialVersionUID = 1L;
&nbsp;&nbsp;&nbsp;private static Logger logger = Logger
&nbsp;&nbsp;&nbsp;.getLogger(KMSolrSearchActionHandler.class);
&nbsp;&nbsp;&nbsp;private String solrServIp = null;
&nbsp;&nbsp;&nbsp;private String solrFileLoc = null;
&nbsp;&nbsp;&nbsp;private&nbsp;&nbsp;&nbsp;String alfServerIp = null;
&nbsp;&nbsp;&nbsp;private NodeService nodeService;
&nbsp;&nbsp;&nbsp;private ServiceRegistry services;
&nbsp;&nbsp;&nbsp;ContentService contentService = null;
&nbsp;&nbsp;&nbsp;List<String> categoryList = null;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;private String webdavUrl = null;
&nbsp;&nbsp;&nbsp;//private Collection<NodeRef> categories = null;
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;/**
&nbsp;&nbsp;&nbsp; * Method to initialize services.
&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;@Override
&nbsp;&nbsp;&nbsp;protected void initialiseHandler(BeanFactory factory) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;services = (ServiceRegistry) factory
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.getBean(ServiceRegistry.SERVICE_REGISTRY);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;nodeService = services.getNodeService();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;contentService = services.getContentService();&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;}

&nbsp;&nbsp;&nbsp;/**
&nbsp;&nbsp;&nbsp; * Method calling formSolrXml() passing noderef of the content 
&nbsp;&nbsp;&nbsp; * forming SOLR search specific XML.
&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;@Override
&nbsp;&nbsp;&nbsp;public void execute(ExecutionContext context) throws Exception {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Inside execute of KMSolrSearchActionHandler");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;KmPropertyReader kmPropertyReader = new KmPropertyReader();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; solrServIp = kmPropertyReader.getProperty("solr.server.ip");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("solrServIp in KMSolrSearchActionHandler : "+solrServIp);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; solrFileLoc = kmPropertyReader.getProperty("solr.file.location");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("solrFileLoc in KMSolrSearchActionHandler : "+solrFileLoc);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; alfServerIp = kmPropertyReader.getProperty("alfresco.server.ip");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("alfServerIp in KMSolrSearchActionHandler : "+alfServerIp);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }catch (Exception e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.error("Error while reading property in KMSolrSearchActionHandler : "+e.getMessage());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;final ContextInstance contextInstance = context.getContextInstance();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;NodeRef nodeRef = (NodeRef) contextInstance.getVariable("nodeRef");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//Forming SOLR XML.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;formSolrXml(nodeRef);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;/**
&nbsp;&nbsp;&nbsp; * Method to form XML to be posted to SOLR.
&nbsp;&nbsp;&nbsp; * Once well-formed XML is formed, it will call postSolrXML method to post 
&nbsp;&nbsp;&nbsp; * the same XML to SOLR using Content Post Utility.
&nbsp;&nbsp;&nbsp; * @param nodeRef
&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;@SuppressWarnings("unchecked")
&nbsp;&nbsp;&nbsp;public void formSolrXml(NodeRef nodeRef){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Inside formSolrXml in KMSolrSearchActionHandler : "+nodeRef);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Node contentNode = new Node(nodeRef);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String repoPath = Utils.generateURL(FacesContext.getCurrentInstance(), contentNode, URLMode.WEBDAV);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//logger.debug("repoPath "+repoPath);&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;webdavUrl = alfServerIp+repoPath;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("webdavUrl in formSolrXml() : "+webdavUrl);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String noderef = nodeRef.toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String[] tempNodeRef = noderef.split("SpacesStore/");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String contentUuid = tempNodeRef[1];
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String category = "";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String content = "";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//Create an XML using XMLFormationBean & pass it to SOLR.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;XmlFormationBean xmlFormationBean = new XmlFormationBean();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName statusQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}contentStatus");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName ownerQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}originalOwner");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName ratingQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}contentRating");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName nameQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}name");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName coAuthorQname = QName.createQName("{{http://www.xxxx.com/model/km/content/1.0}coauthor");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName titleQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}title");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName descriptionQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}description");&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName authorQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}author");
//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName kTQName = QName.createQName("{http://www.alfresco.org/model/content/1.0}Knowledge Type");
//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName kPQName = QName.createQName("{http://www.alfresco.org/model/content/1.0}KP Domain");
//&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName typeQname = QName.createQName("{http://www.alfresco.org/model/content/1.0}content");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cName = nodeService.getProperty(nodeRef, nameQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Name in formSolrXml : "+cName);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cStatus = nodeService.getProperty(nodeRef, statusQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Status in formSolrXml : "+cStatus);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cOwner = nodeService.getProperty(nodeRef, ownerQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Owner in formSolrXml :&nbsp; "+cOwner);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cRating = nodeService.getProperty(nodeRef, ratingQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Rating in formSolrXml :&nbsp; "+cRating);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cCoAuthor = "";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cCoAuthor = nodeService.getProperty(nodeRef, coAuthorQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}catch (NullPointerException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Null CoAuthor in formSolrXml()");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content CoAuthor in formSolrXml : "+cCoAuthor);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cTitle = "";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cTitle = nodeService.getProperty(nodeRef, titleQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}catch (NullPointerException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Null Title in formSolrXml()");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Title in formSolrXml :&nbsp; "+cTitle);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cDesc = "";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cDesc = nodeService.getProperty(nodeRef, descriptionQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}catch (NullPointerException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Null Description in formSolrXml()");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Description in formSolrXml :&nbsp; "+cDesc);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cAuthor = "";
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cAuthor = nodeService.getProperty(nodeRef, authorQname).toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}catch (NullPointerException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Null Author in formSolrXml()");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Author in formSolrXml :&nbsp; "+cAuthor);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String cType =&nbsp; getContentMimeType(nodeRef);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Content Mimetype in formSolrXml :&nbsp; "+cType);&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Collection<NodeRef> categories = (Collection<NodeRef>)nodeService.getProperty(nodeRef, ContentModel.PROP_CATEGORIES);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("categories size : "+categories.size());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Iterator itr11 =&nbsp; categories.iterator();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;categoryList = new ArrayList<String>();&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;while(itr11.hasNext()){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;NodeRef catNodeRef = (NodeRef) itr11.next();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;category = Repository.getNameForNode(nodeService, catNodeRef);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("category name in formSolrXml : "+category);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;categoryList.add(category);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("categoryList size : "+categoryList.size());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}catch (NullPointerException e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.error("Null categories in formSolrXml() ");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//Transforming content to plain text format & extracting text from content as a string.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;contentService = services.getContentService();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ContentReader reader = contentService.getReader(nodeRef, ContentModel.PROP_CONTENT);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (reader != null && reader.exists())
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // get the transformer
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ContentTransformer transformer = contentService.getTransformer(reader.getMimetype(), MimetypeMap.MIMETYPE_TEXT_PLAIN);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (transformer != null)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // We have a transformer that is fast enough
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ContentWriter writer = contentService.getTempWriter();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; writer.setMimetype(MimetypeMap.MIMETYPE_TEXT_PLAIN);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;transformer.transform(reader, writer);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // point the reader to the new-written content
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; reader = writer.getReader();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; // Check that the reader is a view onto something concrete
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (!reader.exists())
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.error("Error while getting reader in KMSolrSearchActionHandler ");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; throw new ContentIOException("The transformation did not write any content, yet: \n"
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; + "&nbsp;&nbsp; transformer:&nbsp;&nbsp;&nbsp;&nbsp; " + transformer + "\n" + "&nbsp;&nbsp; temp writer:&nbsp;&nbsp;&nbsp;&nbsp; " + writer);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; content = reader.getContentString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; catch (ContentIOException e)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.error("Error in transforming content : "+e.getMessage());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("Length of content as a string for SOLR indexing !! :&nbsp; "+content.length());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //Forming well-formed SOLR search XML.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String finalFileName =&nbsp; xmlFormationBean.formXmlFromContent(contentUuid,content, cType, cAuthor, cCoAuthor, cTitle, cOwner, categoryList, cDesc, cStatus, cRating, cName, solrFileLoc,webdavUrl);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("finalFileName in formSolrXml : "+finalFileName);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //Posting well-formed XML to SOLR server.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; postSolrXML(finalFileName,cName,nodeRef);
&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;/**
&nbsp;&nbsp;&nbsp; * Method to post well-formed XML to SOLR using content post utility.
&nbsp;&nbsp;&nbsp; * @param fileName
&nbsp;&nbsp;&nbsp; * @param contentName
&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;public void postSolrXML(String fullFileName,String contentName, NodeRef nodeRef){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Entering postSolrXML() with content to be posted to SOLR : "+contentName +" &&nbsp; fullFileName : "+fullFileName);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//Only if these is a non-null file, then it should be posted to SOLR.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; File file = new File(fullFileName); 
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if(file.length() > 0){&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; try {
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; //Calling&nbsp; SolrPostContentUtility.
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; logger.debug("Posting content to SOLR using utility by passing fully qualified file name,if result is 0, it's OK . if it's 1, its error!");
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; SolrPostContentUtility utility = new SolrPostContentUtility();
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; int outCome = utility.postXmlToSolr(fullFileName);
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; //If outCome is 0, it is OK , if it is 1, it's error!
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; if(outCome == 0){
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; //Set km:underWorkflow to indexed for this content.
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("\n *************** Content named : "+contentName+" : successfully posted to SOLR. *************** \n");
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("\n *************** nodeRef of content posted successfully : " + nodeRef + " ***************");
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("\n *************** webdavUrl of content posted successfully : " + webdavUrl + " ***************");
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; QName underWorkflowQname = QName.createQName("{http://www.xxxx.com/model/km/content/1.0}underWorkflow");
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String underWorkflowFlag = nodeService.getProperty(nodeRef, underWorkflowQname).toString();
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.debug("km:underWorkflow set value in postSolrXML after post : "+underWorkflowFlag);
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Map<QName, Serializable> propertyMap = nodeService.getProperties(nodeRef);
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; propertyMap.put(underWorkflowQname, "indexed");
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; nodeService.setProperties(nodeRef, propertyMap);
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; }else if(outCome == 1){
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; logger.error("\n *************** Content named : "+contentName +" : could NOT be posted successfully to SOLR. *************** \n");
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; }&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; 
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} catch (Exception e) {
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logger.debug("Error while posting file : "+e.getMessage());
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;e.printStackTrace();
&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }else{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;logger.error("Null XML formed");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;/**
&nbsp;&nbsp;&nbsp; * Method to get MimeType of a content passing it's nodeRef.
&nbsp;&nbsp;&nbsp; * @param nodeRef
&nbsp;&nbsp;&nbsp; * @return MimeType
&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;public String getContentMimeType(NodeRef nodeRef){
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;QName PROP_QNAME_CONTENT = QName.createQName("http://www.alfresco.org/model/content/1.0", "content");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ContentData contentData = (ContentData) nodeService.getProperty(nodeRef, PROP_QNAME_CONTENT);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; String originalMimeType = contentData.getMimetype();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return originalMimeType;
&nbsp;&nbsp;&nbsp;}

}

‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍

Its working fine.

jain_kumar11

Hi Lalit,

Could you please share following files as well KmPropertyReader.java and XmlFormationBean.java as existing code is using some reference from these.

KJ

dynamolalit

Hi Jain,

KmPropertyReader.java is nothing but a java class reading properties from a property file.

Also XmlFormationBean.java is a java class creating xml using sax parser to be deployed to solr.

All other relevant class i have already shared here.

All the best.