From 869769dedf8722109c944db9a5d9fac97591c2d3 Mon Sep 17 00:00:00 2001 From: zainali5120 <512061637@qq.com> Date: Sat, 16 Jan 2021 14:41:57 +0800 Subject: [PATCH] TRC20版本提交 --- src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java | 86 +++++++++++++++++++++--------------------- 1 files changed, 43 insertions(+), 43 deletions(-) diff --git a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java index 0a590b2..cbc0438 100644 --- a/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java +++ b/src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java @@ -21,111 +21,111 @@ @Configuration public class RabbitMqConfig { - public static final String EXCHANGE_ONE = "biue-exchange-one"; + public static final String EXCHANGE_ONE = "biue-exchange-one_t"; - public static final String QUEUE_TEST = "test-queue"; + public static final String QUEUE_TEST = "test-queue_t"; - public static final String ROUTING_KEY_TEST = "test-routingKey"; + public static final String ROUTING_KEY_TEST = "test-routingKey_t"; - public static final String EXCHANGE_A = "biue-exchange-A"; + public static final String EXCHANGE_A = "biue-exchange-A_t"; - public static final String EXCHANGE_USDT_UPDATE = "exchange_usdt_update"; + public static final String EXCHANGE_USDT_UPDATE = "exchange_usdt_update_t"; - public static final String QUEUE_USDT_UPDATE = "queue_usdt_update"; + public static final String QUEUE_USDT_UPDATE = "queue_usdt_update_t"; - public static final String ROUTING_KEY_USDT_UPDATE = "routing_key_usdt_update"; + public static final String ROUTING_KEY_USDT_UPDATE = "routing_key_usdt_update_t"; - public static final String EXCHANGE_USDT_ADDRESS = "exchange_usdt_address"; + public static final String EXCHANGE_USDT_ADDRESS = "exchange_usdt_address_t"; - public static final String QUEUE_USDT_ADDRESS= "queue_usdt_address"; + public static final String QUEUE_USDT_ADDRESS= "queue_usdt_address_t"; - public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address"; + public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address_t"; /** * 撮合交易 */ - public static final String EXCHANGE_B = "biue-exchange-B"; + public static final String EXCHANGE_B = "biue-exchange-B_t"; // 开多止盈队列 - public static final String QUEUE_MOREPRO = "QUEUE_MOREPRO_NEW"; + public static final String QUEUE_MOREPRO = "QUEUE_MOREPRO_NEW_t"; // 开空止盈队列 - public static final String QUEUE_LESSPRO = "QUEUE_LESSPRO_NEW"; + public static final String QUEUE_LESSPRO = "QUEUE_LESSPRO_NEW_t"; // 开多止损队列 - public static final String QUEUE_MORELOSS = "QUEUE_MORELOSS_NEW"; + public static final String QUEUE_MORELOSS = "QUEUE_MORELOSS_NEW_t"; // 开空止损队列 - public static final String QUEUE_LESSLOSS = "QUEUE_LESSLOSS_NEW"; + public static final String QUEUE_LESSLOSS = "QUEUE_LESSLOSS_NEW_t"; // 限价委托 - public static final String QUEUE_LIMIT = "QUEUE_LIMIT_NEW"; + public static final String QUEUE_LIMIT = "QUEUE_LIMIT_NEW_t"; // 爆仓队列 - public static final String QUEUE_COINOUT = "QUEUE_COINOUT_NEW"; + public static final String QUEUE_COINOUT = "QUEUE_COINOUT_NEW_t"; //价格操作 - public static final String QUEUE_PRICEOPERATE = "QUEUE_PRICEOPERATE_NEW"; + public static final String QUEUE_PRICEOPERATE = "QUEUE_PRICEOPERATE_NEW_t"; // 平仓队列 - public static final String QUEUE_CLOSETRADE = "QUEUE_CLOSETRADE_NEW"; + public static final String QUEUE_CLOSETRADE = "QUEUE_CLOSETRADE_NEW_t"; // 盘口队列 - public static final String QUEUE_TRADE_PLATE = "QUEUE_TRADE_PLATE"; + public static final String QUEUE_TRADE_PLATE = "QUEUE_TRADE_PLATE_t"; // 处理交易 - public static final String QUEUE_HANDLE_TRADE = "QUEUE_HANDLE_TRADE"; + public static final String QUEUE_HANDLE_TRADE = "QUEUE_HANDLE_TRADE_t"; // 开多止盈路由键 - public static final String ROUTINGKEY_MOREPRO = "ROUTINGKEY_MOREPRO"; + public static final String ROUTINGKEY_MOREPRO = "ROUTINGKEY_MOREPRO_t"; // 开空止盈路由 - public static final String ROUTINGKEY_LESSPRO = "ROUTINGKEY_LESSPRO"; + public static final String ROUTINGKEY_LESSPRO = "ROUTINGKEY_LESSPRO_t"; // 开多止损路由 - public static final String ROUTINGKEY_MORELOSS = "ROUTINGKEY_MORELOSS"; + public static final String ROUTINGKEY_MORELOSS = "ROUTINGKEY_MORELOSS_t"; // 开空止损路由 - public static final String ROUTINGKEY_LESSLOSS = "ROUTINGKEY_LESSLOSS"; + public static final String ROUTINGKEY_LESSLOSS = "ROUTINGKEY_LESSLOSS_t"; // 限价委托 - public static final String ROUTINGKEY_LIMIT = "ROUTINGKEY_LIMIT"; + public static final String ROUTINGKEY_LIMIT = "ROUTINGKEY_LIMIT_t"; // 爆仓路由 - public static final String ROUTINGKEY_COINOUT = "ROUTINGKEY_COINOUT"; + public static final String ROUTINGKEY_COINOUT = "ROUTINGKEY_COINOUT_t"; // 价格操作 - public static final String ROUTINGKEY_PRICEOPERATE = "ROUTINGKEY_PRICEOPERATE"; + public static final String ROUTINGKEY_PRICEOPERATE = "ROUTINGKEY_PRICEOPERATE_t"; // 平仓路由 - public static final String ROUTINGKEY_CLOSETRADE = "ROUTINGKEY_CLOSETRADE"; + public static final String ROUTINGKEY_CLOSETRADE = "ROUTINGKEY_CLOSETRADE_t"; // 盘口理路由 - public static final String ROUTINGKEY_TRADE_PLATE = "ROUTINGKEY_TRADE_PLATE"; + public static final String ROUTINGKEY_TRADE_PLATE = "ROUTINGKEY_TRADE_PLATE_t"; // 交易订单处理 - public static final String ROUTINGKEY_HANDLE_TRADE = "ROUTINGKEY_HANDLE_TRADE"; + public static final String ROUTINGKEY_HANDLE_TRADE = "ROUTINGKEY_HANDLE_TRADE_t"; - public static final String EXCHANGE_ROC = "roc-transfer"; + public static final String EXCHANGE_ROC = "roc-transfer_t"; - public static final String QUEUE_ROC= "roc-queue"; + public static final String QUEUE_ROC= "roc-queue_t"; - public static final String ROUTING_KEY_ROC = "roc-transfer-routingKey"; + public static final String ROUTING_KEY_ROC = "roc-transfer-routingKey_t"; - public static final String EXCHANGE_ROC_ORDER_SUBMIT = "roc-exchange-order-submit"; + public static final String EXCHANGE_ROC_ORDER_SUBMIT = "roc-exchange-order-submit_t"; - public static final String QUEUE_ROC_ORDER_SUBMIT = "roc-order-queue-submit"; + public static final String QUEUE_ROC_ORDER_SUBMIT = "roc-order-queue-submit_t"; - public static final String ROUTING_KEY_ROC_ORDER_SUBMIT = "roc-order-routingKey-submit"; + public static final String ROUTING_KEY_ROC_ORDER_SUBMIT = "roc-order-routingKey-submit_t"; - public static final String EXCHANGE_ROC_ORDER_CANCEL = "roc-exchange-order-cancel"; + public static final String EXCHANGE_ROC_ORDER_CANCEL = "roc-exchange-order-cancel_t"; - public static final String QUEUE_ROC_ORDER_CANCEL = "roc-order-queue-cancel"; + public static final String QUEUE_ROC_ORDER_CANCEL = "roc-order-queue-cancel_t"; - public static final String ROUTING_KEY_ROC_ORDER_CANCEL = "roc-order-routingKey-cancel"; + public static final String ROUTING_KEY_ROC_ORDER_CANCEL = "roc-order-routingKey-cancel_t"; - public static final String EXCHANGE_ROC_ORDER_COMPLETE = "roc-exchange-order-complete"; + public static final String EXCHANGE_ROC_ORDER_COMPLETE = "roc-exchange-order-complete_t"; - public static final String QUEUE_ROC_ORDER_COMPLETE = "roc-order-queue-complete"; + public static final String QUEUE_ROC_ORDER_COMPLETE = "roc-order-queue-complete_t"; - public static final String ROUTING_KEY_ROC_ORDER_COMPLETE = "roc-order-routingKey-complete"; + public static final String ROUTING_KEY_ROC_ORDER_COMPLETE = "roc-order-routingKey-complete_t"; @Resource -- Gitblit v1.9.1