conflect

Helius

2021-05-26 f5d87a5a585adcbb148dee6c62ff6e18c4e7334c

 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);
    }
}