本文整理了Java中org.eclipse.californium.core.coap.Response.isCanceled
方法的一些代码示例,展示了Response.isCanceled
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Response.isCanceled
方法的具体详情如下:
包路径:org.eclipse.californium.core.coap.Response
类名称:Response
方法名:isCanceled
暂无
代码示例来源:origin: org.eclipse.californium/californium-core
@Override
public void sendResponse(Exchange exchange, Response response) {
if (response.getDestination() == null)
throw new NullPointerException("Response has no destination address");
if (response.getDestinationPort() == 0)
throw new NullPointerException("Response has no destination port");
matcher.sendResponse(exchange, response);
/*
* Logging here causes significant performance loss.
* If necessary, add an interceptor that logs the messages,
* e.g., the MessageTracer.
*/
for (MessageInterceptor interceptor:interceptors)
interceptor.sendResponse(response);
// MessageInterceptor might have canceled
if (response.isCanceled()) {
if (null != exchange) {
exchange.setComplete();
}
}
else {
connector.send(serializer.serialize(response));
}
}
代码示例来源:origin: eclipse/californium
private void receiveResponse(final Response response, final RawData raw) {
/*
* Logging here causes significant performance loss.
* If necessary, add an interceptor that logs the messages,
* e.g., the MessageTracer.
*/
for (MessageInterceptor interceptor:interceptors) {
interceptor.receiveResponse(response);
}
// MessageInterceptor might have canceled
if (!response.isCanceled()) {
Exchange exchange = matcher.receiveResponse(response, raw.getCorrelationContext());
if (exchange != null) {
exchange.setEndpoint(CoapEndpoint.this);
response.setRTT(System.currentTimeMillis() - exchange.getTimestamp());
coapstack.receiveResponse(exchange, response);
} else if (response.getType() != Type.ACK) {
LOGGER.log(Level.FINE, "Rejecting unmatchable response from {0}", raw.getInetSocketAddress());
reject(response);
}
}
}
代码示例来源:origin: eclipse/californium
@Override
public void sendResponse(Exchange exchange, Response response) {
assertMessageHasDestinationAddress(response);
matcher.sendResponse(exchange, response);
/*
* Logging here causes significant performance loss.
* If necessary, add an interceptor that logs the messages,
* e.g., the MessageTracer.
*/
for (MessageInterceptor interceptor:interceptors) {
interceptor.sendResponse(response);
}
// MessageInterceptor might have canceled
if (response.isCanceled()) {
if (null != exchange) {
exchange.setComplete();
}
}
else {
connector.send(serializer.serializeResponse(response));
}
}
代码示例来源:origin: eclipse/californium
protected final void appendResponseDetails(final Response response) {
if (response.isCanceled()) {
buffer.append("CANCELED ");
}
buffer.append(response.getType()).append(" [MID=").append(response.getMID())
.append(", T=").append(response.getTokenString()).append("], ")
.append(response.getCode());
appendBlockOption(1, response.getOptions().getBlock1());
appendBlockOption(2, response.getOptions().getBlock2());
appendObserveOption(response.getOptions());
appendSize1(response.getOptions());
appendSize2(response.getOptions());
appendEtags(response.getOptions());
}
代码示例来源:origin: org.eclipse.californium/californium-core
if (!response.isCanceled()) {
Exchange exchange = matcher.receiveResponse(response);
if (exchange != null) {
内容来源于网络,如有侵权,请联系作者删除!