20210525 申诉

xiaoyong931011

2021-05-26 0ca7bf5c850eaef852a6b49d4b94e8366deedb29

 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_MARKET_BUSSINESS)
    public void delayOrder(String content) {
        log.info("--{}-->{}", new Date(), content);
    }
}