Package com.bytedesk.service.queue_member.mq

Class QueueMemberConsumer

java.lang.Object

com.bytedesk.service.queue_member.mq.QueueMemberConsumer

All Implemented Interfaces:

jakarta.jms.MessageListener

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

队列成员消息消费者 用于处理队列成员更新消息

Field Summary

Fields

Modifier and Type	Field	Description
private OptimisticLockingHandler	optimisticLockingHandler
private QueueMemberRepository	queueMemberRepository

Constructor Summary

Constructors

Constructor	Description
QueueMemberConsumer()

Method Summary

Modifier and Type	Method	Description
private void	handleDelete(QueueMemberMessage message)	处理删除操作
private void	handleUpdate(QueueMemberMessage message)	处理更新操作
private boolean	isQueueMemberMessage(jakarta.jms.Message message)	验证消息类型是否是队列成员消息
void	onMessage(jakarta.jms.Message message)
private void	updateFields(QueueMemberEntity member, Map<String,Object> updates)	更新其他字段
private void	updateMessageCounts(QueueMemberEntity member, QueueMemberMessage message)	更新消息计数

Methods inherited from class java.lang.Object

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

Field Details

queueMemberRepository

@Autowired
private QueueMemberRepository queueMemberRepository

optimisticLockingHandler

@Autowired
private OptimisticLockingHandler optimisticLockingHandler

Constructor Details

QueueMemberConsumer

public QueueMemberConsumer()

Method Details

isQueueMemberMessage

private boolean isQueueMemberMessage(jakarta.jms.Message message)

验证消息类型是否是队列成员消息

onMessage

@JmsListener(destination="bytedesk.queue.member.update")
@Transactional
public void onMessage(jakarta.jms.Message message)

Specified by:

onMessage in interface jakarta.jms.MessageListener

handleUpdate

private void handleUpdate(QueueMemberMessage message)

处理更新操作

handleDelete

private void handleDelete(QueueMemberMessage message)

处理删除操作

updateMessageCounts

private void updateMessageCounts(QueueMemberEntity member,
 QueueMemberMessage message)

更新消息计数

updateFields

private void updateFields(QueueMemberEntity member,
 Map<String,Object> updates)

更新其他字段