public interface MqttPahoClientFactory
Modifier and Type | Method and Description |
---|---|
org.eclipse.paho.client.mqttv3.IMqttAsyncClient |
getAsyncClientInstance(String url,
String clientId)
Retrieve an async client instance.
|
org.eclipse.paho.client.mqttv3.IMqttClient |
getClientInstance(String url,
String clientId)
Retrieve a client instance.
|
org.eclipse.paho.client.mqttv3.MqttConnectOptions |
getConnectionOptions()
Retrieve the connection options.
|
ConsumerStopAction |
getConsumerStopAction()
Get the consumer stop action.
|
org.eclipse.paho.client.mqttv3.IMqttClient getClientInstance(String url, String clientId) throws org.eclipse.paho.client.mqttv3.MqttException
url
- The URL.clientId
- The client id.org.eclipse.paho.client.mqttv3.MqttException
- Any.org.eclipse.paho.client.mqttv3.IMqttAsyncClient getAsyncClientInstance(String url, String clientId) throws org.eclipse.paho.client.mqttv3.MqttException
url
- The URL.clientId
- The client id.org.eclipse.paho.client.mqttv3.MqttException
- Any.org.eclipse.paho.client.mqttv3.MqttConnectOptions getConnectionOptions()
ConsumerStopAction getConsumerStopAction()