| | |
|---|
| | | */ |
|---|
| | | @Bean |
|---|
| | | public MessageProducer inbound() { |
|---|
| | | java.util.Random r = new java.util.Random(); |
|---|
| | | |
|---|
| | | String clientId = "spring-boot-mqtt-client-inbound"+r.nextInt(1000); |
|---|
| | | MqttPahoMessageDrivenChannelAdapter adapter = |
|---|
| | | new MqttPahoMessageDrivenChannelAdapter("spring-boot-mqtt-client-inbound", |
|---|
| | | new MqttPahoMessageDrivenChannelAdapter(clientId, |
|---|
| | | mqttClientFactory(), COLLECT_DATA_TOPIC, FEEDBACK_TOPIC,WOCKSTATION_CREATE_TOPIC);//最后一个参数允许多个topic参数 |
|---|
| | | adapter.setCompletionTimeout(5000); |
|---|
| | | adapter.setConverter(new DefaultPahoMessageConverter()); |
|---|
