|
@@ -138,6 +138,7 @@ public class JmsListener {
|
|
|
return "无消息";
|
|
|
}
|
|
|
for(LuceneMessageInterface luceneMessage : luceneMessages){
|
|
|
+ logger.info("LuceneMessage.id..." + luceneMessage.getId());
|
|
|
try {
|
|
|
process(luceneMessage);
|
|
|
} catch (Throwable e) {
|
|
@@ -258,10 +259,12 @@ public class JmsListener {
|
|
|
if (luceneMessage instanceof com.uas.search.console.b2b.jms.platformb2b.LuceneMessage) {
|
|
|
com.uas.search.console.b2b.jms.platformb2b.LuceneMessageDao luceneMessageDao = ContextUtils.getBean(com.uas.search.console.b2b.jms.platformb2b.LuceneMessageDao.class);
|
|
|
luceneMessageDao.save((com.uas.search.console.b2b.jms.platformb2b.LuceneMessage) luceneMessage);
|
|
|
+ logger.info("dequeueLuceneMessage.id..." + luceneMessage.getId());
|
|
|
luceneMessageDao.dequeueLuceneMessage(id);
|
|
|
} else {
|
|
|
com.uas.search.console.b2b.jms.platformmanager.LuceneMessageDao luceneMessageDao = ContextUtils.getBean(com.uas.search.console.b2b.jms.platformmanager.LuceneMessageDao.class);
|
|
|
luceneMessageDao.save((com.uas.search.console.b2b.jms.platformmanager.LuceneMessage) luceneMessage);
|
|
|
+ logger.info("dequeueLuceneMessage.id..." + luceneMessage.getId());
|
|
|
luceneMessageDao.dequeueLuceneMessage(id);
|
|
|
}
|
|
|
}
|