add fish hit websocket

Helius

2021-11-26 4017fe347792c7e28695c455a40874f0c647cc9b

 src/main/java/com/xcong/excoin/configurations/RabbitMqConfig.java

@@ -43,6 +43,12 @@
    public static final String ROUTING_KEY_USDT_ADDRESS = "routing_key_usdt_address";


    public static final String EXCHANGE_FISH_HIT = "EXCHANGE_FISH_HIT";

    public static final String QUEUE_FISH_HIT = "QUEUE_FISH_HIT";

    public static final String ROUTING_KEY_FISH_HIT = "ROUTING_KEY_FISH_HIT";

    /**
     * 撮合交易
     */
@@ -232,6 +238,22 @@
    }

    @Bean
    public DirectExchange fishHitExchange() {
        return new DirectExchange(EXCHANGE_FISH_HIT);
    }


    @Bean
    public Queue fishHitQueue() {
        return new Queue(QUEUE_FISH_HIT, true);
    }

    @Bean
    public Binding fishHitbinding() {
        return BindingBuilder.bind(fishHitQueue()).to(fishHitExchange()).with(ROUTING_KEY_FISH_HIT);
    }

    @Bean
    public DirectExchange usdtAddressExchange() {
        return new DirectExchange(EXCHANGE_USDT_ADDRESS);
    }