使用设置监听的方式,在收到MQ消息后,需要对消息进行解析处理,我是直接在这个内部类里面调用外部类的方法进行处理的。想请教一下,外部类是否可以获取到这个内部类收到的MQ消息?
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
TextMessage tm = null;
String msg;
if(message instanceof ActiveMQTextMessage){
tm = (TextMessage) message;
try {
msg = tm.getText();
logger.info("获取前台发送的MQ信息" + msg);
System.out.println( msg);
String result="";
is_summary=getInstance().getIs_summary(msg);
List<FundsInvestorInfoModel> iList=getInstance().getInvestorInfoModelList(msg);
List<String> ticketList=getInstance().getTicketList(msg);
is_all=getInstance().is_all(msg);
result=getInstance().checkDeposit(is_summary, is_all, iList, ticketList);
getInstance().sendMQ(result,"");
logger.info("返回到前台的MQ消息" +result);
System.out.println( result);
} catch (JMSException e) {
logger.error(e.getMessage(), e);
}
}
}
});