Package com.viglet.turing.api.sn.queue

Class TurSNProcessQueue

java.lang.Object

com.viglet.turing.api.sn.queue.TurSNProcessQueue

@Component
public class TurSNProcessQueue
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT
static final String	DEINDEXED
static final String	INDEXED

Constructor Summary

Constructors

Constructor

Description

TurSNProcessQueue(TurSolr turSolr, TurSNSiteRepository turSNSiteRepository, TurSNSiteLocaleRepository turSNSiteLocaleRepository, TurSolrInstanceProcess turSolrInstanceProcess, TurSNMergeProvidersProcess turSNMergeProvidersProcess, TurSNSpotlightProcess turSNSpotlightProcess, TurSNSiteFieldRepository turSNSiteFieldRepository, TurSNSiteFieldExtRepository turSNSiteFieldExtRepository, TurSNSiteFieldExtFacetRepository turSNSiteFieldExtFacetRepository, TurSEInstanceRepository turSEInstanceRepository)

Method Summary

Modifier and Type	Method	Description
boolean	deIndex(TurSNJobItem turSNJobItem, TurSNSite turSNSite)
void	receiveIndexingQueue(TurSNJobItems turSNJobItems)
Map<String,Object>	removeDuplicateTerms(Map<String,Object> attributes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DEFAULT

public static final String DEFAULT

See Also:

• Constant Field Values

INDEXED

public static final String INDEXED

See Also:

• Constant Field Values

DEINDEXED

public static final String DEINDEXED

See Also:

• Constant Field Values

Constructor Details

TurSNProcessQueue

public TurSNProcessQueue(TurSolr turSolr,
 TurSNSiteRepository turSNSiteRepository,
 TurSNSiteLocaleRepository turSNSiteLocaleRepository,
 TurSolrInstanceProcess turSolrInstanceProcess,
 TurSNMergeProvidersProcess turSNMergeProvidersProcess,
 TurSNSpotlightProcess turSNSpotlightProcess,
 TurSNSiteFieldRepository turSNSiteFieldRepository,
 TurSNSiteFieldExtRepository turSNSiteFieldExtRepository,
 TurSNSiteFieldExtFacetRepository turSNSiteFieldExtFacetRepository,
 TurSEInstanceRepository turSEInstanceRepository)

Method Details

receiveIndexingQueue

@JmsListener(destination="indexing.queue")
@Transactional
public void receiveIndexingQueue(TurSNJobItems turSNJobItems)

deIndex

public boolean deIndex(TurSNJobItem turSNJobItem,
 TurSNSite turSNSite)

removeDuplicateTerms

public Map<String,Object> removeDuplicateTerms(Map<String,Object> attributes)