• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java Protocol类代码示例

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

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



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

示例1: setup

import org.edgexfoundry.domain.meta.Protocol; //导入依赖的package包/类
@Before
public void setup() {
	activator = new IotCoreMQTTOutboundServiceActivator();
	string = ExportStringData.newTestInstance();
	string.setEventString(TEST_STRING);
	string.setEventId(TEST_ID);
	
	Addressable addressable = new Addressable(TEST_STRING, Protocol.OTHER, TEST_ADDRESS, TEST_PORT, TEST_PUBLISHER,
		      TEST_USER, TEST_PASSWORD, TEST_TOPIC);
	ExportRegistration er = new ExportRegistration();
	er.setAddressable(addressable);
	string.setRegistration(er, TEST_ID);
	
	message = MessageBuilder.withPayload(string).build();
    try {
		FieldUtils.writeField(activator, "privateKeyFile", "rsa_private_pkcs8", true);
	    FieldUtils.writeField(activator, "algorithm", "RS256", true);
	} catch (IllegalAccessException e) {
		e.printStackTrace();
	}
}
 
开发者ID:edgexfoundry,项目名称:export-distro,代码行数:22,代码来源:IotCoreMQTTOutboundServiceActivatorTest.java


示例2: getModbusConnection

import org.edgexfoundry.domain.meta.Protocol; //导入依赖的package包/类
public Object getModbusConnection(Addressable addressable){
	Object connection = null;
	synchronized(connections) {
		if(connections.containsKey(addressable.getAddress())){
			connection = connections.get(addressable.getAddress());
		}
		else{
			if(addressable.getProtocol() == Protocol.HTTP){
				logger.info("creating TCP connection");
				connection = createTCPConnection(addressable);
			}
			else /*if(addressable.getProtocol() == Protocol.OTHER)*/{
				connection = createSerialConnection(addressable);
			}
			connections.put(addressable.getAddress(), connection);
		}
	}
	return connection;
}
 
开发者ID:edgexfoundry,项目名称:device-modbus,代码行数:20,代码来源:ModbusConnection.java


示例3: getEndpointUrifromAddressable

import org.edgexfoundry.domain.meta.Protocol; //导入依赖的package包/类
/**
 * Get endpoint URI from Addressable object<br>
 * Use {@link org.edgexfoundry.domain.meta.Addressable} to generate endpoint URI
 * 
 * @param addressable Device's addressable
 * @return Endpoint URI
 */
public String getEndpointUrifromAddressable(Addressable addressable) {
  String endpointUri = "";

  if (null == addressable) {
    return null;
  }
  if (addressable.getProtocol() == Protocol.TCP) {
    endpointUri += String.format("%s", "opc.tcp://");
  } else {
    endpointUri += String.format("%s", "http://");
  }

  endpointUri += String.format("%s:%d/%s", addressable.getAddress(), addressable.getPort(),
      addressable.getPath());
  return endpointUri;
}
 
开发者ID:mgjeong,项目名称:device-opcua-java,代码行数:24,代码来源:OPCUAMessageHandler.java


示例4: setup

import org.edgexfoundry.domain.meta.Protocol; //导入依赖的package包/类
@Before
public void setup() throws Exception {
	Addressable addressable = new Addressable(TEST_STRING, Protocol.OTHER, TEST_ADDRESS, TEST_PORT, TEST_PUBLISHER,
		      TEST_USER, TEST_PASSWORD, TEST_TOPIC);
	boolean thrown = false;
	try {
		sender = new IotCoreMQTTSender(addressable, KEYFILE, ALGORITHM, QOS, KEEPALIVE);
	} catch (Exception e) {
		thrown = true;
		assertTrue("Must fail without proper key file", thrown);
	}
}
 
开发者ID:edgexfoundry,项目名称:export-distro,代码行数:13,代码来源:IoTCoreMQTTSenderTest.java


示例5: getExportRegistration

import org.edgexfoundry.domain.meta.Protocol; //导入依赖的package包/类
private ExportRegistration getExportRegistration() {
  ExportRegistration registration = new ExportRegistration();
  registration.setName(clientName);
  registration.setFormat(ExportFormat.SERIALIZED);
  registration.setDestination(ExportDestination.ZMQ_TOPIC);
  registration.setEnable(true);
  Addressable addressable =
      new Addressable("EdgeXRulesEngineAddressable", Protocol.ZMQ, "", "", 0);
  registration.setAddressable(addressable);
  return registration;
}
 
开发者ID:edgexfoundry,项目名称:support-rulesengine,代码行数:12,代码来源:ExportClientImpl.java


示例6: getEndpointUrifromAddressable

import org.edgexfoundry.domain.meta.Protocol; //导入依赖的package包/类
public String getEndpointUrifromAddressable(Addressable addressable) {
  String endpointUri = "";
  if (addressable.getProtocol() == Protocol.TCP) {
    endpointUri += String.format("%s", "opc.tcp://");
  } else {
    endpointUri += String.format("%s", "http://");
  }

  endpointUri += String.format("%s:%d/%s", addressable.getAddress(), addressable.getPort(),
      addressable.getPath());
  return endpointUri;
}
 
开发者ID:mgjeong,项目名称:device-opcua-java,代码行数:13,代码来源:OPCUADriver.java


示例7: generate

import org.edgexfoundry.domain.meta.Protocol; //导入依赖的package包/类
/**
 * generate Addressable <br>
 * Use
 * {@link org.edgexfoundry.domain.meta.Addressable#Addressable(String, Protocol, String, String, int)}
 * to generate Addressable
 * 
 * @param name Name which matched with Device
 * @return created Addressable
 */
public static Addressable generate(String name) {
  if (name == null || name.isEmpty()) {
    return null;
  }
  Addressable addressable =
      new Addressable(name, Protocol.TCP, OPCUADefaultMetaData.ADDRESS.getValue(),
          OPCUADefaultMetaData.PATH.getValue(), OPCUADefaultMetaData.ADDRESSABLE_PORT);
  return addressable;
}
 
开发者ID:mgjeong,项目名称:device-opcua-java,代码行数:19,代码来源:AddressableGenerator.java


示例8: getAddressable

import org.edgexfoundry.domain.meta.Protocol; //导入依赖的package包/类
private Addressable getAddressable() {
  try {
    return addrClient.addressableForName(mqttAddressableName);
  } catch (javax.ws.rs.NotFoundException notFound) {
    mqttRequestBrokerProtocol = Protocol.valueOf(mqttRequestBrokerProtocolString);
    Addressable addressable = new Addressable(mqttAddressableName, mqttRequestBrokerProtocol,
        mqttRequestBroker, mqttRequestBrokerPort, mqttRequestClientId, mqttRequestUser,
        mqttRequestPassword, mqttRequestTopic);
    addrClient.add(addressable);
    return addressable;
  }
}
 
开发者ID:edgexfoundry,项目名称:device-mqtt,代码行数:13,代码来源:MqttDriver.java



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


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java PositionObserver类代码示例发布时间:2022-05-23
下一篇:
Java DefaultProcessor类代码示例发布时间:2022-05-23
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap