|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.baidubce.services.dugo.core.protocol.mqtt.MqttConnection
public class MqttConnection
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 |
---|
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
org.eclipse.paho.client.mqttv3.MqttException
Method Detail |
---|
public org.eclipse.paho.client.mqttv3.MqttAsyncClient getMqttAsyncClient()
public boolean isConnected()
public org.eclipse.paho.client.mqttv3.IMqttToken disconnect() throws org.eclipse.paho.client.mqttv3.MqttException
org.eclipse.paho.client.mqttv3.MqttException
public void close() throws org.eclipse.paho.client.mqttv3.MqttException
org.eclipse.paho.client.mqttv3.MqttException
public void openConnection()
public void publishMessage(BceIotMessage message)
message
- public void subscribeTopic(BceIotMessage message)
message
- public void unsubscribeTopic(BceIotMessage message)
public static SSLSocketFactory getFactory(KeyStore keystore)
keystore
-
NoSuchAlgorithmException
KeyStoreException
KeyManagementException
IOException
CertificateException
public static SSLSocketFactory getFactory(KeyStore caKeystore, KeyStore clientKeystore, String keystorePassword)
caKeystore
- clientKeystore
- keystorePassword
-
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |