本文整理汇总了Java中org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions类的典型用法代码示例。如果您正苦于以下问题:Java DisconnectedBufferOptions类的具体用法?Java DisconnectedBufferOptions怎么用?Java DisconnectedBufferOptions使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
DisconnectedBufferOptions类属于org.eclipse.paho.client.mqttv3包,在下文中一共展示了DisconnectedBufferOptions类的8个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: init
import org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions; //导入依赖的package包/类
@PostConstruct
public void init() throws Exception {
scheduler = Executors.newSingleThreadScheduledExecutor();
tbClientOptions = new MqttConnectOptions();
tbClientOptions.setCleanSession(false);
tbClientOptions.setMaxInflight(connection.getMaxInFlight());
tbClientOptions.setAutomaticReconnect(true);
MqttGatewaySecurityConfiguration security = connection.getSecurity();
security.setupSecurityOptions(tbClientOptions);
tbClient = new MqttAsyncClient((security.isSsl() ? "ssl" : "tcp") + "://" + connection.getHost() + ":" + connection.getPort(),
security.getClientId(), persistence.getPersistence());
tbClient.setCallback(this);
if (persistence.getBufferSize() > 0) {
DisconnectedBufferOptions options = new DisconnectedBufferOptions();
options.setBufferSize(persistence.getBufferSize());
options.setBufferEnabled(true);
options.setPersistBuffer(true);
tbClient.setBufferOpts(options);
}
connect();
scheduler.scheduleAtFixedRate(this::reportStats, 0, reporting.getInterval(), TimeUnit.MILLISECONDS);
}
开发者ID:osswangxining,项目名称:iot-edge-greengrass,代码行数:28,代码来源:MqttGatewayService.java
示例2: init
import org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions; //导入依赖的package包/类
@PostConstruct
public void init() throws Exception {
scheduler = Executors.newSingleThreadScheduledExecutor();
tbClientOptions = new MqttConnectOptions();
tbClientOptions.setCleanSession(false);
tbClientOptions.setMaxInflight(connection.getMaxInFlight());
tbClientOptions.setAutomaticReconnect(true);
MqttGatewaySecurityConfiguration security = connection.getSecurity();
security.setupSecurityOptions(tbClientOptions);
tbClient = new MqttAsyncClient(
(security.isSsl() ? "ssl" : "tcp") + "://" + connection.getHost() + ":" + connection.getPort(),
security.getClientId(), persistence.getPersistence());
tbClient.setCallback(this);
if (persistence.getBufferSize() > 0) {
DisconnectedBufferOptions options = new DisconnectedBufferOptions();
options.setBufferSize(persistence.getBufferSize());
options.setBufferEnabled(true);
options.setPersistBuffer(true);
tbClient.setBufferOpts(options);
}
connect();
scheduler.scheduleAtFixedRate(this::reportStats, 0, reporting.getInterval(), TimeUnit.MILLISECONDS);
}
开发者ID:osswangxining,项目名称:iotgateway,代码行数:29,代码来源:MqttGatewayService.java
示例3: connect
import org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions; //导入依赖的package包/类
@NonNull
@CheckReturnValue
public static Maybe<IMqttToken> connect(
@NonNull final MqttAndroidClient client,
@NonNull final DisconnectedBufferOptions disconnectedBufferOptions) {
return connect(client, new MqttConnectOptions(), disconnectedBufferOptions);
}
开发者ID:yongjhih,项目名称:rx-mqtt,代码行数:8,代码来源:RxMqtt.java
示例4: defaultDisconnectedBufferOptions
import org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions; //导入依赖的package包/类
@NonNull
@CheckReturnValue
public static DisconnectedBufferOptions defaultDisconnectedBufferOptions() {
final DisconnectedBufferOptions bufferOptions = new DisconnectedBufferOptions();
bufferOptions.setBufferEnabled(true);
bufferOptions.setBufferSize(100);
bufferOptions.setPersistBuffer(false);
bufferOptions.setDeleteOldestMessages(false);
return bufferOptions;
}
开发者ID:yongjhih,项目名称:rx-mqtt,代码行数:11,代码来源:RxMqtt.java
示例5: setBufferOpts
import org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions; //导入依赖的package包/类
/**
* Sets the DisconnectedBufferOptions for this client
* @param bufferOpts
*/
public void setBufferOpts(DisconnectedBufferOptions bufferOpts) {
this.bufferOpts = bufferOpts;
myClient.setBufferOpts(bufferOpts);
}
开发者ID:Cirrus-Link,项目名称:Sparkplug,代码行数:9,代码来源:MqttConnection.java
示例6: reconnect
import org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions; //导入依赖的package包/类
public static Maybe<IMqttToken> reconnect(
@NonNull final MqttAndroidClient client,
@NonNull final MqttConnectOptions options,
@Nullable final DisconnectedBufferOptions bufferOptions) {
return connect(client, options, bufferOptions);
}
开发者ID:yongjhih,项目名称:rx-mqtt,代码行数:7,代码来源:RxMqtt.java
示例7: setBufferOpts
import org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions; //导入依赖的package包/类
/**
* Sets the DisconnectedBufferOptions for this client
* @param clientHandle identifier for the client
* @param bufferOpts the DisconnectedBufferOptions for this client
*/
public void setBufferOpts(String clientHandle, DisconnectedBufferOptions bufferOpts) {
MqttConnection client = getConnection(clientHandle);
client.setBufferOpts(bufferOpts);
}
开发者ID:Cirrus-Link,项目名称:Sparkplug,代码行数:10,代码来源:MqttService.java
示例8: setBufferOpts
import org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions; //导入依赖的package包/类
/**
* Sets the DisconnectedBufferOptions for this client
* @param bufferOpts the DisconnectedBufferOptions
*/
public void setBufferOpts(DisconnectedBufferOptions bufferOpts) {
mqttService.setBufferOpts(clientHandle, bufferOpts);
}
开发者ID:Cirrus-Link,项目名称:Sparkplug,代码行数:8,代码来源:MqttAndroidClient.java
注:本文中的org.eclipse.paho.client.mqttv3.DisconnectedBufferOptions类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论