|
@@ -137,21 +137,6 @@ public class MemberUserServiceImpl implements MemberUserService {
|
|
|
return user;
|
|
|
}
|
|
|
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public void registerTransactionSynchronization(Long userId, Long linkId) {
|
|
|
- // 发送 消息:用户创建
|
|
|
- TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
|
|
|
- @Override
|
|
|
- public void afterCommit() {
|
|
|
- sharePathProducer.sendSharePathCreatMessage(linkId, userId);
|
|
|
- if (linkId != null) {
|
|
|
- shareLinkRegisterProducer.sendShareLinkRegisterMessage(linkId, userId);
|
|
|
- }
|
|
|
- memberUserProducer.sendUserCreateMessage(userId);
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
//现在这个不用了
|
|
|
// @Transactional(rollbackFor = Exception.class)
|
|
|
// public void registerTransactionSynchronization(Long userId, Long linkId) {
|