本文整理了Java中org.eclipse.californium.core.coap.Request.setDestinationContext
方法的一些代码示例,展示了Request.setDestinationContext
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Request.setDestinationContext
方法的具体详情如下:
包路径:org.eclipse.californium.core.coap.Request
类名称:Request
方法名:setDestinationContext
暂无
代码示例来源:origin: eclipse/leshan
private void buildRequestSettings() {
coapRequest.setDestinationContext(new AddressEndpointContext(serverAddress));
}
}
代码示例来源:origin: eclipse/leshan
@Override
public void visit(BootstrapDeleteRequest request) {
coapRequest = Request.newDelete();
coapRequest.setConfirmable(true);
EndpointContext context = EndpointContextUtil.extractContext(destination);
coapRequest.setDestinationContext(context);
setTarget(coapRequest, request.getPath());
}
代码示例来源:origin: eclipse/leshan
public static Observation deserialize(byte[] data) {
JsonObject v = (JsonObject) Json.parse(new String(data));
EndpointContext endpointContext = EndpointContextSerDes.deserialize(v.get("peer").asObject());
byte[] req = Hex.decodeHex(v.getString("request", null).toCharArray());
RawData rawData = RawData.outbound(req, endpointContext, null, false);
Request request = (Request) parser.parseMessage(rawData);
request.setDestinationContext(endpointContext);
JsonValue ctxValue = v.get("context");
if (ctxValue != null) {
Map<String, String> context = new HashMap<>();
JsonObject ctxObject = (JsonObject) ctxValue;
for (String name : ctxObject.names()) {
context.put(name, ctxObject.getString(name, null));
}
request.setUserContext(context);
}
return new Observation(request, endpointContext);
}
代码示例来源:origin: org.eclipse.leshan/leshan-server-cluster
public static Observation deserialize(byte[] data) {
JsonObject v = (JsonObject) Json.parse(new String(data));
EndpointContext endpointContext = EndpointContextSerDes.deserialize(v.get("peer").asObject());
byte[] req = Hex.decodeHex(v.getString("request", null).toCharArray());
RawData rawData = RawData.outbound(req, endpointContext, null, false);
Request request = (Request) parser.parseMessage(rawData);
request.setDestinationContext(endpointContext);
JsonValue ctxValue = v.get("context");
if (ctxValue != null) {
Map<String, String> context = new HashMap<>();
JsonObject ctxObject = (JsonObject) ctxValue;
for (String name : ctxObject.names()) {
context.put(name, ctxObject.getString(name, null));
}
request.setUserContext(context);
}
return new Observation(request, endpointContext);
}
代码示例来源:origin: eclipse/leshan
@Override
public void visit(BootstrapFinishRequest request) {
coapRequest = Request.newPost();
coapRequest.setConfirmable(true);
EndpointContext context = EndpointContextUtil.extractContext(destination);
coapRequest.setDestinationContext(context);
// root path
if (rootPath != null) {
for (String rootPathPart : rootPath.split("/")) {
if (!StringUtils.isEmpty(rootPathPart)) {
coapRequest.getOptions().addUriPath(rootPathPart);
}
}
}
coapRequest.getOptions().addUriPath("bs");
}
代码示例来源:origin: eclipse/leshan
@Override
public void sendCoapRequest(final Registration destination, final Request coapRequest, long timeout,
CoapResponseCallback responseCallback, ErrorCallback errorCallback) {
// Define destination
EndpointContext context = EndpointContextUtil.extractContext(destination.getIdentity());
coapRequest.setDestinationContext(context);
// Add CoAP request callback
MessageObserver obs = new CoapAsyncRequestObserver(coapRequest, responseCallback, errorCallback, timeout);
coapRequest.addMessageObserver(obs);
// Store pending request to cancel it on de-registration
addPendingRequest(destination.getId(), coapRequest);
// Send CoAP request asynchronously
Endpoint endpoint = getEndpointForClient(destination);
endpoint.sendRequest(coapRequest);
}
代码示例来源:origin: eclipse/leshan
private final void setTarget(Request coapRequest, LwM2mPath path) {
EndpointContext context = EndpointContextUtil.extractContext(destination);
coapRequest.setDestinationContext(context);
// root path
if (rootPath != null) {
for (String rootPathPart : rootPath.split("/")) {
if (!StringUtils.isEmpty(rootPathPart)) {
coapRequest.getOptions().addUriPath(rootPathPart);
}
}
}
// objectId
if (path.getObjectId() != null) {
coapRequest.getOptions().addUriPath(Integer.toString(path.getObjectId()));
}
// objectInstanceId
if (path.getObjectInstanceId() == null) {
if (path.getResourceId() != null) {
coapRequest.getOptions().addUriPath("0"); // default instanceId
}
} else {
coapRequest.getOptions().addUriPath(Integer.toString(path.getObjectInstanceId()));
}
// resourceId
if (path.getResourceId() != null) {
coapRequest.getOptions().addUriPath(Integer.toString(path.getResourceId()));
}
}
代码示例来源:origin: eclipse/leshan
@Override
public Response sendCoapRequest(final Registration destination, final Request coapRequest, long timeout)
throws InterruptedException {
// Define destination
EndpointContext context = EndpointContextUtil.extractContext(destination.getIdentity());
coapRequest.setDestinationContext(context);
// Send CoAP request synchronously
CoapSyncRequestObserver syncMessageObserver = new CoapSyncRequestObserver(coapRequest, timeout);
coapRequest.addMessageObserver(syncMessageObserver);
// Store pending request to cancel it on de-registration
addPendingRequest(destination.getId(), coapRequest);
// Send CoAP request asynchronously
Endpoint endpoint = getEndpointForClient(destination);
endpoint.sendRequest(coapRequest);
// Wait for response, then return it
return syncMessageObserver.waitForCoapResponse();
}
内容来源于网络,如有侵权,请联系作者删除!