|
|
|
@@ -5,6 +5,7 @@ import org.eclipse.paho.client.mqttv3.MqttConnectOptions; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.context.annotation.Bean; |
|
|
|
import org.springframework.context.annotation.Configuration; |
|
|
|
import org.springframework.integration.annotation.IntegrationComponentScan; |
|
|
|
import org.springframework.integration.annotation.ServiceActivator; |
|
|
|
import org.springframework.integration.channel.DirectChannel; |
|
|
|
import org.springframework.integration.channel.ExecutorChannel; |
|
|
|
@@ -26,6 +27,7 @@ import java.util.concurrent.ThreadPoolExecutor; |
|
|
|
* mqtt config |
|
|
|
*/ |
|
|
|
@Configuration |
|
|
|
@IntegrationComponentScan("com.xueyi.common.mqtt.connection") |
|
|
|
public class MqttConfigV2 { |
|
|
|
|
|
|
|
@Autowired |
|
|
|
|