modify

Helius

2021-05-21 d30d959c8f249c20b39e66dd0c48341a77751d21

 src/main/java/com/xcong/excoin/rabbit/consumer/OtcConsumer.java

@@ -6,14 +6,22 @@
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;

import java.util.Date;

@Slf4j
@Component
@ConditionalOnProperty(prefix = "app", name = "otc-job", havingValue = "true")
public class OtcConsumer {


    @RabbitListener(queues = RabbitMqConfig.QUEUE_MARKET_BUSSINESS)
//    @RabbitListener(queues = RabbitMqConfig.QUEUE_MARKET_BUSSINESS)
    public void marketBussiness(String content) {
        log.info("---->{}", content);
    }


    @RabbitListener(queues = RabbitMqConfig.QUEUE_DELAY)
    public void delayOrder(String content) {
        log.info("--{}-->{}", new Date(), content);
    }
}