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);
}
 

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);
}
 

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);
}
 

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;
}
 

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);
}
 

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);
}
 

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);
}
 

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);
}