update

consume/md/consume_key.go

@@ -65,6 +65,177 @@ var RabbitMqQueueKeyList = []*MqQueue{
 		BindKey:        "",
 		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",
@@ -72,8 +243,8 @@ var RabbitMqQueueKeyList = []*MqQueue{
 		//Name:           "egg_auto_score_queue",
 		Type:         DirectQueueType,
 		IsPersistent: false,
+		RoutKey:      "egg_auto_score_test",
 		//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