...
|
...
|
@@ -36,10 +36,6 @@ public class ShopsBrandsMqListener extends AbstractMqListener implements Channel |
|
|
@Override
|
|
|
public void onMessage(Message message, Channel channel) throws Exception {
|
|
|
try {
|
|
|
String idField = ISearchConstants.getKeyField(getIndexName());
|
|
|
if (StringUtils.isBlank(idField)) {
|
|
|
throw new Exception("idField is empty,indexName is " + getIndexName());
|
|
|
}
|
|
|
process(this, message);
|
|
|
} catch (Exception e) {
|
|
|
publisher.publishEvent(buildSearchEvent(EventReportEnum.SHOPSBRADNSMQLISTENER_ONMESSAGE, e));
|
...
|
...
|
|