Java OperatingState类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.edgexfoundry.domain.meta.OperatingState类的典型用法代码示例。如果您正苦于以下问题：Java OperatingState类的具体用法？Java OperatingState怎么用？Java OperatingState使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

OperatingState类属于org.edgexfoundry.domain.meta包，在下文中一共展示了OperatingState类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: provision

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public void provision(ScanList availableList) {
	if(availableList != null && availableList.getScan().size() > 0){
		for (Map<String,String> device : availableList.getScan()) {
			Device matchingDevice = deviceExists(device);
			if (matchingDevice != null) {
				if (matchingDevice.getOperatingState().equals(OperatingState.DISABLED) || devices.getDevice(matchingDevice.getName()) == null) {
					matchingDevice.setOperatingState(OperatingState.ENABLED);
					devices.add(matchingDevice);
				}
				continue;
			}
			
			ProvisionWatcher watcher = deviceMatches(device);
			if (watcher != null) {
				//Provision the device
				Device newDevice = createDevice(device, watcher);
				devices.add(newDevice);
			}
		}
	}
	
}

开发者ID:edgexfoundry，项目名称:device-modbus，代码行数:23，代码来源:DeviceDiscovery.java

示例2: provision

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public void provision(ScanList availableList) {
  if (availableList != null && availableList.getScan().size() > 0) {
    for (Map<String, String> device : availableList.getScan()) {
      Device matchingDevice = deviceExists(device);

      if (matchingDevice != null) {
        if (matchingDevice.getOperatingState().equals(OperatingState.disabled)
            || devices.getDevice(matchingDevice.getName()) == null) {
          matchingDevice.setOperatingState(OperatingState.enabled);
          devices.add(matchingDevice);
        }

        continue;
      }

      ProvisionWatcher watcher = deviceMatches(device);
      if (watcher != null) {
        // Provision the device
        Device newDevice = createDevice(device, watcher);
        devices.add(newDevice);
      }
    }
  }
}

开发者ID:mgjeong，项目名称:device-opcua-java，代码行数:25，代码来源:DeviceDiscovery.java

示例3: add

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public boolean add(Device device) {
  if (devices.containsKey(device.getName())) {
    devices.remove(device.getName());
    profiles.removeDevice(device);
  }

  logger.info("Adding managed device:  " + device.getName());
  Device metaDevice = addDeviceToMetaData(device);

  if (metaDevice == null) {
    remove(device);
    return false;
  }

  if (metaDevice.getOperatingState().equals(OperatingState.enabled)) {
    OPCUA.initializeDevice(metaDevice);
  }

  return true;
}

开发者ID:mgjeong，项目名称:device-opcua-java，代码行数:21，代码来源:DeviceStore.java

示例4: add

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public boolean add(Device device) {
  if (devices.containsKey(device.getName())) {
    devices.remove(device.getName());
    profiles.removeDevice(device);
  }

  logger.info("Adding managed device:  " + device.getName());
  Device metaDevice = addDeviceToMetaData(device);

  if (metaDevice == null) {
    remove(device);
    return false;
  }

  if (metaDevice.getOperatingState().equals(OperatingState.ENABLED)) {
    mqtt.initializeDevice(metaDevice);
  }

  return true;
}

开发者ID:edgexfoundry，项目名称:device-mqtt，代码行数:21，代码来源:DeviceStore.java

示例5: provision

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public void provision(ScanList availableList) {
  if (availableList != null && availableList.getScan().size() > 0) {
    for (Map<String, String> device : availableList.getScan()) {
      Device matchingDevice = deviceExists(device);

      if (matchingDevice != null) {
        if (matchingDevice.getOperatingState().equals(OperatingState.DISABLED)
            || devices.getDevice(matchingDevice.getName()) == null) {
          matchingDevice.setOperatingState(OperatingState.ENABLED);
          devices.add(matchingDevice);
        }

        continue;
      }

      ProvisionWatcher watcher = deviceMatches(device);
      if (watcher != null) {
        // Provision the device
        Device newDevice = createDevice(device, watcher);
        devices.add(newDevice);
      }
    }
  }
}

开发者ID:edgexfoundry，项目名称:device-mqtt，代码行数:25，代码来源:DeviceDiscovery.java

示例6: add

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public boolean add(Device device) {
  if (devices.containsKey(device.getName())) {
    devices.remove(device.getName());
    profiles.removeDevice(device);
  }

  logger.info("Adding managed device:  " + device.getName());
  Device metaDevice = addDeviceToMetaData(device);

  if (metaDevice == null) {
    remove(device);
    return false;
  }

  if (metaDevice.getOperatingState().equals(OperatingState.ENABLED)) {
    Ble.initializeDevice(metaDevice);
  }

  return true;
}

开发者ID:edgexfoundry，项目名称:device-bluetooth，代码行数:21，代码来源:DeviceStore.java

示例7: provision

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public void provision(ScanList availableList) {
  if (availableList != null && availableList.getScan().size() > 0) {
    for (Map<String,String> device : availableList.getScan()) {
      Device matchingDevice = deviceExists(device);

      if (matchingDevice != null) {
        if (matchingDevice.getOperatingState().equals(OperatingState.DISABLED)
            || devices.getDevice(matchingDevice.getName()) == null) {
          matchingDevice.setOperatingState(OperatingState.ENABLED);
          devices.add(matchingDevice);
        }

        continue;
      }

      ProvisionWatcher watcher = deviceMatches(device);
      if (watcher != null) {
        // Provision the device
        Device newDevice = createDevice(device, watcher);
        devices.add(newDevice);
      }
    }
  }
}

开发者ID:edgexfoundry，项目名称:device-bluetooth，代码行数:25，代码来源:DeviceDiscovery.java

示例8: remove

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public boolean remove(Device device) {
	logger.debug("Removing managed device:  " + device.getName());
	if (devices.containsKey(device.getName())) {
		devices.remove(device.getName());			
		Modbus.disconnectDevice(device);
		deviceClient.updateOpState(device.getId(), OperatingState.DISABLED.name());
		profiles.removeDevice(device);
	}
	return true;
}

开发者ID:edgexfoundry，项目名称:device-modbus，代码行数:11，代码来源:DeviceStore.java

示例9: add

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public boolean add(Device device) {
	if (devices.containsKey(device.getName())) {
		devices.remove(device.getName());
		profiles.removeDevice(device);
	}
	logger.info("Adding managed device:  " + device.getName());
	Device metaDevice = addDeviceToMetaData(device);
	if (metaDevice == null) {
		remove(device);
		return false;
	}
	if (metaDevice.getOperatingState().equals(OperatingState.ENABLED))
		Modbus.initializeDevice(metaDevice);
	return true;
}

开发者ID:edgexfoundry，项目名称:device-modbus，代码行数:16，代码来源:DeviceStore.java

示例10: initialize

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public Map<String, Device> initialize(String id) {
	List<Device> metaDevices = deviceClient.devicesForService(id);
	devices = new HashMap<>();
	watchers.initialize(id);
	Modbus.initialize();
	for (Device device : metaDevices) {
		deviceClient.updateOpState(device.getId(),OperatingState.DISABLED.name());
		add(device);
	}
	logger.info("Device service has " + devices.size() + " devices.");
	return getDevices();
}

开发者ID:edgexfoundry，项目名称:device-modbus，代码行数:13，代码来源:DeviceStore.java

示例11: isDeviceLocked

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public boolean isDeviceLocked(String deviceId){
	Device device = getDeviceById(deviceId);
	if (device == null) {
		device = getMetaDeviceById(deviceId);
		if (device == null) { 
			logger.error("Device not present with id " + deviceId);
			throw new NotFoundException("device", deviceId);
		}
	}
	return device.getAdminState().equals(AdminState.LOCKED) || device.getOperatingState().equals(OperatingState.DISABLED);
}

开发者ID:edgexfoundry，项目名称:device-modbus，代码行数:12，代码来源:DeviceStore.java

示例12: updateLastConnected

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
private void updateLastConnected(String deviceName) {
	Device device = devices.getDevice(deviceName);
	if (device != null) {
		deviceClient.updateLastConnected(device.getId(), Calendar.getInstance().getTimeInMillis());
		if (device.getOperatingState().equals(OperatingState.DISABLED))
			devices.setDeviceByIdOpState(device.getId(), OperatingState.ENABLED);
	} else {
		logger.debug("No device found for device name: " + deviceName + ". Could not update last connected time");
	}
}

开发者ID:edgexfoundry，项目名称:device-modbus，代码行数:11，代码来源:CoreDataMessageHandler.java

示例13: sendCoreData

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public List<ResponseObject> sendCoreData(String deviceName, List<Reading> readings, Map<String, ModbusObject> objects) {
	try{
	
		if (objects != null) {

			List<ResponseObject> resps = new ArrayList<>();
			logger.debug("readings: " + readings);
			for (Reading reading: readings) {										
				ResponseObject resp = new ResponseObject(reading.getName(), reading.getValue());						
				resps.add(resp);
			}
			boolean success = sendEvent(buildEvent(deviceName, readings), 0);
			if (success) {
				updateLastConnected(deviceName);
				return resps;
			}
			else {
				if (devices.getDevice(deviceName).getOperatingState().equals(OperatingState.ENABLED))
					devices.setDeviceOpState(deviceName, OperatingState.DISABLED);
				logger.error("Could not send event to core data for " + deviceName + ".  Check core data service");
			}
		} else
			logger.debug("No profile object found for the device " + deviceName + ".  MQTT message ignored.");
	}catch(Exception e){
		logger.error("Cannot push the readings to Coredata " + e.getMessage());
		e.printStackTrace();
	}
	return new ArrayList<ResponseObject>();
}

开发者ID:edgexfoundry，项目名称:device-modbus，代码行数:30，代码来源:CoreDataMessageHandler.java

示例14: createDevice

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
private Device createDevice(Map<String, String> device, ProvisionWatcher watcher) {
	Device newDevice = new Device();
	newDevice.setProfile(watcher.getProfile());
	newDevice.setService(watcher.getService());
	String name = device.get("name") + " " + device.get("address");
	newDevice.setName(name);
	Addressable addressable = createAddressable(device, name, watcher.getService().getAddressable());
	newDevice.setAddressable(addressable);
	newDevice.setLabels(watcher.getService().getLabels());
	newDevice.setAdminState(AdminState.UNLOCKED);
	newDevice.setOperatingState(OperatingState.ENABLED);
	return newDevice;
}

开发者ID:edgexfoundry，项目名称:device-modbus，代码行数:14，代码来源:DeviceDiscovery.java

示例15: createDevice

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
private Device createDevice(Map<String, String> device, ProvisionWatcher watcher) {
  Device newDevice = new Device();
  newDevice.setProfile(watcher.getProfile());
  newDevice.setService(watcher.getService());
  String name = device.get("name") + " " + device.get("address");
  newDevice.setName(name);
  Addressable addressable =
      createAddressable(device, name, watcher.getService().getAddressable());
  newDevice.setAddressable(addressable);
  newDevice.setLabels(watcher.getService().getLabels());
  newDevice.setAdminState(AdminState.unlocked);
  newDevice.setOperatingState(OperatingState.enabled);
  return newDevice;
}

开发者ID:mgjeong，项目名称:device-opcua-java，代码行数:15，代码来源:DeviceDiscovery.java

示例16: remove

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public boolean remove(Device device) {
  logger.debug("Removing managed device:  " + device.getName());
  if (devices.containsKey(device.getName())) {
    devices.remove(device.getName());
    OPCUA.disconnectDevice(device);
    deviceClient.updateOpState(device.getId(), OperatingState.disabled.name());
    profiles.removeDevice(device);
  }
  return true;
}

开发者ID:mgjeong，项目名称:device-opcua-java，代码行数:11，代码来源:DeviceStore.java

示例17: initialize

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public Map<String, Device> initialize(String id) {
  List<Device> metaDevices = deviceClient.devicesForService(id);
  devices = new HashMap<>();
  watchers.initialize(id);
  OPCUA.initialize();
  for (Device device : metaDevices) {
    deviceClient.updateOpState(device.getId(), OperatingState.disabled.name());
    add(device);
  }

  logger.info("Device service has " + devices.size() + " devices.");
  return getDevices();
}

开发者ID:mgjeong，项目名称:device-opcua-java，代码行数:14，代码来源:DeviceStore.java

示例18: isDeviceLocked

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public boolean isDeviceLocked(String deviceId) {
  Device device = getDeviceById(deviceId);
  if (device == null) {
    device = getMetaDeviceById(deviceId);
    if (device == null) {
      logger.error("Device not present with id " + deviceId);
      throw new NotFoundException("device", deviceId);
    }
  }

  return device.getAdminState().equals(AdminState.locked)
      || device.getOperatingState().equals(OperatingState.disabled);
}

开发者ID:mgjeong，项目名称:device-opcua-java，代码行数:14，代码来源:DeviceStore.java

示例19: updateLastConnected

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
private void updateLastConnected(String deviceName) {
  Device device = devices.getDevice(deviceName);
  if (device != null) {
    deviceClient.updateLastConnected(device.getId(), Calendar.getInstance().getTimeInMillis());
    if (device.getOperatingState().equals(OperatingState.disabled))
      devices.setDeviceByIdOpState(device.getId(), OperatingState.enabled);
  } else {
    logger.debug("No device found for device name: " + deviceName
        + ". Could not update last connected time");
  }
}

开发者ID:mgjeong，项目名称:device-opcua-java，代码行数:12，代码来源:CoreDataMessageHandler.java

示例20: sendCoreData

import org.edgexfoundry.domain.meta.OperatingState; //导入依赖的package包/类
public List<EdgeElement> sendCoreData(String deviceName, List<Reading> readings,
    Map<String, OPCUAObject> objects) {
  try {
    if (objects != null) {
      List<EdgeElement> elementList = new ArrayList<EdgeElement>();
      logger.debug("readings: " + readings);
      for (Reading reading : readings) {
        elementList.add(EdgeJsonFormatter.decodeJsonStringToEdgeElement(reading.getValue()));
      }
      boolean success = sendEvent(buildEvent(deviceName, readings), 0);
      if (success) {
        updateLastConnected(deviceName);
        logger.debug("elementList: " + elementList);
        return elementList;
      } else {
        if (devices.getDevice(deviceName).getOperatingState().equals(OperatingState.enabled))
          devices.setDeviceOpState(deviceName, OperatingState.disabled);
        logger.error(
            "Could not send event to core data for " + deviceName + ".  Check core data service");
      }
    } else
      logger.debug(
          "No profile object found for the device " + deviceName + ".  MQTT message ignored.");
  } catch (Exception e) {
    logger.error("Cannot push the readings to Coredata " + e.getMessage());
    e.printStackTrace();
  }
  return new ArrayList<EdgeElement>();
}

开发者ID:mgjeong，项目名称:device-opcua-java，代码行数:30，代码来源:CoreDataMessageHandler.java

注：本文中的org.edgexfoundry.domain.meta.OperatingState类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java ResourcesFacet类代码示例发布时间：2022-05-23

Java Tools类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18792|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9856|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8278|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8637|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8561|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9563|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8555|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7953|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8557|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7477|2022-11-06

客服电话

电子邮件

Java OperatingState类代码示例

示例1: provision

示例2: provision

示例3: add

示例4: add

示例5: provision

示例6: add

示例7: provision

示例8: remove

示例9: add

示例10: initialize

示例11: isDeviceLocked

示例12: updateLastConnected

示例13: sendCoreData

示例14: createDevice

示例15: createDevice

示例16: remove

示例17: initialize

示例18: isDeviceLocked

示例19: updateLastConnected

示例20: sendCoreData

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

CVE-2022-2486

medfreeman/markdown-it-toc-and-anchor: m

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053