Java – Null pointer exception: Cannot send from MessageListener to client via websocket with Spring boot

Null pointer exception: Cannot send from MessageListener to client via websocket with Spring boot… here is a solution to the problem.

Null pointer exception: Cannot send from MessageListener to client via websocket with Spring boot

After subscribing to messages from Redis, I’m trying to send messages to topic /topic/room.
My code is as follows.

@Component
public class RedisSubscriber implements MessageListener {

static private Logger log = Logger.getLogger(RedisSubscriber.class.getName());

@Autowired
    private SimpMessagingTemplate template;

@Override
    public void onMessage(final Message message, final byte[] pattern) {

log.info("template: " + template);
        template.convertAndSend("/topic/room", message);
        log.info("Message send: " + message.toString());
    }
}

The results are as follows.
I don’t know why the SimpMessagingTemplate object is empty.
SimpMessagingTemplate doesn’t seem to be @Autowired.
Do I need to create additional templates?
Please give me advice.

You get the following exception

2017-07-12 19:53:24.920  INFO 8724 --- [edisContainer-2] j.c.t.l.delivery.redis.RedisSubscriber   : template: null
2017-07-12 19:53:24.939 ERROR 8724 --- [edisContainer-2] o.s.d.r.l.a.MessageListenerAdapter       : Listener execution failed

java.lang.NullPointerException: null
    at XXXX.redis.RedisSubscriber.onMessage(RedisSubscriber.java:27) ~[classes/:na]
    at org.springframework.data.redis.listener.adapter.MessageListenerAdapter.onMessage(MessageListenerAdapter.java:299) ~[spring-data-redis-1.8.4.RELEASE.jar:na]
    at org.springframework.data.redis.listener.RedisMessageListenerContainer.executeListener(RedisMessageListenerContainer.java:249) [spring-data-redis-1.8.4.RELEASE.jar:na ]
    at org.springframework.data.redis.listener.RedisMessageListenerContainer.processMessage(RedisMessageListenerContainer.java:239) [spring-data-redis-1.8.4.RELEASE.jar:na]
    at org.springframework.data.redis.listener.RedisMessageListenerContainer$1.run(RedisMessageListenerContainer.java:967) [spring-data-redis-1.8.4.RELEASE.jar:na]
    at java.lang.Thread.run(Thread.java:748) [na:1.8.0_131]

Additional information is provided below.
This is how I get the RedisSubscriber and register it with the MessageListenerAdapter.

@Configuration
@EnableScheduling
public class AppConfig {

@Bean
    JedisConnectionFactory jedisConnectionFactory() {
        return new JedisConnectionFactory();
    }

@Bean
    RedisTemplate<String, Object> redisTemplate() {
        final RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
        template.setConnectionFactory(jedisConnectionFactory());
        template.setKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(new GenericToStringSerializer<Object>(Object.class));
        template.setValueSerializer(new GenericToStringSerializer<Object>(Object.class));
        return template;
    }

@Bean
    MessageListenerAdapter messageListener() {
        return new MessageListenerAdapter(new RedisSubscriber());
    }

@Bean
    RedisMessageListenerContainer redisContainer() {
        final RedisMessageListenerContainer container = new RedisMessageListenerContainer();

container.setConnectionFactory(jedisConnectionFactory());
        container.addMessageListener(messageListener(), topic());

return container;
    }

@Bean
    RedisPublisher redisPublisher() {
        return new RedisPublisher(redisTemplate(), topic());
    }

@Bean
    ChannelTopic topic() {
        return new ChannelTopic("topic");
    }
}

Solution

In AppConfig, you can automatically connect your subscribers

@Configuration
@EnableScheduling
public class AppConfig {
    @Autowire
    RedisSubscriber redisSubscriber

@Bean
    MessageListenerAdapter messageListener() {
        return new MessageListenerAdapter(redisSubscriber);
    }
}

If your subscribers use @Service annotations, you can automatically connect to the service in the subscriber class:

@Service
public class RedisSubscriber implements MessageListener {
    @Autowired
    private SimpMessagingTemplate template // should be non-null
}

Related Problems and Solutions