Package com.bytedesk.kbase.llm_file.mq

Class FileChunkMessageConsumer

java.lang.Object

com.bytedesk.kbase.llm_file.mq.FileChunkMessageConsumer

@Component
public class FileChunkMessageConsumer
extends Object

文件Chunk消息消费者 处理文件chunk相关的异步消息

Field Summary

Fields

Modifier and Type	Field	Description
private ChunkRestService	chunkRestService
private FileRestService	fileRestService

Constructor Summary

Constructors

Constructor	Description
FileChunkMessageConsumer()

Method Summary

Modifier and Type	Method	Description
void	handleChunkComplete(String fileId)	处理文件块处理完成消息
void	handleChunkIndex(String chunkIds)	处理文件块索引消息
void	handleChunkRetry(String chunkId)	处理文件块重试消息

Methods inherited from class java.lang.Object

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

Field Details

fileRestService

@Autowired
private FileRestService fileRestService

chunkRestService

@Autowired
private ChunkRestService chunkRestService

Constructor Details

FileChunkMessageConsumer

public FileChunkMessageConsumer()

Method Details

handleChunkRetry

@JmsListener(destination="bytedesk.queue.file.chunk.retry",
             containerFactory="jmsArtemisQueueFactory")
public void handleChunkRetry(String chunkId)

处理文件块重试消息

handleChunkComplete

@JmsListener(destination="bytedesk.queue.file.chunk.complete",
             containerFactory="jmsArtemisQueueFactory")
public void handleChunkComplete(String fileId)

处理文件块处理完成消息

handleChunkIndex

@JmsListener(destination="bytedesk.queue.file.chunk.index",
             containerFactory="jmsArtemisQueueFactory")
public void handleChunkIndex(String chunkIds)

处理文件块索引消息