Package com.bytedesk.kbase.article.mq

Class ArticleMessageConsumer

java.lang.Object

com.bytedesk.kbase.article.mq.ArticleMessageConsumer

@Component
public class ArticleMessageConsumer
extends Object

文章索引消费者 用于处理文章索引队列中的消息

Field Summary

Fields

Modifier and Type	Field	Description
private final ArticleElasticService	articleElasticService
private final ArticleRestService	articleRestService
private ArticleVectorService	articleVectorService
private final Random	random

Constructor Summary

Constructors

Constructor	Description
ArticleMessageConsumer(ArticleElasticService articleElasticService, ArticleRestService articleRestService)

Method Summary

Modifier and Type	Method	Description
private void	handleDeleteOperation(ArticleEntity article, ArticleIndexMessage message)	处理删除操作
private void	handleIndexOperation(ArticleEntity article, ArticleIndexMessage message)	处理索引操作
void	processIndexMessage(jakarta.jms.Message jmsMessage, ArticleIndexMessage message)	处理文章索引队列中的消息 使用客户端确认模式，只有成功处理后才确认消息 增强了对乐观锁冲突的处理

Methods inherited from class java.lang.Object

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

Field Details

articleElasticService

private final ArticleElasticService articleElasticService

articleRestService

private final ArticleRestService articleRestService

articleVectorService

@Autowired(required=false)
private ArticleVectorService articleVectorService

random

private final Random random

Constructor Details

ArticleMessageConsumer

public ArticleMessageConsumer(ArticleElasticService articleElasticService,
 ArticleRestService articleRestService)

Method Details

processIndexMessage

@JmsListener(destination="bytedesk.queue.article.index",
             containerFactory="jmsListenerContainerFactory")
public void processIndexMessage(jakarta.jms.Message jmsMessage,
 ArticleIndexMessage message)

处理文章索引队列中的消息 使用客户端确认模式，只有成功处理后才确认消息 增强了对乐观锁冲突的处理

Parameters:

jmsMessage - JMS原始消息

message - 文章索引消息

handleIndexOperation

private void handleIndexOperation(ArticleEntity article,
 ArticleIndexMessage message)

处理索引操作

Parameters:

article - 文章实体

message - 索引消息

handleDeleteOperation

private void handleDeleteOperation(ArticleEntity article,
 ArticleIndexMessage message)

处理删除操作

Parameters:

article - 文章实体

message - 索引消息