diff --git a/consume/md/consume_key.go b/consume/md/consume_key.go index a502122..2867d76 100644 --- a/consume/md/consume_key.go +++ b/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", }, diff --git a/etc/cfg.yml b/etc/cfg.yml index e08bbf2..cae636e 100644 --- a/etc/cfg.yml +++ b/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