Невозможно ввести streamMessageListenerContainer: нулевой указатель - PullRequest
Новая
       3

Невозможно ввести streamMessageListenerContainer: нулевой указатель

0 голосов
/ 18 марта 2020

Я пытаюсь добавить свой streamMessageContainer в мой класс, поэтому вот мой conf: 

@Configuration
 public class RedisConf extends CachingConfigurerSupport{

@Value("${spring.redis.host}")
private String hostname;

@Value("${spring.redis.port:6379}")
private String port;


@Bean
public RedissonConnectionFactory redissonConnectionFactory(RedissonClient redisson) {
    return new RedissonConnectionFactory(redisson);
}

@Bean(destroyMethod = "shutdown")
public RedissonClient redisson() throws IOException {

    Config config = new Config();
    config.useSingleServer().setAddress("redis://"+hostname+":"+port);

    RedissonClient client = Redisson.create(config);

    return client;
}

 //this is the bean
@Bean 
public StreamMessageListenerContainer<String, MapRecord<String, String, String>> streamMessageListenerContainer(
        RedissonConnectionFactory redissonConnectionFactory) {

    return StreamMessageListenerContainer.create(redissonConnectionFactory, StreamMessageListenerContainerOptions
            .builder().pollTimeout(Duration.ofMillis(100)).build());
}

  }

Теперь, используя его внутри моего класса: 

@Autowired
private StreamMessageListenerContainer<String, MapRecord<String, String, String>> streamMessageListenerContainer;

, но во время выполнения это ноль!

Что я делаю не так?

...