import org.eclipse.paho.client.mqttv3.internal.ClientComms; //导入依赖的package包/类
/**
 * 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());
}
 

import org.eclipse.paho.client.mqttv3.internal.ClientComms; //导入依赖的package包/类
/**
 * 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());
}
 

import org.eclipse.paho.client.mqttv3.internal.ClientComms; //导入依赖的package包/类
@Override
public void init(ClientComms comms) {
	this.comms = comms;
	this.alarmReceiver = new AlarmReceiver();
}
 

import org.eclipse.paho.client.mqttv3.internal.ClientComms; //导入依赖的package包/类
@Override
public void init(ClientComms comms) {
    this.comms = comms;
    this.alarmReceiver = new AlarmReceiver();
}
 

import org.eclipse.paho.client.mqttv3.internal.ClientComms; //导入依赖的package包/类
public MqttTopic(String name, ClientComms comms) {
    this.comms = comms;
    this.name = name;
}
 

import org.eclipse.paho.client.mqttv3.internal.ClientComms; //导入依赖的package包/类
public void init(ClientComms comms) {
	if (comms == null) {
		throw new IllegalArgumentException("ClientComms cannot be null.");
	}
	this.comms = comms;
}
 

import org.eclipse.paho.client.mqttv3.internal.ClientComms; //导入依赖的package包/类
public MqttTopic(String name, ClientComms comms) {
	this.comms = comms;
	this.name = name;
}
 

import org.eclipse.paho.client.mqttv3.internal.ClientComms; //导入依赖的package包/类
/**
 * 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);
}
 

import org.eclipse.paho.client.mqttv3.internal.ClientComms; //导入依赖的package包/类
/**
 * 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);
}
 

import org.eclipse.paho.client.mqttv3.internal.ClientComms; //导入依赖的package包/类
/**
 * 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);