Package com.bytedesk.kbase.quick_reply.mq

Class QuickReplyIndexConsumer

java.lang.Object

com.bytedesk.kbase.quick_reply.mq.QuickReplyIndexConsumer

@Component
public class QuickReplyIndexConsumer
extends Object

快捷回复索引消费者

Field Summary

Fields

Modifier and Type	Field	Description
private QuickReplyElasticService	quickReplyElasticService
private QuickReplyRepository	quickReplyRepository
private QuickReplyVectorService	quickReplyVectorService

Constructor Summary

Constructors

Constructor	Description
QuickReplyIndexConsumer()

Method Summary

Modifier and Type	Method	Description
void	handleQuickReplyIndexMessage(QuickReplyIndexMessage indexMessage, jakarta.jms.Message message)	处理快捷回复索引消息

Methods inherited from class java.lang.Object

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

Field Details

quickReplyRepository

@Autowired
private QuickReplyRepository quickReplyRepository

quickReplyElasticService

@Autowired
private QuickReplyElasticService quickReplyElasticService

quickReplyVectorService

@Autowired
private QuickReplyVectorService quickReplyVectorService

Constructor Details

QuickReplyIndexConsumer

public QuickReplyIndexConsumer()

Method Details

handleQuickReplyIndexMessage

@JmsListener(destination="bytedesk.queue.quick_reply.index",
             containerFactory="jmsArtemisQueueFactory")
public void handleQuickReplyIndexMessage(QuickReplyIndexMessage indexMessage,
 jakarta.jms.Message message)
                                  throws jakarta.jms.JMSException

处理快捷回复索引消息

Throws:

jakarta.jms.JMSException