Java 类org.eclipse.paho.client.mqttv3.internal.ClientComms 实例源码

/**
 * Dump information that show the version of the MQTT client being used.
 */
protected void dumpVersion() {
    StringBuffer vInfo = new StringBuffer();
    vInfo.append(lineSep + separator + " Version Info " + separator + lineSep);
    vInfo.append(left("Version", 20, ' ') + ":  " + ClientComms.VERSION + lineSep);
    vInfo.append(left("Build Level", 20, ' ') + ":  " + ClientComms.BUILD_LEVEL + lineSep);
    vInfo.append(separator + separator + separator + lineSep);
    log.fine(className, "dumpVersion", vInfo.toString());
}

/**
 * Dump information that show the version of the MQTT client being used.
 */
protected void dumpVersion() {
    StringBuffer vInfo = new StringBuffer();
    vInfo.append(lineSep+separator+" Version Info "+ separator+lineSep);
    vInfo.append(left("Version",20,' ') + ":  "+ ClientComms.VERSION + lineSep);
    vInfo.append(left("Build Level",20,' ') + ":  "+ ClientComms.BUILD_LEVEL + lineSep);
    vInfo.append(separator+separator+separator+lineSep);
    log.fine(CLASS_NAME,"dumpVersion", vInfo.toString());
}

@Override
public void init(ClientComms comms) {
    this.comms = comms;
    this.alarmReceiver = new AlarmReceiver();
}

@Override
public void init(ClientComms comms) {
    this.comms = comms;
    this.alarmReceiver = new AlarmReceiver();
}

@Override
public void init(ClientComms comms) {
    this.comms = comms;
    this.alarmReceiver = new AlarmReceiver();
}

public MqttTopic(String name, ClientComms comms) {
    this.comms = comms;
    this.name = name;
}

@Override
public void init(ClientComms comms) {
    this.comms = comms;
    this.alarmReceiver = new AlarmReceiver();
}

public void init(ClientComms comms) {
    if (comms == null) {
        throw new IllegalArgumentException("ClientComms cannot be null.");
    }
    this.comms = comms;
}

public MqttTopic(String name, ClientComms comms) {
    this.comms = comms;
    this.name = name;
}

/**
 * Set the debug facility up for a specific client
 * @param clientID  the ID of the client being debugged
 * @param comms    the ClientComms object of the client being debugged
 */
public Debug(String clientID, ClientComms comms) {
    this.clientID = clientID;
    this.comms = comms;
    log.setResourceName(clientID);
}

/**
 * Set the debug facility up for a specific client
 *
 * @param clientID the ID of the client being debugged
 * @param comms    the ClientComms object of the client being debugged
 */
public Debug(String clientID, ClientComms comms) {
    this.clientID = clientID;
    this.comms = comms;
    log.setResourceName(clientID);
}

/**
 * Initial method. Pass interal state of current client in.
 * @param  The core of the client, which holds the state information for pending and in-flight messages.
 */
public void init(ClientComms comms);