TRC20版本提交

zainali5120

2021-01-16 869769dedf8722109c944db9a5d9fac97591c2d3

 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