import com.ibm.iotf.client.device.Command; //导入依赖的package包/类
/**
 * This method is invoked by the library whenever there is command matching the subscription criteria
 */
@Override
public void processCommand(Command cmd) {
	try {
		queue.put(cmd);
		} catch (InterruptedException e) {
	}			
}
 

import com.ibm.iotf.client.device.Command; //导入依赖的package包/类
@Override
public void run() {
	while(true) {
		Command cmd = null;
		try {
			//In this sample, we just display the command
			cmd = queue.take();
			System.out.println("COMMAND RECEIVED = '" + cmd.getCommand() + "'\twith Payload = '" + cmd.getPayload() + "'");
		} catch (InterruptedException e) {}
	}
}
 

import com.ibm.iotf.client.device.Command; //导入依赖的package包/类
@Override
public void accept(Consumer<Command> commandSubmitter) {
    
    try {
        connector.subscribeCommands(commandSubmitter);
    } catch (Exception e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}
 

import com.ibm.iotf.client.device.Command; //导入依赖的package包/类
synchronized void subscribeCommands(Consumer<Command> tupleSubmitter) throws Exception {
    DeviceClient client = getClient();
    
    client.setCommandCallback(cmd -> {
        tupleSubmitter.accept(cmd);
    });
}
 

import com.ibm.iotf.client.device.Command; //导入依赖的package包/类
/**
 * This method is invoked by the library whenever there is command matching the subscription criteria
 */
@Override
public void processCommand(Command cmd) {
	commandReceived = true;
	System.out.println("Received command, name = "+cmd.getCommand() +
			", format = " + cmd.getFormat() + ", Payload = "+cmd.getPayload() + ", time = "+cmd.getTimestamp());
}
 

import com.ibm.iotf.client.device.Command; //导入依赖的package包/类
@Override
public void processCommand(Command command) {
	System.out.println("COMMAND RECEIVED = '" + command.getCommand() + 
			"'\twith Payload = '" + command.getPayload() + "'");		
}
 

import com.ibm.iotf.client.device.Command; //导入依赖的package包/类
private TStream<Command> allCommands() {
    if (commandStream == null)
        commandStream = topology.events(new IotfDeviceCommands(connector));
    return commandStream;
}