| | |
|---|
| | | String[] topics = mqttProperties.getTopics().split(","); |
|---|
| | | //topicList.toArray(topics); |
|---|
| | | |
|---|
| | | MqttPahoMessageDrivenChannelAdapter adapter = |
|---|
| | | new MqttPahoMessageDrivenChannelAdapter(mqttProperties.getClientInId(), receiverMqttClientFactoryForSub(), topics); |
|---|
| | | MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter(mqttProperties.getClientInId(), receiverMqttClientFactoryForSub(), topics); |
|---|
| | | adapter.setCompletionTimeout(mqttProperties.getCompletionTimeout()); |
|---|
| | | adapter.setConverter(new DefaultPahoMessageConverter()); |
|---|
| | | adapter.setQos(mqttProperties.getQos()); |
|---|
