Обработка сообщений, полученных при интеграции Spring mqtt, и сохранение их в базе данных. - PullRequest
Новая
       10

Обработка сообщений, полученных при интеграции Spring mqtt, и сохранение их в базе данных.

0 голосов
/ 20 сентября 2018

Я работаю с Spring MQTT интеграции, чтобы подписать тему и сохранить сообщение по этой теме в базе данных.

здесь в этом коде для обработки входящих сообщений, 

@Bean
@ServiceActivator(inputChannel = "mqttInputChannel")
public MessageHandler handler() {
    return new MessageHandler() {

        public void handleMessage(Message<?> message) throws MessagingException {
            System.out.println(message.getPayload());
            System.out.println(message.getHeaders());
        }

    };
}

сообщениесодержимое доступно в консоли.

Мое намерение состоит в том, чтобы получить этот bean-компонент на уровне контроллера с помощью автоматической проводки, чтобы сообщение было доступно там.Проблема в том, что я не могу правильно настроить его на уровне контроллера.

...