本文整理了Java中org.fusesource.mqtt.client.MQTT.setReconnectAttemptsMax()方法的一些代码示例，展示了MQTT.setReconnectAttemptsMax()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。MQTT.setReconnectAttemptsMax()方法的具体详情如下：
包路径：org.fusesource.mqtt.client.MQTT
类名称：MQTT
方法名：setReconnectAttemptsMax

MQTT.setReconnectAttemptsMax介绍

暂无

代码示例

代码示例来源：origin: apache/storm

client.setReconnectBackOffMultiplier(options.getReconnectBackOffMultiplier());
client.setConnectAttemptsMax(options.getConnectAttemptsMax());
client.setReconnectAttemptsMax(options.getReconnectAttemptsMax());

代码示例来源：origin: PerfCake/PerfCake

mqttClient.setHost(protocol + "://" + host + ":" + port);
mqttClient.setConnectAttemptsMax(0);
mqttClient.setReconnectAttemptsMax(0);
if (userName != null) {
  mqttClient.setUserName(userName);
   mqttResponseClient.setHost(responseProtocol + "://" + responseHost + ":" + responsePort);
   mqttResponseClient.setConnectAttemptsMax(0);
   mqttResponseClient.setReconnectAttemptsMax(0);
   if (responseUserName != null) {
     mqttResponseClient.setUserName(responseUserName);

代码示例来源：origin: apache/activemq-artemis

private MQTT createMQTTSslConnection(String clientId, boolean clean) throws Exception {
 MQTT mqtt = new MQTT();
 mqtt.setConnectAttemptsMax(1);
 mqtt.setReconnectAttemptsMax(0);
 mqtt.setTracer(createTracer());
 mqtt.setHost("ssl://localhost:" + port);
 if (clientId != null) {
   mqtt.setClientId(clientId);
 }
 mqtt.setCleanSession(clean);
 SSLContext ctx = SSLContext.getInstance("TLS");
 ctx.init(new KeyManager[0], new TrustManager[]{new DefaultTrustManager()}, new SecureRandom());
 mqtt.setSslContext(ctx);
 return mqtt;
}

代码示例来源：origin: apache/activemq-artemis

@Override
public void connect(String host) throws Exception {
 mqtt.setHost(host);
 mqtt.setVersion("3.1.1");
 // shut off connect retry
 mqtt.setConnectAttemptsMax(0);
 mqtt.setReconnectAttemptsMax(0);
 connection = mqtt.blockingConnection();
 connection.connect();
}

代码示例来源：origin: apache/activemq-artemis

private MQTT createMQTTTcpConnection(String clientId, boolean clean) throws Exception {
 MQTT mqtt = new MQTT();
 mqtt.setConnectAttemptsMax(1);
 mqtt.setReconnectAttemptsMax(0);
 mqtt.setTracer(createTracer());
 mqtt.setVersion("3.1.1");
 if (clientId != null) {
   mqtt.setClientId(clientId);
 }
 mqtt.setCleanSession(clean);
 mqtt.setHost("localhost", port);
 return mqtt;
}

代码示例来源：origin: apache/activemq-artemis

private BlockingConnection retrieveMQTTConnection(String host, String truststorePath, String truststorePass, String keystorePath, String keystorePass) throws Exception {
 MQTT mqtt = new MQTT();
 mqtt.setConnectAttemptsMax(1);
 mqtt.setReconnectAttemptsMax(0);
 mqtt.setHost(host);
 SSLContext sslContext = new SSLSupport()
   .setKeystorePath(keystorePath)
   .setKeystorePassword(keystorePass)
   .setTruststorePath(truststorePath)
   .setTruststorePassword(truststorePass)
   .createContext();
 mqtt.setSslContext(sslContext);
 BlockingConnection connection = mqtt.blockingConnection();
 connection.connect();
 return connection;
}