update: 消费临时队列

consume/md/consume_key.go

@@ -66,182 +66,14 @@ var RabbitMqQueueKeyList = []*MqQueue{
 		ConsumeFunName: "IMEggEnergyDelFriendCircleDataConsume",
 	},
 	{
-		ExchangeName:   "egg.app",
-		Name:           "egg_fin_withdraw_apply",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "egg_fin_withdraw_apply",
-		BindKey:        "",
-		ConsumeFunName: "EggFinWithdrawApplyDataConsume",
-	},
-	{
-		ExchangeName:   "egg.energy",
-		Name:           "egg_energy_settlement_public_give_activity_coin",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "settlement_public_give_activity_coin",
-		BindKey:        "",
-		ConsumeFunName: "EggEnergySettlementPublicGiveActivityCoinConsume",
-	},
-	{
-		ExchangeName:   "egg.energy",
-		Name:           "egg_energy_start_exchange_egg_energy",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "start_exchange_egg_energy",
-		BindKey:        "",
-		ConsumeFunName: "EggEnergyStartExchangeGreenEnergyConsume",
-	},
-	{
-		ExchangeName:   "egg.energy",
-		Name:           "egg_energy_auto_exchange_egg_energy",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "auto_exchange_egg_energy",
-		BindKey:        "",
-		ConsumeFunName: "EggEnergyAutoExchangeGreenEnergyConsume",
-	},
-	{
-		ExchangeName:   "egg.app",
-		Name:           "add_public_platoon_user_relation_commission",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "add_public_platoon_user_relation_commission",
-		BindKey:        "",
-		ConsumeFunName: "AddPublicPlatoonUserRelationCommissionConsume",
-	},
-	{
-		ExchangeName:   "egg.jpush",
-		Name:           "egg_jpush_record_queue",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "jpush_record",
-		BindKey:        "",
-		ConsumeFunName: "JpushRecordConsume",
-	},
-	{
-		ExchangeName:   "egg.aliyun_sms",
-		Name:           "egg_aliyun_sms_record_queue_new",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "aliyun_sms_record",
-		BindKey:        "",
-		ConsumeFunName: "AliyunSmsRecordConsume",
-	},
-	{
-		ExchangeName:   "egg.advertising",
-		Name:           "egg_advertising_smash",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "advertising_smash",
-		BindKey:        "",
-		ConsumeFunName: "AdvertisingSmashConsume",
-	},
-	{
-		ExchangeName:   "egg.advertising",
-		Name:           "egg_advertising_sign",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "advertising_sign",
-		BindKey:        "",
-		ConsumeFunName: "AdvertisingSignConsume",
-	},
-	{
-		ExchangeName:   "egg.app",
-		Name:           "egg_new_user_register_queue",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "egg_new_user_register",
-		BindKey:        "",
-		ConsumeFunName: "EggEnergyNewUserRegisterDataConsume",
-	},
-	{
-		ExchangeName:   "egg.energy",
-		Name:           "egg_energy_user_ecpm",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "user_ecpm",
-		BindKey:        "",
-		ConsumeFunName: "EggEnergyDealUserECPMConsume",
-	},
-	{
-		ExchangeName:   "egg.canal.topic",
-		Name:           "egg_canal_invite_user_nums_queue",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "user_relate",
-		BindKey:        "",
-		ConsumeFunName: "EggCanalInviteUserNumsConsume",
-	},
-	{
-		ExchangeName:   "egg.canal.topic",
-		Name:           "egg_canal_violate_nums_queue",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "user_tag_records",
-		BindKey:        "",
-		ConsumeFunName: "EggCanalViolateNumsConsume",
-	},
-	{
-		ExchangeName:   "im.egg.energy",
-		Name:           "im_egg_energy_send_red_package_queue",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "send_red_package",
-		BindKey:        "",
-		ConsumeFunName: "IMEggEnergySendRedPackageConsume",
-	},
-	{
-		ExchangeName:   "egg.app",
-		Name:           "egg_record_active_queue",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "egg_record_active",
-		BindKey:        "",
-		ConsumeFunName: "EggRecordActiveDataConsume",
-	},
-	{
-		ExchangeName:   "egg.canal.topic",
-		Name:           "egg_canal_person_add_activity_value_queue",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "egg_canal_user_virtual_coin_flow",
-		BindKey:        "",
-		ConsumeFunName: "EggCanalPersonAddActivityValueConsume",
-	},
-	{
-		ExchangeName:   "egg.video_playlet",
-		Name:           "egg_video_reward",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "video",
-		BindKey:        "",
-		ConsumeFunName: "VideoRewardFunName",
-	},
-	{
-		ExchangeName:   "egg.video_playlet",
-		Name:           "egg_playlet_reward",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "playlet",
-		BindKey:        "",
-		ConsumeFunName: "PlayletRewardFunName",
-	},
-	{
-		ExchangeName:   "egg.user",
-		Name:           "egg_user_delete",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "user_delete",
-		BindKey:        "",
-		ConsumeFunName: "UserDeleteConsume",
-	},
-	{
-		ExchangeName:   "egg.app",
-		Name:           "egg_auto_score_queue",
-		Type:           DirectQueueType,
-		IsPersistent:   false,
-		RoutKey:        "egg_auto_score",
+		// 消费临时队列
+		ExchangeName: "egg.app",
+		Name:         "egg_auto_score_test_queue",
+		//Name:           "egg_auto_score_queue",
+		Type:         DirectQueueType,
+		IsPersistent: false,
+		//RoutKey:        "egg_auto_score",
+		RoutKey:        "egg_auto_score_test",
 		BindKey:        "",
 		ConsumeFunName: "EggEnergyAutoScoreConsume",
 	},

etc/cfg.yml

@@ -81,26 +81,26 @@ log:
   file_name: 'debug.log'
 
 # 连接RabbitMq
-mq:
-  host: '120.77.153.180'
-  port: '5672'
-  user: 'guest'
-  pwd: 'guest'
 #mq:
-#  host: '116.62.62.35'
+#  host: '120.77.153.180'
 #  port: '5672'
-#  user: 'zhios'
-#  pwd: 'ZHIoscnfnuo123'
-
-#es:
-#  url: 'http://120.55.48.175:9200'
-#  user: 'elastic'
-#  pwd: 'fnuo123'
+#  user: 'guest'
+#  pwd: 'guest'
+mq:
+  host: '116.62.62.35'
+  port: '5672'
+  user: 'zhios'
+  pwd: 'ZHIoscnfnuo123'
 
 es:
-  url: 'http://123.57.140.192:9200'
+  url: 'http://120.55.48.175:9200'
   user: 'elastic'
-  pwd: 'se4BxqYyGhHyPWPA3w8Q'
+  pwd: 'fnuo123'
+
+#es:
+#  url: 'http://123.57.140.192:9200'
+#  user: 'elastic'
+#  pwd: 'se4BxqYyGhHyPWPA3w8Q'
 
 im_business_rpc:
   url: im-rpc-business.izhim.com