Package com.bytedesk.core.member.mq

Class MemberBatchConsumer

java.lang.Object

com.bytedesk.core.member.mq.MemberBatchConsumer

All Implemented Interfaces:

jakarta.jms.MessageListener

@Component
public class MemberBatchConsumer
extends Object
implements jakarta.jms.MessageListener

Member批量导入消息消费者 参考FAQ的异步处理模式，用于处理Member批量导入消息

Field Summary

Fields

Modifier and Type	Field	Description
private static final long	BASE_RETRY_DELAY	重试延迟基数（毫秒）
private static final int	MAX_RETRY_COUNT	最大重试次数
private MemberBatchMessageService	memberBatchMessageService
private MemberRestService	memberRestService

Constructor Summary

Constructors

Constructor	Description
MemberBatchConsumer()

Method Summary

Modifier and Type	Method	Description
private void	handleProcessingFailure(MemberBatchMessage batchMessage, jakarta.jms.Message message)	处理失败的处理逻辑，采用指数退避策略进行重试
void	onMessage(jakarta.jms.Message message)
private boolean	processBatchImport(MemberBatchMessage batchMessage)	处理Member批量导入

Methods inherited from class java.lang.Object

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

Field Details

memberRestService

@Autowired
private MemberRestService memberRestService

memberBatchMessageService

@Autowired
private MemberBatchMessageService memberBatchMessageService

MAX_RETRY_COUNT

private static final int MAX_RETRY_COUNT

最大重试次数

See Also:

• Constant Field Values

BASE_RETRY_DELAY

private static final long BASE_RETRY_DELAY

重试延迟基数（毫秒）

See Also:

• Constant Field Values

Constructor Details

MemberBatchConsumer

public MemberBatchConsumer()

Method Details

onMessage

@JmsListener(destination="bytedesk.queue.member.batch.import",
             containerFactory="jmsArtemisQueueFactory")
@Transactional
public void onMessage(jakarta.jms.Message message)

Specified by:

onMessage in interface jakarta.jms.MessageListener

processBatchImport

private boolean processBatchImport(MemberBatchMessage batchMessage)

处理Member批量导入

handleProcessingFailure

private void handleProcessingFailure(MemberBatchMessage batchMessage,
 jakarta.jms.Message message)
                              throws jakarta.jms.JMSException

处理失败的处理逻辑，采用指数退避策略进行重试

Throws:

jakarta.jms.JMSException