com.baidubce.services.dugo.core.protocol.mqtt
Class MqttConnection

java.lang.Object
  extended by com.baidubce.services.dugo.core.protocol.mqtt.MqttConnection

public class MqttConnection
extends Object

MQTT connect base Created by liuzhenxing01 on 2018/10/9.


Constructor Summary
MqttConnection(String serverURI, String clientId, String userName, String password, SocketFactory socketFactory, org.eclipse.paho.client.mqttv3.MqttCallback mqttCallbackListener, org.eclipse.paho.client.mqttv3.IMqttActionListener mqttMessageListener)
           
 
Method Summary
 void close()
           
 org.eclipse.paho.client.mqttv3.IMqttToken disconnect()
           
static SSLSocketFactory getFactory(KeyStore keystore)
           
static SSLSocketFactory getFactory(KeyStore caKeystore, KeyStore clientKeystore, String keystorePassword)
          get SSLSocketFactory
 org.eclipse.paho.client.mqttv3.MqttAsyncClient getMqttAsyncClient()
           
 boolean isConnected()
          is connect success
 void openConnection()
           
 void publishMessage(BceIotMessage message)
          publish message
 void subscribeTopic(BceIotMessage message)
          subscribe Topic
 void unsubscribeTopic(BceIotMessage message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MqttConnection

public MqttConnection(String serverURI,
                      String clientId,
                      String userName,
                      String password,
                      SocketFactory socketFactory,
                      org.eclipse.paho.client.mqttv3.MqttCallback mqttCallbackListener,
                      org.eclipse.paho.client.mqttv3.IMqttActionListener mqttMessageListener)
               throws org.eclipse.paho.client.mqttv3.MqttException
Throws:
org.eclipse.paho.client.mqttv3.MqttException
Method Detail

getMqttAsyncClient

public org.eclipse.paho.client.mqttv3.MqttAsyncClient getMqttAsyncClient()

isConnected

public boolean isConnected()
is connect success

Returns:
false

disconnect

public org.eclipse.paho.client.mqttv3.IMqttToken disconnect()
                                                     throws org.eclipse.paho.client.mqttv3.MqttException
Throws:
org.eclipse.paho.client.mqttv3.MqttException

close

public void close()
           throws org.eclipse.paho.client.mqttv3.MqttException
Throws:
org.eclipse.paho.client.mqttv3.MqttException

openConnection

public void openConnection()

publishMessage

public void publishMessage(BceIotMessage message)
publish message

Parameters:
message -

subscribeTopic

public void subscribeTopic(BceIotMessage message)
subscribe Topic

Parameters:
message -

unsubscribeTopic

public void unsubscribeTopic(BceIotMessage message)

getFactory

public static SSLSocketFactory getFactory(KeyStore keystore)
Parameters:
keystore -
Returns:
Throws:
NoSuchAlgorithmException
KeyStoreException
KeyManagementException
IOException
CertificateException

getFactory

public static SSLSocketFactory getFactory(KeyStore caKeystore,
                                          KeyStore clientKeystore,
                                          String keystorePassword)
get SSLSocketFactory

Parameters:
caKeystore -
clientKeystore -
keystorePassword -
Returns:


Copyright © 2018. All rights reserved.