|
...
|
...
|
@@ -66,7 +66,7 @@ public class ProductExtMqListener extends AbstractMqListener implements ChannelA |
|
|
|
public void updateData(final Map data, final String indexName) throws Exception {
|
|
|
|
long begin = System.currentTimeMillis();
|
|
|
|
ProductExtWithBLOBs productExtWithBLOBs = new ProductExtWithBLOBs();
|
|
|
|
productExtWithBLOBs = (ProductExtWithBLOBs) ConvertUtils.toJavaBean(ProductExtWithBLOBs.class, data);
|
|
|
|
productExtWithBLOBs = (ProductExtWithBLOBs) ConvertUtils.toJavaBean(productExtWithBLOBs, data);
|
|
|
|
if (productExtWithBLOBs == null ) {
|
|
|
|
return;
|
|
|
|
}
|
...
|
...
|
|
