Showing
16 changed files
with
16 additions
and
16 deletions
@@ -18,7 +18,7 @@ import org.springframework.stereotype.Component; | @@ -18,7 +18,7 @@ import org.springframework.stereotype.Component; | ||
18 | * @version 2018/9/11 | 18 | * @version 2018/9/11 |
19 | */ | 19 | */ |
20 | @Component | 20 | @Component |
21 | -@SearchMqConsumerListerner(tableName = "ufo_product.brand") | 21 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "brand") |
22 | public class UfoBrandMqListener extends AbstractMqListener { | 22 | public class UfoBrandMqListener extends AbstractMqListener { |
23 | 23 | ||
24 | @Autowired | 24 | @Autowired |
@@ -16,7 +16,7 @@ import org.springframework.stereotype.Component; | @@ -16,7 +16,7 @@ import org.springframework.stereotype.Component; | ||
16 | * @version 2018/9/11 | 16 | * @version 2018/9/11 |
17 | */ | 17 | */ |
18 | @Component | 18 | @Component |
19 | -@SearchMqConsumerListerner(tableName = "ufo_product.brand_series") | 19 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "brand_series") |
20 | public class UfoBrandSeriesMqListener extends AbstractMqListener { | 20 | public class UfoBrandSeriesMqListener extends AbstractMqListener { |
21 | 21 | ||
22 | @Autowired | 22 | @Autowired |
@@ -14,7 +14,7 @@ import org.springframework.stereotype.Component; | @@ -14,7 +14,7 @@ import org.springframework.stereotype.Component; | ||
14 | * Created by aaron.wang on 2018/12/5. | 14 | * Created by aaron.wang on 2018/12/5. |
15 | */ | 15 | */ |
16 | @Component | 16 | @Component |
17 | -@SearchMqConsumerListerner(tableName = "ufo_order.buyer_order_goods") | 17 | +@SearchMqConsumerListerner(dbName = "ufo_order",tableName = "buyer_order_goods") |
18 | public class UfoBuyerOrderGoodsMqListener extends AbstractMqListener { | 18 | public class UfoBuyerOrderGoodsMqListener extends AbstractMqListener { |
19 | 19 | ||
20 | @Autowired | 20 | @Autowired |
@@ -14,7 +14,7 @@ import org.springframework.stereotype.Component; | @@ -14,7 +14,7 @@ import org.springframework.stereotype.Component; | ||
14 | * Created by aaron.wang on 2018/12/5. | 14 | * Created by aaron.wang on 2018/12/5. |
15 | */ | 15 | */ |
16 | @Component | 16 | @Component |
17 | -@SearchMqConsumerListerner(tableName = "ufo_order.buyer_order") | 17 | +@SearchMqConsumerListerner(dbName = "ufo_order",tableName = "buyer_order") |
18 | public class UfoBuyerOrderMqListener extends AbstractMqListener { | 18 | public class UfoBuyerOrderMqListener extends AbstractMqListener { |
19 | @Autowired | 19 | @Autowired |
20 | private UfoBuyerOrderService ufoBuyerOrderService; | 20 | private UfoBuyerOrderService ufoBuyerOrderService; |
@@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | @@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | ||
15 | * @version 2018/9/11 | 15 | * @version 2018/9/11 |
16 | */ | 16 | */ |
17 | @Component | 17 | @Component |
18 | -@SearchMqConsumerListerner(tableName = "ufo_product.goods_images") | 18 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "goods_images") |
19 | public class UfoGoodsImagesMqListener extends AbstractMqListener { | 19 | public class UfoGoodsImagesMqListener extends AbstractMqListener { |
20 | 20 | ||
21 | @Autowired | 21 | @Autowired |
@@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | @@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | ||
15 | * @version 2018/9/11 | 15 | * @version 2018/9/11 |
16 | */ | 16 | */ |
17 | @Component | 17 | @Component |
18 | -@SearchMqConsumerListerner(tableName = "ufo_product.goods") | 18 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "goods") |
19 | public class UfoGoodsMqListener extends AbstractMqListener { | 19 | public class UfoGoodsMqListener extends AbstractMqListener { |
20 | 20 | ||
21 | @Autowired | 21 | @Autowired |
@@ -17,7 +17,7 @@ import org.springframework.stereotype.Component; | @@ -17,7 +17,7 @@ import org.springframework.stereotype.Component; | ||
17 | * @version 2018/9/11 | 17 | * @version 2018/9/11 |
18 | */ | 18 | */ |
19 | @Component | 19 | @Component |
20 | -@SearchMqConsumerListerner(tableName = "ufo_product.product_color") | 20 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "product_color") |
21 | public class UfoProductColorMqListener extends AbstractMqListener { | 21 | public class UfoProductColorMqListener extends AbstractMqListener { |
22 | 22 | ||
23 | @Autowired | 23 | @Autowired |
@@ -17,7 +17,7 @@ import org.springframework.stereotype.Component; | @@ -17,7 +17,7 @@ import org.springframework.stereotype.Component; | ||
17 | * @version 2018/9/11 | 17 | * @version 2018/9/11 |
18 | */ | 18 | */ |
19 | @Component | 19 | @Component |
20 | -@SearchMqConsumerListerner(tableName = "ufo_product.product") | 20 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "product") |
21 | public class UfoProductMqListener extends AbstractMqListener { | 21 | public class UfoProductMqListener extends AbstractMqListener { |
22 | 22 | ||
23 | @Autowired | 23 | @Autowired |
index/src/main/java/com/yoho/search/consumer/index/increment/ufo/UfoProductPoolDetailMqListener.java
@@ -16,7 +16,7 @@ import org.springframework.stereotype.Component; | @@ -16,7 +16,7 @@ import org.springframework.stereotype.Component; | ||
16 | * @version 2018/9/11 | 16 | * @version 2018/9/11 |
17 | */ | 17 | */ |
18 | @Component | 18 | @Component |
19 | -@SearchMqConsumerListerner(tableName = "ufo_product.product_pool_detail") | 19 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "product_pool_detail") |
20 | public class UfoProductPoolDetailMqListener extends AbstractMqListener { | 20 | public class UfoProductPoolDetailMqListener extends AbstractMqListener { |
21 | 21 | ||
22 | @Autowired | 22 | @Autowired |
@@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | @@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | ||
15 | * @version 2018/9/11 | 15 | * @version 2018/9/11 |
16 | */ | 16 | */ |
17 | @Component | 17 | @Component |
18 | -@SearchMqConsumerListerner(tableName = "ufo_product.product_pool") | 18 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "product_pool") |
19 | public class UfoProductPoolMqListener extends AbstractMqListener { | 19 | public class UfoProductPoolMqListener extends AbstractMqListener { |
20 | 20 | ||
21 | @Autowired | 21 | @Autowired |
@@ -17,7 +17,7 @@ import org.springframework.stereotype.Component; | @@ -17,7 +17,7 @@ import org.springframework.stereotype.Component; | ||
17 | * @version 2018/9/11 | 17 | * @version 2018/9/11 |
18 | */ | 18 | */ |
19 | @Component | 19 | @Component |
20 | -@SearchMqConsumerListerner(tableName = "ufo_product.product_sort") | 20 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "product_sort") |
21 | public class UfoProductSortMqListener extends AbstractMqListener { | 21 | public class UfoProductSortMqListener extends AbstractMqListener { |
22 | 22 | ||
23 | @Autowired | 23 | @Autowired |
@@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | @@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | ||
15 | * @version 2018/11/19 | 15 | * @version 2018/11/19 |
16 | */ | 16 | */ |
17 | @Component | 17 | @Component |
18 | -@SearchMqConsumerListerner(tableName = "ufo_score_product_rule") | 18 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "score_product_rule") |
19 | public class UfoScoreProductRuleMqListener extends AbstractMqListener { | 19 | public class UfoScoreProductRuleMqListener extends AbstractMqListener { |
20 | @Autowired | 20 | @Autowired |
21 | private UfoScoreProductRuleMapper ufoScoreProductRuleMapper; | 21 | private UfoScoreProductRuleMapper ufoScoreProductRuleMapper; |
@@ -16,7 +16,7 @@ import org.springframework.stereotype.Component; | @@ -16,7 +16,7 @@ import org.springframework.stereotype.Component; | ||
16 | * @version 2018/11/8 | 16 | * @version 2018/11/8 |
17 | */ | 17 | */ |
18 | @Component | 18 | @Component |
19 | -@SearchMqConsumerListerner(tableName = "ufo_product.search_sort_relation") | 19 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "search_sort_relation") |
20 | public class UfoSearchSortRelationMqListener extends AbstractMqListener { | 20 | public class UfoSearchSortRelationMqListener extends AbstractMqListener { |
21 | 21 | ||
22 | @Autowired | 22 | @Autowired |
@@ -18,7 +18,7 @@ import org.springframework.stereotype.Component; | @@ -18,7 +18,7 @@ import org.springframework.stereotype.Component; | ||
18 | * @version 2018/9/11 | 18 | * @version 2018/9/11 |
19 | */ | 19 | */ |
20 | @Component | 20 | @Component |
21 | -@SearchMqConsumerListerner(tableName = "ufo_product.size") | 21 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "size") |
22 | public class UfoSizeMqListener extends AbstractMqListener { | 22 | public class UfoSizeMqListener extends AbstractMqListener { |
23 | 23 | ||
24 | @Autowired | 24 | @Autowired |
@@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | @@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | ||
15 | * @version 2018/9/11 | 15 | * @version 2018/9/11 |
16 | */ | 16 | */ |
17 | @Component | 17 | @Component |
18 | -@SearchMqConsumerListerner(tableName = "ufo_product.storage") | 18 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "storage") |
19 | public class UfoStorageMqListener extends AbstractMqListener { | 19 | public class UfoStorageMqListener extends AbstractMqListener { |
20 | 20 | ||
21 | @Autowired | 21 | @Autowired |
@@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | @@ -15,7 +15,7 @@ import org.springframework.stereotype.Component; | ||
15 | * @version 2018/9/11 | 15 | * @version 2018/9/11 |
16 | */ | 16 | */ |
17 | @Component | 17 | @Component |
18 | -@SearchMqConsumerListerner(tableName = "ufo_product.storage_price") | 18 | +@SearchMqConsumerListerner(dbName = "ufo_product",tableName = "storage_price") |
19 | public class UfoStoragePriceMqListener extends AbstractMqListener { | 19 | public class UfoStoragePriceMqListener extends AbstractMqListener { |
20 | 20 | ||
21 | @Autowired | 21 | @Autowired |
-
Please register or login to post a comment