| | |
|---|
| | | if (!Constant.IS_TEST)
|
|---|
| | | producer.send(message);
|
|---|
| | | } else {// 修改
|
|---|
| | | UserInfoUpdateMQMsg mqMsg = null;
|
|---|
| | |
|
|---|
| | | if (type == ModifyTypeEnum.portrait) {
|
|---|
| | | mqMsg = new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.portrait, value, new Date());
|
|---|
| | | } else if (type == ModifyTypeEnum.nickName)
|
|---|
| | | mqMsg = new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.nickName, value, new Date());
|
|---|
| | | else if (type == ModifyTypeEnum.setWeiXinNum)
|
|---|
| | | mqMsg = new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.wxId, value, new Date());
|
|---|
| | |
|
|---|
| | | if (mqMsg != null) {
|
|---|
| | | Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER,
|
|---|
| | | UserTopicTagEnum.userInfoUpdate, new Gson().toJson(new UserInfoUpdateMQMsg(uid,
|
|---|
| | | UserInfoUpdateTypeEnum.portrait, value, new Date())));
|
|---|
| | | UserTopicTagEnum.userInfoUpdate, mqMsg);
|
|---|
| | | producer.send(message);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
