package com.fdkankan.contro;

import com.dtflys.forest.springboot.annotation.ForestScan;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;

/**
 * <p>
 * </p>
 *
 * @author dengsixing
 * @since 2022/2/22
 **/
@SpringBootApplication
@EnableScheduling
@ComponentScan(basePackages = {"com.fdkankan.*"})
@EnableAsync
@MapperScan("com.fdkankan.**.mapper")
@EnableDiscoveryClient
@ForestScan(basePackages = "com.fdkankan.contro.httpclient")
public class ModelingControlApplication {
    public static void main(String[] args) {
        SpringApplication.run(ModelingControlApplication.class, args);

//        NSQLookup lookup = new DefaultNSQLookup();
//        lookup.addLookupAddress("192.168.0.127", 4161);
//        NSQConsumer consumer = new NSQConsumer(lookup, "topic-bd", "channel-bd", (message) -> {
//            System.out.println("received: " + message);
//            //now mark the message as finished.
//            message.finished();
//
//            //or you could requeue it, which indicates a failure and puts it back on the queue.
////            message.requeue();
//        });
//
//        consumer.start();
    }
}