Package com.bytedesk.core.member.mq

Class MemberBatchMessageService

java.lang.Object

com.bytedesk.core.member.mq.MemberBatchMessageService

@Service
public class MemberBatchMessageService
extends Object

Member批量导入消息服务 参考FAQ的异步处理模式，用于发送Member批量导入消息到消息队列

Field Summary

Fields

Modifier and Type	Field	Description
private org.springframework.jms.core.JmsTemplate	jmsTemplate

Constructor Summary

Constructors

Constructor	Description
MemberBatchMessageService()

Method Summary

Modifier and Type	Method	Description
void	sendBatchImportMessages(List<MemberExcelImport> memberExcelList, String orgUid)	发送批量导入消息 将Member列表分批发送到消息队列，避免大批量数据的并发冲突
void	sendRetryMessage(MemberBatchMessage originalMessage, long retryDelay)	发送重试消息 当Member创建失败时，重新发送到队列进行重试

Methods inherited from class java.lang.Object

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

Field Details

jmsTemplate

@Autowired
private org.springframework.jms.core.JmsTemplate jmsTemplate

Constructor Details

MemberBatchMessageService

public MemberBatchMessageService()

Method Details

sendBatchImportMessages

public void sendBatchImportMessages(List<MemberExcelImport> memberExcelList,
 String orgUid)

发送批量导入消息 将Member列表分批发送到消息队列，避免大批量数据的并发冲突

Parameters:

memberExcelList - Member Excel数据列表

orgUid - 组织唯一标识

sendRetryMessage

public void sendRetryMessage(MemberBatchMessage originalMessage,
 long retryDelay)

发送重试消息 当Member创建失败时，重新发送到队列进行重试

Parameters:

originalMessage - 原始消息

retryDelay - 重试延迟（毫秒）