|
|
@@ -7,6 +7,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
|
|
|
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
|
|
|
import org.springframework.cloud.openfeign.EnableFeignClients;
|
|
|
import org.springframework.context.annotation.Bean;
|
|
|
+import org.springframework.context.annotation.ComponentScan;
|
|
|
import org.springframework.messaging.Message;
|
|
|
import reactor.core.publisher.Flux;
|
|
|
import reactor.core.publisher.FluxSink;
|
|
|
@@ -17,6 +18,7 @@ import java.util.function.Supplier;
|
|
|
@EnableDubbo
|
|
|
@EnableFeignClients({"com.sckw.*.api.feign"})
|
|
|
@EnableDiscoveryClient
|
|
|
+@ComponentScan(basePackages = { "com.sckw.core","com.sckw.message"})
|
|
|
@SpringBootApplication
|
|
|
public class MessageApplication {
|
|
|
|