| | |
|---|
| | | /** |
|---|
| | | * 反馈创建的topic（mdc中），本应用接收并处理 |
|---|
| | | */ |
|---|
| | | public static final String FEEDBACK_TOPIC = "mdc/feedback"; |
|---|
| | | //public static final String FEEDBACK_TOPIC = "mdc/feedback"; |
|---|
| | | |
|---|
| | | public static final String WOCKSTATION_CREATE_TOPIC = "mdc/workstation-create"; |
|---|
| | | |
|---|
| | |
|---|
| | | MessageDO messageDO = new MessageDO(); |
|---|
| | | messageDO.setNeedBroadcast(false); |
|---|
| | | String msgtxt =JSONUtil.toJsonStr(jsonWebSocketMessage); |
|---|
| | | logger.info("websockettxt={}",msgtxt); |
|---|
| | | logger.info("send_to_page_websockettxt={}",msgtxt); |
|---|
| | | messageDO.setMessageText(msgtxt); |
|---|
| | | |
|---|
| | | messageDistributor.distribute(messageDO); |
|---|
