Package com.bytedesk.kbase.article.mq

Class ArticleIndexMessageListener

java.lang.Object

com.bytedesk.kbase.article.mq.ArticleIndexMessageListener

@Component
public class ArticleIndexMessageListener
extends Object

文章索引消息监听器 处理文章的索引和删除消息

Field Summary

Fields

Modifier and Type	Field	Description
private final ArticleRestService	articleRestService
private ArticleVectorService	articleVectorService

Constructor Summary

Constructors

Constructor	Description
ArticleIndexMessageListener(ArticleRestService articleRestService)

Method Summary

Modifier and Type	Method	Description
void	onIndexMessage(ArticleIndexMessage message)	监听文章索引队列，处理索引和删除操作 使用并发消费者提高吞吐量，但保持消息的顺序处理

Methods inherited from class java.lang.Object

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

Field Details

articleRestService

private final ArticleRestService articleRestService

articleVectorService

@Autowired(required=false)
private ArticleVectorService articleVectorService

Constructor Details

ArticleIndexMessageListener

public ArticleIndexMessageListener(ArticleRestService articleRestService)

Method Details

onIndexMessage

@JmsListener(destination="bytedesk.queue.article.index",
             concurrency="3-5",
             containerFactory="jmsListenerContainerFactory")
public void onIndexMessage(ArticleIndexMessage message)

监听文章索引队列，处理索引和删除操作 使用并发消费者提高吞吐量，但保持消息的顺序处理

Parameters:

message - 文章索引消息