Skip to content

向汉 / uc-consumer

Go to a project
Toggle navigation
Toggle navigation pinning
Commit 64fe16cc 64fe16cc2c2ed5a3b7706ec146f322f7d1bfaf20 by xianghan
Options

1.update

1 parent ea6a3b38
Inline Side-by-side
Showing 5 changed files with 9 additions and 9 deletions
...@@ -31,7 +31,7 @@ public class UcEngineIptv2ManagementConsumer { ...@@ -31,7 +31,7 @@ public class UcEngineIptv2ManagementConsumer {
31 * @author Hongyan Wang 31 * @author Hongyan Wang
32 * @date 2021/9/7 11:26 上午 32 * @date 2021/9/7 11:26 上午
33 */ 33 */
34 /*@RabbitHandler 34 /* @RabbitHandler
35 @RabbitListener(bindings = { 35 @RabbitListener(bindings = {
36 @QueueBinding(value = @Queue(value = RabbitMqConfig.ENGINE_TO_MANAGEMENT_DIRECT), 36 @QueueBinding(value = @Queue(value = RabbitMqConfig.ENGINE_TO_MANAGEMENT_DIRECT),
37 exchange = @Exchange(value = ExchangeTypes.DIRECT)) 37 exchange = @Exchange(value = ExchangeTypes.DIRECT))
......
...@@ -28,11 +28,11 @@ public class UcEngineManagement2IptvConsumer { ...@@ -28,11 +28,11 @@ public class UcEngineManagement2IptvConsumer {
28 * @author Hongyan Wang 28 * @author Hongyan Wang
29 * @date 2021/9/7 11:26 上午 29 * @date 2021/9/7 11:26 上午
30 */ 30 */
31 @RabbitHandler 31 /*@RabbitHandler
32 @RabbitListener(bindings = { 32 @RabbitListener(bindings = {
33 @QueueBinding(value = @Queue(value = RabbitMqConfig.ENGINE_TO_SERVICE_DIRECT), 33 @QueueBinding(value = @Queue(value = RabbitMqConfig.ENGINE_TO_SERVICE_DIRECT),
34 exchange = @Exchange(value = ExchangeTypes.DIRECT)) 34 exchange = @Exchange(value = ExchangeTypes.DIRECT))
35 }, containerFactory = "serviceRabbitListenerContainerFactory") 35 }, containerFactory = "serviceRabbitListenerContainerFactory")*/
36 public void ucEventConsumer(String content) { 36 public void ucEventConsumer(String content) {
37 log.info(" receive dataSync msg , content is : {} ", content); 37 log.info(" receive dataSync msg , content is : {} ", content);
38 TableOperationMsg tableOperationMsg = this.parseContent(content); 38 TableOperationMsg tableOperationMsg = this.parseContent(content);
......
...@@ -39,9 +39,9 @@ public class UcEventBusIptv2ManagementUcEngine { ...@@ -39,9 +39,9 @@ public class UcEventBusIptv2ManagementUcEngine {
39 * @author Hongyan Wang 39 * @author Hongyan Wang
40 * @date 2021/9/7 11:26 上午 40 * @date 2021/9/7 11:26 上午
41 */ 41 */
42 @RabbitHandler 42 /*@RabbitHandler
43 @RabbitListener(queues = RabbitMqConfig.UC_EVENTBUS_QUEUE, 43 @RabbitListener(queues = RabbitMqConfig.UC_EVENTBUS_QUEUE,
44 containerFactory = "managementRabbitListenerContainerFactory") 44 containerFactory = "managementRabbitListenerContainerFactory")*/
45 public void ucEventConsumer(String content) { 45 public void ucEventConsumer(String content) {
46 log.info(" receive dataSync msg , content is : {} ", content); 46 log.info(" receive dataSync msg , content is : {} ", content);
47 DataSyncMsg dataSyncMsg = this.parseContent(content); 47 DataSyncMsg dataSyncMsg = this.parseContent(content);
......
...@@ -28,11 +28,11 @@ public class UcGatewayIptv2IptvConsumer { ...@@ -28,11 +28,11 @@ public class UcGatewayIptv2IptvConsumer {
28 * @author Hongyan Wang 28 * @author Hongyan Wang
29 * @date 2021/9/7 11:26 上午 29 * @date 2021/9/7 11:26 上午
30 */ 30 */
31 @RabbitHandler 31 /*@RabbitHandler
32 @RabbitListener(bindings = { 32 @RabbitListener(bindings = {
33 @QueueBinding(value = @Queue(value = RabbitMqConfig.GATEWAY_TO_SERVICE_DIRECT), 33 @QueueBinding(value = @Queue(value = RabbitMqConfig.GATEWAY_TO_SERVICE_DIRECT),
34 exchange = @Exchange(value = ExchangeTypes.DIRECT)) 34 exchange = @Exchange(value = ExchangeTypes.DIRECT))
35 }, containerFactory = "managementRabbitListenerContainerFactory") 35 }, containerFactory = "managementRabbitListenerContainerFactory")*/
36 public void ucEventConsumer(String content) { 36 public void ucEventConsumer(String content) {
37 log.info(" receive dataSync msg , content is : {} ", content); 37 log.info(" receive dataSync msg , content is : {} ", content);
38 DataSyncMsg dataSyncMsg = this.parseContent(content); 38 DataSyncMsg dataSyncMsg = this.parseContent(content);
......
...@@ -74,11 +74,11 @@ public class WeiXinEventConsumer { ...@@ -74,11 +74,11 @@ public class WeiXinEventConsumer {
74 * } 74 * }
75 * @param content 75 * @param content
76 */ 76 */
77 /*@RabbitHandler 77 @RabbitHandler
78 @RabbitListener(bindings = { 78 @RabbitListener(bindings = {
79 @QueueBinding(value = @Queue(value = RabbitMqConfig.WEIXIN_SUBORUNSUB_QUEUE), 79 @QueueBinding(value = @Queue(value = RabbitMqConfig.WEIXIN_SUBORUNSUB_QUEUE),
80 exchange = @Exchange(value = ExchangeTypes.DIRECT))}, 80 exchange = @Exchange(value = ExchangeTypes.DIRECT))},
81 containerFactory = "managementRabbitListenerContainerFactory")*/ 81 containerFactory = "managementRabbitListenerContainerFactory")
82 @Transactional 82 @Transactional
83 public void subOrUnSubEvent(String content) { 83 public void subOrUnSubEvent(String content) {
84 try { 84 try {
......