Java Protocol类代码示例

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

原作者: [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；未经允许，请勿转载。