go_rely_warehouse
/
zyos_go_mq_consume
4
0
Fork 0
Código Incidencias 0 Pull Requests 0 Lanzamientos 0 Wiki Actividad
golang 的 rabbitmq 消费项目
No puede seleccionar más de 25 temas Los temas deben comenzar con una letra o número, pueden incluir guiones ('-') y pueden tener hasta 35 caracteres de largo.
511 Commits
7 Ramas
31 MiB
 
 
 
Árbol: 0c53670f00
Ramas Etiquetas
${ item.name }
Crear rama ${ searchTerm }
desde '0c53670f00'
${ noResults }
zyos_go_mq_consume/consume/md/consume_key.go

729 líneas
26 KiB
Original Blame Histórico 

  1. package md

  2. 

  3. type MqQueue struct {

  4. 	ExchangeName   string `json:"exchangeName"`     //交换机名字

  5. 	Name           string `json:"name"`             //队列名字

  6. 	Type           string `json:"type"`             //队列类型

  7. 	IsPersistent   bool   `json:"is_persistent"`    //队列是否持久化

  8. 	RoutKey        string `json:"rout_key"`         //路由

  9. 	BindKey        string `json:"bind_key"`         //绑定的路由

  10. 	ConsumeFunName string `json:"consume_fun_name"` //消费方法

  11. }

  12. 

  13. var RabbitMqQueueKeyList = []*MqQueue{

  14. 	{

  15. 		ExchangeName:   "",

  16. 		Name:           "cloud_issuance_async_mlogin",

  17. 		Type:           SimpleQueueType,

  18. 		IsPersistent:   false,

  19. 		RoutKey:        "",

  20. 		BindKey:        "",

  21. 		ConsumeFunName: "CloudIssuanceAsyncMLoginConsume",

  22. 	},

  23. 	{

  24. 		ExchangeName:   "",

  25. 		Name:           "super_cloud_issuance_async_mlogin",

  26. 		Type:           SimpleQueueType,

  27. 		IsPersistent:   false,

  28. 		RoutKey:        "",

  29. 		BindKey:        "",

  30. 		ConsumeFunName: "SuperCloudIssuanceAsyncMLoginConsume",

  31. 	},

  32. 	{

  33. 		ExchangeName:   "zhios.cloud.issuance.msg.callback.exchange",

  34. 		Name:           "cloud_issuance_msg_call_back",

  35. 		Type:           DirectQueueType,

  36. 		IsPersistent:   false,

  37. 		RoutKey:        "",

  38. 		BindKey:        "",

  39. 		ConsumeFunName: "CloudIssuanceMsgCallBackConsume",

  40. 	},

  41. 	{

  42. 		ExchangeName:   "zhios.super.cloud.issuance.msg.callback.exchange",

  43. 		Name:           "super_cloud_issuance_msg_call_back",

  44. 		Type:           DirectQueueType,

  45. 		IsPersistent:   false,

  46. 		RoutKey:        "",

  47. 		BindKey:        "",

  48. 		ConsumeFunName: "SuperCloudIssuanceMsgCallBackConsume",

  49. 	},

  50. 	{

  51. 		ExchangeName:   "zhios.cloud_chain.fenxiao.newChange.exchange",

  52. 		Name:           "cloud_chain_fenxiao_newChange",

  53. 		Type:           FanOutQueueType,

  54. 		IsPersistent:   false,

  55. 		RoutKey:        "",

  56. 		BindKey:        "",

  57. 		ConsumeFunName: "SupplyCloudChainFenxiaoNewChangeConsume",

  58. 	},

  59. 	{

  60. 		ExchangeName:   "zhios.addSupplyGoods.exchange",

  61. 		Name:           "mall_add_supply_goods",

  62. 		Type:           FanOutQueueType,

  63. 		IsPersistent:   false,

  64. 		RoutKey:        "",

  65. 		BindKey:        "",

  66. 		ConsumeFunName: "MallAddSupplyGoodsConsume",

  67. 	},

  68. 	{

  69. 		ExchangeName:   "canal.topic",

  70. 		Name:           "canal_order",

  71. 		Type:           TopicQueueType,

  72. 		IsPersistent:   false,

  73. 		RoutKey:        "canal_mall_order",

  74. 		BindKey:        "",

  75. 		ConsumeFunName: "CanalOrderConsume",

  76. 	},

  77. 	{

  78. 		ExchangeName:   "canal.topic",

  79. 		Name:           "canal_guide_order_for_numerical_statement",

  80. 		Type:           TopicQueueType,

  81. 		IsPersistent:   false,

  82. 		RoutKey:        "canal_order_list",

  83. 		BindKey:        "",

  84. 		ConsumeFunName: "CanalGuideOrderForNumericalStatementConsume",

  85. 	},

  86. 	{

  87. 		ExchangeName:   "canal.topic",

  88. 		Name:           "canal_mall_order_for_numerical_statement",

  89. 		Type:           TopicQueueType,

  90. 		IsPersistent:   false,

  91. 		RoutKey:        "canal_mall_order",

  92. 		BindKey:        "",

  93. 		ConsumeFunName: "CanalMallOrderForNumericalStatementConsume",

  94. 	},

  95. 	{

  96. 		ExchangeName:   "canal.topic",

  97. 		Name:           "canal_b2c_order_for_numerical_statement",

  98. 		Type:           TopicQueueType,

  99. 		IsPersistent:   false,

  100. 		RoutKey:        "canal_b2c_order",

  101. 		BindKey:        "",

  102. 		ConsumeFunName: "CanalB2cOrderForNumericalStatementConsume",

  103. 	},

  104. 	{

  105. 		ExchangeName:   "canal.topic",

  106. 		Name:           "canal_o2o_order_for_numerical_statement",

  107. 		Type:           TopicQueueType,

  108. 		IsPersistent:   false,

  109. 		RoutKey:        "canal_o2o_order",

  110. 		BindKey:        "",

  111. 		ConsumeFunName: "CanalO2oOrderForNumericalStatementConsume",

  112. 	},

  113. 	{

  114. 		ExchangeName:   "canal.topic",

  115. 		Name:           "canal_o2o_pay_order_for_numerical_statement",

  116. 		Type:           TopicQueueType,

  117. 		IsPersistent:   false,

  118. 		RoutKey:        "canal_o2o_pay_to_merchant",

  119. 		BindKey:        "",

  120. 		ConsumeFunName: "CanalO2oPayOrderForNumericalStatementConsume",

  121. 	},

  122. 	{

  123. 		ExchangeName:   "canal.topic",

  124. 		Name:           "canal_gim_message",

  125. 		Type:           TopicQueueType,

  126. 		IsPersistent:   false,

  127. 		RoutKey:        "canal_gim_message",

  128. 		BindKey:        "",

  129. 		ConsumeFunName: "CanalGimMessageConsume",

  130. 	},

  131. 	{

  132. 		ExchangeName:   "canal.topic",

  133. 		Name:           "canal_guide_order",

  134. 		Type:           TopicQueueType,

  135. 		IsPersistent:   false,

  136. 		RoutKey:        "canal_order_list",

  137. 		BindKey:        "",

  138. 		ConsumeFunName: "CanalGuideOrderConsume",

  139. 	},

  140. 	{

  141. 		ExchangeName:   "canal.topic",

  142. 		Name:           "canal_guide_order_by_user_up_lv",

  143. 		Type:           TopicQueueType,

  144. 		IsPersistent:   false,

  145. 		RoutKey:        "canal_order_list",

  146. 		BindKey:        "",

  147. 		ConsumeFunName: "CanalGuideOrderByUserUpLvConsume",

  148. 	},

  149. 	{

  150. 		ExchangeName:   "zhios.app.user.visit.ip.address.exchange",

  151. 		Name:           "zhios_user_visit_ip_address_queue",

  152. 		Type:           FanOutQueueType,

  153. 		IsPersistent:   false,

  154. 		RoutKey:        "queue_one",

  155. 		BindKey:        "",

  156. 		ConsumeFunName: "ZhiOsUserVisitIpAddressConsume",

  157. 	},

  158. 	{

  159. 		ExchangeName:   "zhios.order.fast.return.exchange",

  160. 		Name:           "zhios_fast_return_order_pay",

  161. 		Type:           DirectQueueType,

  162. 		IsPersistent:   false,

  163. 		RoutKey:        "order_pay",

  164. 		BindKey:        "",

  165. 		ConsumeFunName: "ZhiosFastReturnOrderPay",

  166. 	},

  167. 	{

  168. 		ExchangeName:   "zhios.order.fast.return.exchange",

  169. 		Name:           "zhios_fast_return_order_success",

  170. 		Type:           DirectQueueType,

  171. 		IsPersistent:   false,

  172. 		RoutKey:        "order_success",

  173. 		BindKey:        "",

  174. 		ConsumeFunName: "ZhiosFastReturnOrderSuccess",

  175. 	},

  176. 	{

  177. 		ExchangeName:   "zhios.order.fast.return.exchange",

  178. 		Name:           "zhios_fast_return_order_refund",

  179. 		Type:           DirectQueueType,

  180. 		IsPersistent:   false,

  181. 		RoutKey:        "order_refund",

  182. 		BindKey:        "",

  183. 		ConsumeFunName: "ZhiosFastReturnOrderRefund",

  184. 	},

  185. 	{

  186. 		ExchangeName:   "zhios.order.fast.return.exchange",

  187. 		Name:           "zhios_fast_return_order_refund_second",

  188. 		Type:           DirectQueueType,

  189. 		IsPersistent:   false,

  190. 		RoutKey:        "order_refund_second",

  191. 		BindKey:        "",

  192. 		ConsumeFunName: "ZhiosFastReturnOrderRefundSecond",

  193. 	},

  194. 	{

  195. 		ExchangeName:   "zhios.doushen.user.register.exchange",

  196. 		Name:           "zhios_doushen_user_register_my_fans",

  197. 		Type:           DirectQueueType,

  198. 		IsPersistent:   false,

  199. 		RoutKey:        "my_fans",

  200. 		BindKey:        "my_fans",

  201. 		ConsumeFunName: "DouShenUserRegisterConsumeForMyFans",

  202. 	},

  203. 	{

  204. 		ExchangeName:   "zhios.doushen.user.register.exchange",

  205. 		Name:           "zhios_doushen_user_register_operation_center",

  206. 		Type:           DirectQueueType,

  207. 		IsPersistent:   false,

  208. 		RoutKey:        "operation_center",

  209. 		BindKey:        "operation_center",

  210. 		ConsumeFunName: "DouShenUserRegisterConsumeForOperationCenter",

  211. 	},

  212. 	{

  213. 		ExchangeName:   "zhios.doushen.user.register.exchange",

  214. 		Name:           "zhios_doushen_user_register_my_recommender",

  215. 		Type:           DirectQueueType,

  216. 		IsPersistent:   false,

  217. 		RoutKey:        "my_recommender",

  218. 		BindKey:        "my_recommender",

  219. 		ConsumeFunName: "DouShenUserRegisterConsumeForMyRecommender",

  220. 	},

  221. 	{

  222. 		ExchangeName:   "zhios.doushen.user.register.exchange",

  223. 		Name:           "zhios_doushen_user_register_official",

  224. 		Type:           DirectQueueType,

  225. 		IsPersistent:   false,

  226. 		RoutKey:        "official",

  227. 		BindKey:        "official",

  228. 		ConsumeFunName: "DouShenUserRegisterConsumeForOfficial",

  229. 	},

  230. 	{

  231. 		ExchangeName:   "zhios.doushen.user.register.exchange",

  232. 		Name:           "zhios_doushen_user_register_user_comm_up_lv",

  233. 		Type:           DirectQueueType,

  234. 		IsPersistent:   false,

  235. 		RoutKey:        "user_register_comm_up_lv",

  236. 		BindKey:        "user_register_comm_up_lv",

  237. 		ConsumeFunName: "DouShenUserRegisterConsumeForUserRegisterUpLv",

  238. 	},

  239. 	{

  240. 		ExchangeName:   "canal.topic",

  241. 		Name:           "canal_mall_ord_for_you_mi_shang",

  242. 		Type:           DirectQueueType,

  243. 		IsPersistent:   false,

  244. 		RoutKey:        "canal_mall_order",

  245. 		BindKey:        "",

  246. 		ConsumeFunName: "CanalMallOrdForYouMiShang",

  247. 	},

  248. 	{

  249. 		ExchangeName:   "zhios.youmishang.exchange",

  250. 		Name:           "zhios_youmishang_exchange_store",

  251. 		Type:           DirectQueueType,

  252. 		IsPersistent:   false,

  253. 		RoutKey:        "store",

  254. 		BindKey:        "store",

  255. 		ConsumeFunName: "YoumishangExchangeStore",

  256. 	},

  257. 	{

  258. 		ExchangeName:   "zhios.recharge.order.exchange",

  259. 		Name:           "zhios_recharge_order_fail",

  260. 		Type:           DirectQueueType,

  261. 		IsPersistent:   false,

  262. 		RoutKey:        "order_fail",

  263. 		BindKey:        "",

  264. 		ConsumeFunName: "ZhiosRechargeOrderFail",

  265. 	},

  266. 	{

  267. 		ExchangeName:   "zhios.tikTok.exchange",

  268. 		Name:           "zhios_tikTok_update",

  269. 		Type:           DirectQueueType,

  270. 		IsPersistent:   false,

  271. 		RoutKey:        "update",

  272. 		BindKey:        "",

  273. 		ConsumeFunName: "ZhiosTikTokUpdate",

  274. 	},

  275. 	{

  276. 		ExchangeName:   "zhios.tikTok.exchange",

  277. 		Name:           "zhios_tikTok_all_update",

  278. 		Type:           DirectQueueType,

  279. 		IsPersistent:   false,

  280. 		RoutKey:        "all_update",

  281. 		BindKey:        "",

  282. 		ConsumeFunName: "ZhiosTikTokAllUpdate",

  283. 	},

  284. 	{

  285. 		ExchangeName:   "zhios.capital_pool.order_total.exchange",

  286. 		Name:           "zhios_capital_pool_order_total",

  287. 		Type:           DirectQueueType,

  288. 		IsPersistent:   false,

  289. 		RoutKey:        "order_total",

  290. 		BindKey:        "",

  291. 		ConsumeFunName: "ZhiosCapitalPoolOrderTotal",

  292. 	},

  293. 	{

  294. 		ExchangeName:   "zhios.acquisition.exchange",

  295. 		Name:           "zhios_acquisition_condition",

  296. 		Type:           DirectQueueType,

  297. 		IsPersistent:   false,

  298. 		RoutKey:        "condition",

  299. 		BindKey:        "",

  300. 		ConsumeFunName: "ZhiosAcquisitionCondition",

  301. 	},

  302. 	{

  303. 		ExchangeName:   "zhios.acquisition.exchange",

  304. 		Name:           "zhios_acquisition_condition_dev",

  305. 		Type:           DirectQueueType,

  306. 		IsPersistent:   false,

  307. 		RoutKey:        "acq_dev",

  308. 		BindKey:        "",

  309. 		ConsumeFunName: "ZhiosAcquisitionConditionDev",

  310. 	},

  311. 	{

  312. 		ExchangeName:   "zhios.recharge.order.exchange",

  313. 		Name:           "zhios_recharge_order_fail_dev",

  314. 		Type:           DirectQueueType,

  315. 		IsPersistent:   false,

  316. 		RoutKey:        "order_fail_dev",

  317. 		BindKey:        "",

  318. 		ConsumeFunName: "ZhiosRechargeOrderFailDev",

  319. 	},

  320. 	{

  321. 		ExchangeName:   "zhios.express.order.exchange",

  322. 		Name:           "zhios_express_order_fail",

  323. 		Type:           DirectQueueType,

  324. 		IsPersistent:   false,

  325. 		RoutKey:        "order_fail",

  326. 		BindKey:        "",

  327. 		ConsumeFunName: "zhiosExpressOrderFail",

  328. 	},

  329. 	{

  330. 		ExchangeName:   "zhios.withdraw.reward.exchange",

  331. 		Name:           "zhios_withdraw_reward",

  332. 		Type:           DirectQueueType,

  333. 		IsPersistent:   false,

  334. 		RoutKey:        "withdraw_reward",

  335. 		BindKey:        "",

  336. 		ConsumeFunName: "zhiosWithdrawReward",

  337. 	},

  338. 	{

  339. 		ExchangeName:   "zhios.task.exchange",

  340. 		Name:           "zhios_task_total",

  341. 		Type:           DirectQueueType,

  342. 		IsPersistent:   false,

  343. 		RoutKey:        "task_total",

  344. 		BindKey:        "",

  345. 		ConsumeFunName: "zhiosTaskTotal",

  346. 	},

  347. 	{

  348. 		ExchangeName:   "zhios.user_profile.exchange",

  349. 		Name:           "zhios_user_profile_invite_code",

  350. 		Type:           DirectQueueType,

  351. 		IsPersistent:   false,

  352. 		RoutKey:        "user_profile_invite_code",

  353. 		BindKey:        "",

  354. 		ConsumeFunName: "ZhiosUserProfileInviteCode",

  355. 	},

  356. 	{

  357. 		ExchangeName:   "zhios.user_profile.exchange",

  358. 		Name:           "zhios_auto_un_freeze",

  359. 		Type:           DirectQueueType,

  360. 		IsPersistent:   false,

  361. 		RoutKey:        "auto_un_freeze",

  362. 		BindKey:        "",

  363. 		ConsumeFunName: "ZhiosAutoUnFreeze",

  364. 	},

  365. 	{

  366. 		ExchangeName:   "zhios.user_valid.exchange",

  367. 		Name:           "zhios_user_valid",

  368. 		Type:           DirectQueueType,

  369. 		IsPersistent:   false,

  370. 		RoutKey:        "user_valid",

  371. 		BindKey:        "",

  372. 		ConsumeFunName: "ZhiosValidUser",

  373. 	},

  374. 	{

  375. 		ExchangeName:   "zhios.appreciation.exchange",

  376. 		Name:           "zhios_appreciation",

  377. 		Type:           DirectQueueType,

  378. 		IsPersistent:   false,

  379. 		RoutKey:        "appreciation",

  380. 		BindKey:        "",

  381. 		ConsumeFunName: "ZhiosAppreciation",

  382. 	},

  383. 	{

  384. 		ExchangeName:   "zhios.appreciation.exchange",

  385. 		Name:           "zhios_appreciation_dev",

  386. 		Type:           DirectQueueType,

  387. 		IsPersistent:   false,

  388. 		RoutKey:        "appreciation_dev",

  389. 		BindKey:        "",

  390. 		ConsumeFunName: "ZhiosAppreciationDev",

  391. 	},

  392. 	{

  393. 		ExchangeName:   "zhios.guide_store.exchange",

  394. 		Name:           "zhios_guide_store_order",

  395. 		Type:           DirectQueueType,

  396. 		IsPersistent:   false,

  397. 		RoutKey:        "guide_store_order",

  398. 		BindKey:        "",

  399. 		ConsumeFunName: "ZhiosGuideStoreOrder",

  400. 	},

  401. 	{

  402. 		ExchangeName:   "zhios.supplier_after_order.exchange",

  403. 		Name:           "zhios_supplier_after_order",

  404. 		Type:           DirectQueueType,

  405. 		IsPersistent:   false,

  406. 		RoutKey:        "refund",

  407. 		BindKey:        "",

  408. 		ConsumeFunName: "ZhiosSupplierAfterOrder",

  409. 	},

  410. 	{

  411. 		ExchangeName:   "zhios.order_buckle.exchange",

  412. 		Name:           "zhios_order_buckle",

  413. 		Type:           DirectQueueType,

  414. 		IsPersistent:   false,

  415. 		RoutKey:        "order_buckle",

  416. 		BindKey:        "",

  417. 		ConsumeFunName: "ZhiosOrderBuckle",

  418. 	},

  419. 	{

  420. 		ExchangeName:   "zhios.order_hjy.exchange",

  421. 		Name:           "zhios_order_hjy",

  422. 		Type:           DirectQueueType,

  423. 		IsPersistent:   false,

  424. 		RoutKey:        "order_hjy",

  425. 		BindKey:        "",

  426. 		ConsumeFunName: "ZhiosOrderHjy",

  427. 	},

  428. 	{

  429. 		ExchangeName:   "zhios.order_settle_total.exchange",

  430. 		Name:           "zhios_order_settle_total",

  431. 		Type:           DirectQueueType,

  432. 		IsPersistent:   false,

  433. 		RoutKey:        "order_settle_total",

  434. 		BindKey:        "",

  435. 		ConsumeFunName: "ZhiosOrderSettleTotal",

  436. 	},

  437. 	{

  438. 		ExchangeName:   "zhios.order_total.exchange",

  439. 		Name:           "zhios_order_total",

  440. 		Type:           DirectQueueType,

  441. 		IsPersistent:   false,

  442. 		RoutKey:        "order_total",

  443. 		BindKey:        "",

  444. 		ConsumeFunName: "ZhiosOrderTotal",

  445. 	},

  446. 	{

  447. 		ExchangeName:   "zhios.order_total.exchange",

  448. 		Name:           "zhios_order_total_second",

  449. 		Type:           DirectQueueType,

  450. 		IsPersistent:   false,

  451. 		RoutKey:        "order_total_second",

  452. 		BindKey:        "",

  453. 		ConsumeFunName: "ZhiosOrderTotalSecond",

  454. 	},

  455. 	{

  456. 		ExchangeName:   "zhios.order_free.exchange",

  457. 		Name:           "zhios_order_free",

  458. 		Type:           DirectQueueType,

  459. 		IsPersistent:   false,

  460. 		RoutKey:        "order_free",

  461. 		BindKey:        "",

  462. 		ConsumeFunName: "ZhiosOrderFree",

  463. 	},

  464. 	{

  465. 		ExchangeName:   "zhios.user_up_lv.exchange",

  466. 		Name:           "zhios_user_up_lv",

  467. 		Type:           DirectQueueType,

  468. 		IsPersistent:   false,

  469. 		RoutKey:        "user_up_lv",

  470. 		BindKey:        "",

  471. 		ConsumeFunName: "ZhiosUserUpLv",

  472. 	},

  473. 	{

  474. 		ExchangeName:   "zhios.integral_proxy_recharge.exchange",

  475. 		Name:           "zhios_integral_proxy_recharge",

  476. 		Type:           DirectQueueType,

  477. 		IsPersistent:   false,

  478. 		RoutKey:        "integral_proxy_recharge",

  479. 		BindKey:        "",

  480. 		ConsumeFunName: "ZhiosIntegralProxyRecharge",

  481. 	},

  482. 	{

  483. 		ExchangeName:   "zhios.mall_green_coin_consume.exchange",

  484. 		Name:           "zhios_mall_green_coin_consume",

  485. 		Type:           DirectQueueType,

  486. 		IsPersistent:   false,

  487. 		RoutKey:        "mall_green_coin_consume",

  488. 		BindKey:        "",

  489. 		ConsumeFunName: "ZhiosMallGreenCoinConsume",

  490. 	},

  491. 	{

  492. 		ExchangeName:   "canal.topic",

  493. 		Name:           "user_virtual_coin_flow_aggregation",

  494. 		Type:           TopicQueueType,

  495. 		IsPersistent:   false,

  496. 		RoutKey:        "canal_user_virtual_coin_flow_aggregation",

  497. 		BindKey:        "",

  498. 		ConsumeFunName: "ZhiosOneCirclesCoinConsume",

  499. 	},

  500. 	{

  501. 		ExchangeName:   "canal.topic",

  502. 		Name:           "canal_user_virtual_coin_flow",

  503. 		Type:           TopicQueueType,

  504. 		IsPersistent:   false,

  505. 		RoutKey:        "canal_user_virtual_coin_flow",

  506. 		BindKey:        "",

  507. 		ConsumeFunName: "CanalUserVirtualCoinFlowConsume",

  508. 	},

  509. 	{

  510. 		ExchangeName:   "canal.topic",

  511. 		Name:           "canal_service_award_dividend_relation",

  512. 		Type:           TopicQueueType,

  513. 		IsPersistent:   false,

  514. 		RoutKey:        "canal_service_award_dividend_relation",

  515. 		BindKey:        "",

  516. 		ConsumeFunName: "CanalServiceAwardDividendRelationConsume",

  517. 	},

  518. 	{

  519. 		ExchangeName:   "one.circles",

  520. 		Name:           "one_circles_sign_in_green_energy",

  521. 		Type:           TopicQueueType,

  522. 		IsPersistent:   false,

  523. 		RoutKey:        "sign_in",

  524. 		BindKey:        "",

  525. 		ConsumeFunName: "OneCirclesSignInGreenEnergyConsume",

  526. 	},

  527. 	{

  528. 		ExchangeName:   "one.circles",

  529. 		Name:           "one_circles_start_level_dividend",

  530. 		Type:           TopicQueueType,

  531. 		IsPersistent:   false,

  532. 		RoutKey:        "star_level_dividend",

  533. 		BindKey:        "",

  534. 		ConsumeFunName: "OneCirclesStartLevelDividendConsume",

  535. 	},

  536. 	{

  537. 		ExchangeName:   "one.circles",

  538. 		Name:           "one_circles_auto_exchange_green_energy_to_person_1",

  539. 		Type:           TopicQueueType,

  540. 		IsPersistent:   false,

  541. 		RoutKey:        "auto_exchange_green_energy_to_person_1",

  542. 		BindKey:        "",

  543. 		ConsumeFunName: "OneCirclesActivityCoinAutoExchangeGreenEnergyConsume",

  544. 	},

  545. 	{

  546. 		ExchangeName:   "one.circles",

  547. 		Name:           "one_circles_auto_exchange_green_energy_to_team",

  548. 		Type:           TopicQueueType,

  549. 		IsPersistent:   false,

  550. 		RoutKey:        "auto_exchange_green_energy_to_team",

  551. 		BindKey:        "",

  552. 		ConsumeFunName: "OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamConsume",

  553. 	},

  554. 	{

  555. 		ExchangeName:   "one.circles",

  556. 		Name:           "one_circles_settlement_public_give_activity_coin",

  557. 		Type:           TopicQueueType,

  558. 		IsPersistent:   false,

  559. 		RoutKey:        "settlement_public_give_activity_coin",

  560. 		BindKey:        "",

  561. 		ConsumeFunName: "OneCirclesSettlementPublicGiveActivityCoinConsume",

  562. 	},

  563. 	{

  564. 		ExchangeName:   "one.circles",

  565. 		Name:           "one_circles_add_public_platoon_user_relation_commission",

  566. 		Type:           TopicQueueType,

  567. 		IsPersistent:   false,

  568. 		RoutKey:        "add_public_platoon_user_relation_commission",

  569. 		BindKey:        "",

  570. 		ConsumeFunName: "OneCirclesAddPublicPlatoonUserRelationCommissionConsume",

  571. 	},

  572. 	{

  573. 		ExchangeName:   "one.circles",

  574. 		Name:           "one_circles_reward_user_coin",

  575. 		Type:           TopicQueueType,

  576. 		IsPersistent:   false,

  577. 		RoutKey:        "reward_user_coin",

  578. 		BindKey:        "",

  579. 		ConsumeFunName: "OneCirclesDealUserCoinConsume",

  580. 	},

  581. 	{

  582. 		ExchangeName:   "zhios.app.user.withdraw.apply.exchange",

  583. 		Name:           "zhios_app_user_withdraw_apply_queue",

  584. 		Type:           FanOutQueueType,

  585. 		IsPersistent:   false,

  586. 		RoutKey:        "queues_one",

  587. 		BindKey:        "",

  588. 		ConsumeFunName: "WithdrawConsume",

  589. 	},

  590. 	{

  591. 		ExchangeName:   "zhios.app.user.withdraw.apply.flexible.employment.exchange",

  592. 		Name:           "zhios_app_user_withdraw_apply_gongmao_queue",

  593. 		Type:           DirectQueueType,

  594. 		IsPersistent:   false,

  595. 		RoutKey:        "gongmao",

  596. 		BindKey:        "",

  597. 		ConsumeFunName: "FlexibleEmploymentWithdrawForGongMaoConsume",

  598. 	},

  599. 	{

  600. 		ExchangeName:   "zhios.app.user.withdraw.apply.flexible.employment.exchange",

  601. 		Name:           "zhios_app_user_withdraw_apply_pupiao_queue",

  602. 		Type:           DirectQueueType,

  603. 		IsPersistent:   false,

  604. 		RoutKey:        "pupiao",

  605. 		BindKey:        "",

  606. 		ConsumeFunName: "FlexibleEmploymentWithdrawForPupiaoConsume",

  607. 	},

  608. 	{

  609. 		ExchangeName:   "zhios.app.user.withdraw.apply.flexible.employment.exchange",

  610. 		Name:           "zhios_app_user_withdraw_apply_new_pupiao_queue",

  611. 		Type:           DirectQueueType,

  612. 		IsPersistent:   false,

  613. 		RoutKey:        "new_pupiao",

  614. 		BindKey:        "",

  615. 		ConsumeFunName: "NewFlexibleEmploymentWithdrawForPupiaoConsume",

  616. 	},

  617. 	{

  618. 		ExchangeName:   "installment.payment",

  619. 		Name:           "zhios_installment_payment_auto_repaid",

  620. 		Type:           DirectQueueType,

  621. 		IsPersistent:   false,

  622. 		RoutKey:        "auto_repaid",

  623. 		BindKey:        "",

  624. 		ConsumeFunName: "InstallmentPaymentAutoRepaidConsume",

  625. 	},

  626. 	{

  627. 		ExchangeName:   "service.award.dividend",

  628. 		Name:           "service_award_dividend_relation",

  629. 		Type:           DirectQueueType,

  630. 		IsPersistent:   false,

  631. 		RoutKey:        "",

  632. 		BindKey:        "",

  633. 		ConsumeFunName: "ServiceAwardDividendRelationConsume",

  634. 	},

  635. 	{

  636. 		ExchangeName:   "honey.dividend",

  637. 		Name:           "honey_dividend_user_reward",

  638. 		Type:           DirectQueueType,

  639. 		IsPersistent:   false,

  640. 		RoutKey:        "user_dividend",

  641. 		BindKey:        "",

  642. 		ConsumeFunName: "DividendRewardConsume",

  643. 	},

  644. 	{

  645. 		ExchangeName:   "honey.dividend",

  646. 		Name:           "honey_user_contribution_exchange",

  647. 		Type:           DirectQueueType,

  648. 		IsPersistent:   false,

  649. 		RoutKey:        "user_contribution_exchange",

  650. 		BindKey:        "",

  651. 		ConsumeFunName: "ContributionExchangeConsume",

  652. 	},

  653. }

  654. 

  655. const (

  656. 	ZhiosUserRelateFunName                                      = "ZhiosUserRelate"

  657. 	ZhiosIntegralProxyRechargeFunName                           = "ZhiosIntegralProxyRecharge"

  658. 	ZhiosMallGreenCoinConsumeFunName                            = "ZhiosMallGreenCoinConsume"

  659. 	ZhiosOneCirclesCoinConsumeFunName                           = "ZhiosOneCirclesCoinConsume"

  660. 	ZhiosUserUpLvFunName                                        = "ZhiosUserUpLv"

  661. 	CanalGuideOrderByUserUpLvConsume                            = "CanalGuideOrderByUserUpLvConsume"

  662. 	ZhiosOrderFreeFunName                                       = "ZhiosOrderFree"

  663. 	ZhiosOrderSettleTotalFunName                                = "ZhiosOrderSettleTotal"

  664. 	ZhiosOrderTotalFunName                                      = "ZhiosOrderTotal"

  665. 	ZhiosOrderTotalSecondFunName                                = "ZhiosOrderTotalSecond"

  666. 	ZhiosOrderHjyFunName                                        = "ZhiosOrderHjy"

  667. 	ZhiosOrderBuckleFunName                                     = "ZhiosOrderBuckle"

  668. 	ZhiosSupplierAfterOrderFunName                              = "ZhiosSupplierAfterOrder"

  669. 	CanalOrderConsumeFunName                                    = "CanalOrderConsume"

  670. 	CanalGuideOrderForNumericalStatementConsumeFunName          = "CanalGuideOrderForNumericalStatementConsume"

  671. 	CanalMallOrderForNumericalStatementConsumeFunName           = "CanalMallOrderForNumericalStatementConsume"

  672. 	CanalO2oOrderForNumericalStatementConsumeFunName            = "CanalO2oOrderForNumericalStatementConsume"

  673. 	CanalO2oPayOrderForNumericalStatementConsumeFunName         = "CanalO2oPayOrderForNumericalStatementConsume"

  674. 	CanalB2cOrderForNumericalStatementConsumeFunName            = "CanalB2cOrderForNumericalStatementConsume"

  675. 	CanalGuideOrderConsumeFunName                               = "CanalGuideOrderConsume"

  676. 	ZhiOsUserVisitIpAddressConsumeFunName                       = "ZhiOsUserVisitIpAddressConsume"

  677. 	DouShenUserRegisterConsumeForOfficialFunName                = "DouShenUserRegisterConsumeForOfficial"

  678. 	DouShenUserRegisterConsumeForOperationCenterFunName         = "DouShenUserRegisterConsumeForOperationCenter"

  679. 	DouShenUserRegisterConsumeForMyRecommenderFunName           = "DouShenUserRegisterConsumeForMyRecommender"

  680. 	DouShenUserRegisterConsumeForMyFansFunName                  = "DouShenUserRegisterConsumeForMyFans"

  681. 	DouShenUserRegisterConsumeForUserRegisterUpLvFunName        = "DouShenUserRegisterConsumeForUserRegisterUpLv"

  682. 	ZhiosFastReturnOrderPayFunName                              = "ZhiosFastReturnOrderPay"

  683. 	ZhiosFastReturnOrderSuccessFunName                          = "ZhiosFastReturnOrderSuccess"

  684. 	ZhiosFastReturnOrderRefundFunName                           = "ZhiosFastReturnOrderRefund"

  685. 	ZhiosFastReturnOrderRefundSecondFunName                     = "ZhiosFastReturnOrderRefundSecond"

  686. 	CanalMallOrdForYouMiShangFunName                            = "CanalMallOrdForYouMiShang"

  687. 	YoumishangExchangeStoreFunName                              = "YoumishangExchangeStore"

  688. 	ZhiosRechargeOrderFailFunName                               = "ZhiosRechargeOrderFail"

  689. 	ZhiosRechargeOrderFailDevFunName                            = "ZhiosRechargeOrderFailDev"

  690. 	ZhiosCapitalPoolOrderTotalFunName                           = "ZhiosCapitalPoolOrderTotal"

  691. 	ZhiosExpressOrderFail                                       = "zhiosExpressOrderFail"

  692. 	ZhiosWithdrawReward                                         = "zhiosWithdrawReward"

  693. 	ZhiosTikTokUpdateFunName                                    = "ZhiosTikTokUpdate"

  694. 	ZhiosTikTokAllUpdateFunName                                 = "ZhiosTikTokAllUpdate"

  695. 	CloudIssuanceAsyncMLoginFunName                             = "CloudIssuanceAsyncMLoginConsume"

  696. 	CloudIssuanceMsgCallBackFunName                             = "CloudIssuanceMsgCallBackConsume"

  697. 	SuperCloudIssuanceAsyncMLoginFunName                        = "SuperCloudIssuanceAsyncMLoginConsume"

  698. 	SuperCloudIssuanceMsgCallBackFunName                        = "SuperCloudIssuanceMsgCallBackConsume"

  699. 	ZhiosAcquisitionConditionFunName                            = "ZhiosAcquisitionCondition"

  700. 	ZhiosValidUserFunName                                       = "ZhiosValidUser"

  701. 	ZhiosAppreciationFunName                                    = "ZhiosAppreciation"

  702. 	ZhiosAppreciationDevFunName                                 = "ZhiosAppreciationDev"

  703. 	ZhiosGuideStoreOrderFunName                                 = "ZhiosGuideStoreOrder"

  704. 	ZhiosAcquisitionConditionDevFunName                         = "ZhiosAcquisitionConditionDev"

  705. 	SupplyCloudChainFenxiaoNewChangeFunName                     = "SupplyCloudChainFenxiaoNewChangeConsume"

  706. 	MallAddSupplyGoodsFunName                                   = "MallAddSupplyGoodsConsume"

  707. 	CanalUserVirtualCcoinFlowFunName                            = "CanalUserVirtualCoinFlowConsume"

  708. 	OneCirclesSignInGreenEnergyFunName                          = "OneCirclesSignInGreenEnergyConsume"

  709. 	OneCirclesDealUserCoinConsumeFunName                        = "OneCirclesDealUserCoinConsume"

  710. 	OneCirclesStartLevelDividendFunName                         = "OneCirclesStartLevelDividendConsume"

  711. 	OneCirclesActivityCoinAutoExchangeGreenEnergyFunName        = "OneCirclesActivityCoinAutoExchangeGreenEnergyConsume"

  712. 	OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamFunName = "OneCirclesActivityCoinAutoExchangeGreenEnergyForTeamConsume"

  713. 	OneCirclesSettlementPublicGiveActivityCoinFunName           = "OneCirclesSettlementPublicGiveActivityCoinConsume"

  714. 	OneCirclesAddPublicPlatoonUserRelationCommissionFunName     = "OneCirclesAddPublicPlatoonUserRelationCommissionConsume"

  715. 	WithdrawConsumeFunName                                      = "WithdrawConsume"

  716. 	FlexibleEmploymentWithdrawForGongMaoConsumeFunName          = "FlexibleEmploymentWithdrawForGongMaoConsume"

  717. 	FlexibleEmploymentWithdrawForPupiaoConsumeFunName           = "FlexibleEmploymentWithdrawForPupiaoConsume"

  718. 	NewFlexibleEmploymentWithdrawForPupiaoConsumeFunName        = "NewFlexibleEmploymentWithdrawForPupiaoConsume"

  719. 	ZhiosTaskTotal                                              = "zhiosTaskTotal"

  720. 	ZhiosUserProfileInviteCode                                  = "ZhiosUserProfileInviteCode"

  721. 	ZhiosAutoUnFreeze                                           = "ZhiosAutoUnFreeze"

  722. 	InstallmentPaymentAutoRepaidConsumeFunName                  = "InstallmentPaymentAutoRepaidConsume"

  723. 	CanalGimMessageConsumeFunName                               = "CanalGimMessageConsume"

  724. 	ServiceAwardDividendRelationConsumeFunName                  = "ServiceAwardDividendRelationConsume"

  725. 	CanalServiceAwardDividendRelationConsumeFunName             = "CanalServiceAwardDividendRelationConsume"

  726. 	DividendRewardConsumeFunName                                = "DividendRewardConsume"

  727. 	ContributionExchangeConsumeFunName                          = "ContributionExchangeConsume"

  728. )