| | |
|---|
| | | import com.qianwen.smartman.modules.sync.util.CodeUtil; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 企业微信消息消费 |
|---|
| | | */ |
|---|
| | | @RocketMQMessageListener(topic = QyWechatConstant.WECHAT_TOPIC, consumerGroup = QyWechatConstant.WECHAT_GROUP) |
|---|
| | | @Component |
|---|
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/sync/message/consumer/QyWechatSyncConsumer.class */ |
|---|
| | | public class QyWechatSyncConsumer implements RocketMQListener<JSONObject> { |
|---|
| | | private static final Logger log = LoggerFactory.getLogger(QyWechatSyncConsumer.class); |
|---|
| | | private final SseEmitterServer sseEmitterServer; |
|---|
