|
@ -54,16 +54,19 @@ public class RedisMsgPubSubListener extends JedisPubSub {
|
|
|
|
|
|
@Override
|
|
|
public void onMessage(String channel, String message) {
|
|
|
logger.info("redis_onMessage...");
|
|
|
logger.info("redis_onMessage...:"+message);
|
|
|
//this.unsubscribe();
|
|
|
JSONObject json = new JSONObject(message);
|
|
|
String title = json.getString("title");
|
|
|
if("redisAddPrescription".equals(title)){
|
|
|
logger.info(json.toString());
|
|
|
//审核消息发送
|
|
|
prescriptionInfoService.onMesSquareState(message);
|
|
|
try{
|
|
|
JSONObject json = new JSONObject(message);
|
|
|
String title = json.getString("title");
|
|
|
if("redisAddPrescription".equals(title)){
|
|
|
logger.info(json.toString());
|
|
|
//审核消息发送
|
|
|
prescriptionInfoService.onMesSquareState(message);
|
|
|
}
|
|
|
}catch (Exception e){
|
|
|
logger.error("redis_error...",e);
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
@Override
|