Package com.bytedesk.service.queue_member.mq

Class QueueMemberMessageService

java.lang.Object
com.bytedesk.service.queue_member.mq.QueueMemberMessageService
@Service public class QueueMemberMessageService extends Object
队列成员消息服务 用于发送队列成员更新消息到消息队列

  • Field Details

    • jmsTemplate

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

  • Constructor Details

    • QueueMemberMessageService

      public QueueMemberMessageService()

  • Method Details

    • sendUpdateMessage

      public void sendUpdateMessage(QueueMemberEntity member, Map<String,Object> updates)
      发送队列成员更新消息
      Parameters:
      member - 队列成员实体
      updates - 需要更新的字段

    • sendDeleteMessage

      public void sendDeleteMessage(String memberUid)
      发送队列成员删除消息
      Parameters:
      memberUid - 队列成员唯一标识

    • sendMessageCountUpdate

      public void sendMessageCountUpdate(QueueMemberEntity member)
      发送消息计数更新消息
      Parameters:
      member - 队列成员实体

    • sendTimestampUpdate

      public void sendTimestampUpdate(QueueMemberEntity member)
      发送时间戳更新消息
      Parameters:
      member - 队列成员实体

    • sendStatusUpdate

      public void sendStatusUpdate(QueueMemberEntity member)
      发送状态更新消息
      Parameters:
      member - 队列成员实体