package com.vincent.rsf.schedule.common.config;
|
|
import com.vincent.rsf.framework.common.SnowflakeIdWorker;
|
import com.vincent.rsf.schedule.common.domain.QueueTask;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.ComponentScan;
|
import org.springframework.context.annotation.Configuration;
|
|
import java.util.concurrent.LinkedBlockingQueue;
|
|
/**
|
* Created by vincent on 12/19/2023
|
*/
|
@Configuration
|
@ComponentScan(value = "com.vincent.rsf.schedule.common.config")
|
public class BeanConfig {
|
|
@Bean
|
public LinkedBlockingQueue<QueueTask> unlockTaskQueue() {
|
return new LinkedBlockingQueue<>();
|
}
|
|
@Bean
|
public SnowflakeIdWorker snowflakeIdWorker() {
|
return new SnowflakeIdWorker();
|
}
|
|
}
|
