Authored by unknown

fix

Showing 51 changed files with 1 additions and 51 deletions
... ... @@ -15,7 +15,6 @@ import java.util.HashSet;
import java.util.Set;
@Component
@RabbitListener(queues = "#{'${data_update_channel_esworddef}'}" )
public class EsWordDefMqListener extends AbstractMqListener {
private static final Set<Integer> validWordType = new HashSet<Integer>() {
... ...
... ... @@ -13,7 +13,6 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Component
@RabbitListener(queues = "#{'${data_update_channel_pagerecallstrategydetail}'}" )
public class PageRecallStrategyDetailMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -12,7 +12,6 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Component
@RabbitListener(queues = "#{'${data_update_channel_pagerecalltype}'}" )
public class PageRecallTypeMqListener extends AbstractMqListener {
@Autowired
private PageRecallTypeService pageRecallTypeService;
... ...
... ... @@ -12,7 +12,6 @@ import com.yoho.search.consumer.service.daoService.ParameterMakeService;
import com.yoho.search.dal.model.ParameterMake;
@Component
@RabbitListener(queues = "#{'${data_update_channel_parametermake}'}" )
public class ParameterMakeMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -12,7 +12,6 @@ import com.yoho.search.consumer.service.daoService.ProductAttributeService;
import com.yoho.search.dal.model.ProductAttribute;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productattribute}'}" )
public class ProductAttributeMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -14,7 +14,6 @@ import com.yoho.search.consumer.service.daoService.PromotionInfoService;
import com.yoho.search.dal.model.PromotionInfo;
@Component
@RabbitListener(queues = "#{'${data_update_channel_promotioninfo}'}" )
public class PromotionInfoMqListener extends AbstractMqListener {
private static final String PROMOTION_INDEX_NAME = "promotionindex";
... ...
... ... @@ -12,7 +12,6 @@ import com.yoho.search.consumer.service.daoService.PromotionParamsService;
import com.yoho.search.dal.model.PromotionParams;
@Component
@RabbitListener(queues = "#{'${data_update_channel_promotionparams}'}" )
public class PromotionParamsMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -14,7 +14,6 @@ import org.springframework.stereotype.Component;
* Created by wangnan on 2017/9/14.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_promotiontype}'}" )
public class PromotionTypeMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -12,7 +12,6 @@ import com.yoho.search.consumer.service.logicService.SalesCategoryLogicService;
import com.yoho.search.dal.model.SalesCategory;
@Component
@RabbitListener(queues = "#{'${data_update_channel_salescategory}'}" )
public class SalesCategoryMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -13,7 +13,6 @@ import com.yoho.search.consumer.service.logicService.ScoreRuleLogicService;
import com.yoho.search.dal.model.ScoreRule;
@Component
@RabbitListener(queues = "#{'${data_update_channel_scorerule}'}" )
public class ScoreRuleMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -15,7 +15,6 @@ import com.yoho.search.dal.model.ShopsBrands;
* Created by wangnan on 2016/12/1.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_shopsbrands}'}" )
public class ShopsBrandsMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -12,7 +12,6 @@ import com.yoho.search.consumer.service.daoService.StandardService;
import com.yoho.search.dal.model.Standard;
@Component
@RabbitListener(queues = "#{'${data_update_channel_standard}'}" )
public class StandardMqListener extends AbstractMqListener{
@Autowired
... ...
... ... @@ -15,7 +15,6 @@ import com.yoho.search.dal.model.Videos;
* Created by mingdan.ge on 2017/7/17.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_videos}'}" )
public class VideosMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -17,7 +17,6 @@ import org.springframework.stereotype.Component;
* Created by wangnan on 2017/9/11.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_activitytag}'}" )
public class ActivityTagMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -16,7 +16,6 @@ import com.yoho.search.consumer.service.daoService.BrandService;
import com.yoho.search.dal.model.Brand;
@Component
@RabbitListener(queues = "#{'${data_update_channel_brand}'}" )
public class BrandMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -21,7 +21,6 @@ import com.yoho.search.dal.model.Helper;
* Created by wangnan on 2016/12/5.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_helper}'}" )
public class HelperMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -15,7 +15,6 @@ import com.yoho.search.consumer.service.logicService.ProductGoodsLogicService;
import com.yoho.search.dal.model.ProductColor;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productcolor}'}" )
public class ProductColorMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -15,7 +15,6 @@ import com.yoho.search.consumer.service.logicService.VipPriceLogicService;
import com.yoho.search.dal.model.ProductPricePlan;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productpriceplan}'}" )
public class ProductPricePlanMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -16,7 +16,6 @@ import com.yoho.search.consumer.service.daoService.ProductSortService;
import com.yoho.search.dal.model.ProductSort;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productsort}'}" )
public class ProductSortMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -24,7 +24,6 @@ import com.yoho.search.dal.model.PromotionProductFlags;
* Created by wangnan on 2017/5/11.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_promotionproductflags}'}" )
public class PromotionProductFlagsMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(PromotionProductFlagsMqListener.class);
... ...
... ... @@ -17,7 +17,6 @@ import com.yoho.search.dal.model.RobotQuestion;
* Created by wangnan on 2016/11/28.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_robotquestion}'}" )
public class RobotQuestionMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -22,7 +22,6 @@ import com.yoho.search.dal.model.Shops;
* Created by wangnan on 2016/12/1.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_shops}'}" )
public class ShopsMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -15,7 +15,6 @@ import com.yoho.search.consumer.service.daoService.SizeService;
import com.yoho.search.dal.model.Size;
@Component
@RabbitListener(queues = "#{'${data_update_channel_size}'}" )
public class SizeMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -14,7 +14,6 @@ import com.yoho.search.consumer.service.daoService.StyleService;
import com.yoho.search.dal.model.Style;
@Component
@RabbitListener(queues = "#{'${data_update_channel_style}'}" )
public class StyleMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -23,7 +23,6 @@ import com.yoho.search.dal.model.SuggestConversion;
import com.yoho.search.dal.model.SuggestConversionCustom;
@Component
@RabbitListener(queues = "#{'${data_update_channel_suggestconversioncustom}'}" )
public class SuggestConversionCustomMqListener extends AbstractMqListener {
static final Logger logger = LoggerFactory.getLogger(SuggestConversionCustomMqListener.class);
... ...
... ... @@ -24,7 +24,6 @@ import java.util.Map;
* Created by gemingdan on 2017/3/15.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_suggestwordcustom}'}" )
public class SuggestWordCustomMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(SuggestWordCustomMqListener.class);
... ...
... ... @@ -20,7 +20,6 @@ import java.util.List;
import java.util.Map;
@Component
@RabbitListener(queues = "#{'${data_update_channel_activityproduct}'}" )
public class ActivityProductMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -28,7 +28,6 @@ import com.yoho.search.consumer.service.logicService.productIndex.VideosBuilder;
import com.yoho.search.dal.model.GoodsImages;
@Component
@RabbitListener(queues = "#{'${data_update_channel_goodsimages}'}" )
public class GoodsImagesMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(GoodsImagesMqListener.class);
... ...
... ... @@ -26,7 +26,6 @@ import java.util.List;
import java.util.Map;
@Component
@RabbitListener(queues = "#{'${data_update_channel_goods}'}" )
public class GoodsMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(GoodsMqListener.class);
... ...
... ... @@ -23,7 +23,6 @@ import java.util.List;
import java.util.Map;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productactivitieslink}'}" )
public class ProductActivitiesLinkMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ProductActivitiesLinkMqListener.class);
... ...
... ... @@ -20,7 +20,6 @@ import java.util.HashMap;
import java.util.Map;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productattributepropertyvalues}'}" )
public class ProductAttributePropertyValuesMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -21,7 +21,6 @@ import java.util.HashMap;
import java.util.Map;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productext}'}" )
public class ProductExtMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ProductExtMqListener.class);
... ...
... ... @@ -23,7 +23,6 @@ import com.yoho.search.consumer.service.bo.ProductIndexBO;
import com.yoho.search.consumer.service.logicService.ProductIndexBOToMapService;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productindex}'}" )
public class ProductIndexMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ProductIndexMqListener.class);
... ...
... ... @@ -22,7 +22,6 @@ import java.util.Map;
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_productkeywords}'}" )
public class ProductKeywordsMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -29,7 +29,6 @@ import org.springframework.util.CollectionUtils;
@Component
@RabbitListener(queues = "#{'${data_update_channel_product}'.split(',')}" )
public class ProductMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ProductMqListener.class);
... ...
... ... @@ -23,7 +23,6 @@ import java.util.*;
* Created by wangnan on 2016/8/17.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_productpooldetail}'}" )
public class ProductPoolDetailMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ProductPoolDetailMqListener.class);
... ...
... ... @@ -23,7 +23,6 @@ import com.yoho.search.dal.model.Product;
import com.yoho.search.dal.model.ProductPrice;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productprice}'.split(',')}" )
public class ProductPriceMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ProductPriceMqListener.class);
... ...
... ... @@ -20,7 +20,6 @@ import java.util.HashMap;
import java.util.Map;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productsearch}'}" )
public class ProductSearchMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ProductSearchMqListener.class);
... ...
... ... @@ -18,7 +18,6 @@ import org.springframework.stereotype.Component;
import java.util.*;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productstandardrelation}'}" )
public class ProductStandardRelationMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ProductStandardRelationMqListener.class);
... ...
... ... @@ -18,7 +18,6 @@ import org.springframework.stereotype.Component;
import java.util.*;
@Component
@RabbitListener(queues = "#{'${data_update_channel_productstylerelation}'}" )
public class ProductStyleRelationMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ProductStyleRelationMqListener.class);
... ...
... ... @@ -28,7 +28,6 @@ import java.util.Map;
* Created by wangnan on 2016/11/24.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_producttiming}'}" )
public class ProductTimingMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ProductTimingMqListener.class);
... ...
... ... @@ -24,7 +24,6 @@ import java.util.Map;
* Created by gemingdan on 2017/6/19.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_scoresknrule}'}" )
public class ScoreSknRuleMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(ScoreSknRuleMqListener.class);
... ...
... ... @@ -24,7 +24,6 @@ import com.yoho.search.dal.model.SknBlock;
* Created by mingdan.ge on 2017/7/10.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_sknblock}'}" )
public class SknBlockMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(SknBlockMqListener.class);
... ...
... ... @@ -28,7 +28,6 @@ import java.util.List;
import java.util.Map;
@Component
@RabbitListener(queues = "#{'${data_update_channel_storage}'}" )
public class StorageMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(StorageMqListener.class);
... ...
... ... @@ -23,7 +23,6 @@ import java.util.List;
* Created by wangnan on 2016/12/16.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_tblbrand}'}" )
public class TblBrandMqListener extends AbstractMqListener {
private static final Logger logger = LoggerFactory.getLogger(TblBrandMqListener.class);
... ...
... ... @@ -17,7 +17,6 @@ import com.yoho.search.dal.model.TblProduct;
* Created by wangnan on 2016/12/19.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_tblproduct}'}" )
public class TblProductMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -17,7 +17,6 @@ import com.yoho.search.dal.model.TblProductSkc;
* Created by wangnan on 2016/12/19.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_tblproductskc}'}" )
public class TblProductSkcMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -17,7 +17,6 @@ import com.yoho.search.dal.model.TblProductSku;
* Created by wangnan on 2016/12/19.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_tblproductsku}'}" )
public class TblProductSkuMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -21,7 +21,6 @@ import com.yoho.search.dal.model.TblSite;
* Created by wangnan on 2016/12/16.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_tblsite}'}" )
public class TblSiteMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -17,7 +17,6 @@ import com.yoho.search.dal.model.TblSort;
* Created by wangnan on 2016/12/19.
*/
@Component
@RabbitListener(queues = "#{'${data_update_channel_tblsort}'}" )
public class TblSortMqListener extends AbstractMqListener {
@Autowired
... ...
... ... @@ -24,7 +24,7 @@
<property name="locations">
<list>
<value>classpath:config.properties</value>
<value>classpath*:mq.properties</value>
<value>classpath*:table.properties</value>
</list>
</property>
</bean>
... ...