package com.qianwen.core.task.config;
|
|
import com.qianwen.core.context.task.TaskSender;
|
import com.qianwen.core.task.sender.redis.RedisTaskSender;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
|
@ConditionalOnClass({StringRedisTemplate.class})
|
@ConditionalOnProperty(prefix = TaskProperties.PREFIX, name = {"distributor"}, havingValue = TaskDistributorTypeConstants.REDIS)
|
@Configuration(proxyBeanMethods = false)
|
/* loaded from: blade-starter-task-9.3.0.0-SNAPSHOT.jar:org/springblade/core/task/config/RedisTaskSenderConfiguration.class */
|
public class RedisTaskSenderConfiguration {
|
@ConditionalOnMissingBean({TaskSender.class})
|
@Bean
|
public RedisTaskSender redisTaskSender(StringRedisTemplate stringRedisTemplate) {
|
return new RedisTaskSender(stringRedisTemplate);
|
}
|
}
|