org.snmp4j.event.ResponseEvent.getRequest()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(11.0k)|赞(0)|评价(0)|浏览(43)

本文整理了Java中org.snmp4j.event.ResponseEvent.getRequest方法的一些代码示例，展示了ResponseEvent.getRequest的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ResponseEvent.getRequest方法的具体详情如下：
包路径：org.snmp4j.event.ResponseEvent
类名称：ResponseEvent
方法名：getRequest

ResponseEvent.getRequest介绍

[英]Gets the request PDU.
[中]获取请求PDU。

代码示例

代码示例来源：origin: apache/nifi

flowFile = SNMPUtils.addAttribute(SNMPUtils.SNMP_PROP_PREFIX + "error", error, flowFile, processSession);
processSession.transfer(processSession.penalize(flowFile), REL_FAILURE);
this.getLogger().error("Failed while executing SNMP Set [{}] via " + this.targetResource + ". Error = {}", new Object[]{response.getRequest().getVariableBindings(), error});

代码示例来源：origin: org.apache.servicemix/servicemix-snmp

public void onResponse(ResponseEvent event) {
  // Always cancel async request when response has been received
  // otherwise a memory leak is created! Not canceling a request
  // immediately can be useful when sending a request to a broadcast
  // address.
  ((Snmp)event.getSource()).cancel(event.getRequest(), this);
  // check for valid response
  if (event.getRequest() == null || event.getResponse() == null) {
    // ignore null requests/responses
    logger.debug("Received invalid snmp event. Request: {} / Response: {}", event.getRequest(),
         event.getResponse());
    return;
  }
  // now prepare the message and send it
  sendSnmpDataMessage(event.getRequest(), event.getResponse());
}

代码示例来源：origin: org.apache.camel/camel-snmp

public void onResponse(ResponseEvent event) {
  // Always cancel async request when response has been received
  // otherwise a memory leak is created! Not canceling a request
  // immediately can be useful when sending a request to a broadcast address.
  ((Snmp)event.getSource()).cancel(event.getRequest(), this);
  // check for valid response
  if (event.getRequest() == null || event.getResponse() == null) {
    // ignore null requests/responses
    LOG.debug("Received invalid SNMP event. Request: " + event.getRequest() + " / Response: " + event.getResponse());
    return;
  }
  
  PDU pdu = event.getResponse();
  processPDU(pdu);
}

代码示例来源：origin: OpenNMS/opennms

/**
 * TODO: Merge this logic with {@link Snmp4JWalker.Snmp4JResponseListener} #processResponse(PDU response)
 */
private static SnmpValue[] processResponse(Snmp4JAgentConfig agentConfig, ResponseEvent responseEvent) throws IOException {
  SnmpValue[] retvalues = { null };
  if (responseEvent.getResponse() == null) {
    LOG.warn("processResponse: Timeout.  Agent: {}, requestID={}", agentConfig, responseEvent.getRequest().getRequestID());
  } else if (responseEvent.getError() != null) {
    LOG.warn("processResponse: Error during get operation.  Error: {}, requestID={}", responseEvent.getError().getLocalizedMessage(), responseEvent.getError(), responseEvent.getRequest().getRequestID());
  } else if (responseEvent.getResponse().getType() == PDU.REPORT) {
    LOG.warn("processResponse: Error during get operation.  Report returned with varbinds: {}, requestID={}", responseEvent.getResponse().getVariableBindings(), responseEvent.getRequest().getRequestID());
  } else if (responseEvent.getResponse().getVariableBindings().size() < 1) {
    LOG.warn("processResponse: Received PDU with 0 varbinds. Agent: {}, requestID={}", agentConfig, responseEvent.getRequest().getRequestID());
  } else if (responseEvent.getResponse().get(0).getSyntax() == SMIConstants.SYNTAX_NULL) {
    LOG.info("processResponse: Null value returned in varbind: {}. Agent: {}, requestID={}", responseEvent.getResponse().get(0), agentConfig, responseEvent.getRequest().getRequestID());
  } else {
    retvalues = convertResponseToValues(responseEvent);
    LOG.debug("processResponse: SNMP operation successful, value: {}", (Object)retvalues);
  }
  return retvalues;
}

代码示例来源：origin: org.opennms.core.snmp/org.opennms.core.snmp.implementations.snmp4j

/**
 * TODO: Merge this logic with {@link Snmp4JWalker.Snmp4JResponseListener} #processResponse(PDU response)
 */
private static SnmpValue[] processResponse(Snmp4JAgentConfig agentConfig, ResponseEvent responseEvent) throws IOException {
  SnmpValue[] retvalues = { null };
  if (responseEvent.getResponse() == null) {
    LOG.warn("processResponse: Timeout.  Agent: {}, requestID={}", agentConfig, responseEvent.getRequest().getRequestID());
  } else if (responseEvent.getError() != null) {
    LOG.warn("processResponse: Error during get operation.  Error: {}, requestID={}", responseEvent.getError().getLocalizedMessage(), responseEvent.getError(), responseEvent.getRequest().getRequestID());
  } else if (responseEvent.getResponse().getType() == PDU.REPORT) {
    LOG.warn("processResponse: Error during get operation.  Report returned with varbinds: {}, requestID={}", responseEvent.getResponse().getVariableBindings(), responseEvent.getRequest().getRequestID());
  } else if (responseEvent.getResponse().getVariableBindings().size() < 1) {
    LOG.warn("processResponse: Received PDU with 0 varbinds. Agent: {}, requestID={}", agentConfig, responseEvent.getRequest().getRequestID());
  } else if (responseEvent.getResponse().get(0).getSyntax() == SMIConstants.SYNTAX_NULL) {
    LOG.info("processResponse: Null value returned in varbind: {}. Agent: {}, requestID={}", responseEvent.getResponse().get(0), agentConfig, responseEvent.getRequest().getRequestID());
  } else {
    retvalues = convertResponseToValues(responseEvent);
    LOG.debug("processResponse: SNMP operation successful, value: {}", (Object)retvalues);
  }
  return retvalues;
}

代码示例来源：origin: OpenNMS/opennms

@Override
public void onResponse(ResponseEvent responseEvent) {
  // need to cancel the request here otherwise SNMP4J Keeps it around forever... go figure
  m_session.cancel(responseEvent.getRequest(), this);
  // Check to see if we got an interrupted exception
  if (responseEvent.getError() instanceof InterruptedException) {
    LOG.debug("Interruption event.  We have probably tried to close the session due to an error", responseEvent.getError());
  // Check to see if the response is null, indicating a timeout
  } else if (responseEvent.getResponse() == null) {
    handleTimeout(getName()+": snmpTimeoutError for: " + getAddress());
  // Check to see if we got any kind of error
  } else if (responseEvent.getError() != null){
    handleError(getName()+": snmpInternalError: " + responseEvent.getError() + " for: " + getAddress(), responseEvent.getError());
  // If we have a PDU in the response, process it
  } else {
    try {
      processResponse(responseEvent.getResponse());
    } catch (final SnmpException e) {
      handleFatalError(e);
    }
  }
  
}

代码示例来源：origin: org.opennms.core.snmp/org.opennms.core.snmp.implementations.snmp4j

@Override
public void onResponse(ResponseEvent responseEvent) {
  // need to cancel the request here otherwise SNMP4J Keeps it around forever... go figure
  m_session.cancel(responseEvent.getRequest(), this);
  // Check to see if we got an interrupted exception
  if (responseEvent.getError() instanceof InterruptedException) {
    LOG.debug("Interruption event.  We have probably tried to close the session due to an error", responseEvent.getError());
  // Check to see if the response is null, indicating a timeout
  } else if (responseEvent.getResponse() == null) {
    handleTimeout(getName()+": snmpTimeoutError for: " + getAddress());
  // Check to see if we got any kind of error
  } else if (responseEvent.getError() != null){
    handleError(getName()+": snmpInternalError: " + responseEvent.getError() + " for: " + getAddress(), responseEvent.getError());
  // If we have a PDU in the response, process it
  } else {
    try {
      processResponse(responseEvent.getResponse());
    } catch (final SnmpException e) {
      handleFatalError(e);
    }
  }
  
}

代码示例来源：origin: org.kaazing/snmp4j

public void onResponse(ResponseEvent event) {
 session.cancel(event.getRequest(), this);
 if (finished) {
  return;
   boolean anyMatchInChunk = false;
   int startCol = ((Integer) event.getUserObject()).intValue();
   PDU request = event.getRequest();
   PDU response = event.getResponse();
   int cols = request.size();

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.snmp4j

@SuppressWarnings("unchecked")
public void onResponse(ResponseEvent event) {
 session.cancel(event.getRequest(), this);
 if (finished) {
  return;
   ColumnsOfRequest colsOfRequest = (ColumnsOfRequest) event.getUserObject();
   boolean receivedInOrder = removePending(colsOfRequest.getRequestSerial());
   PDU request = event.getRequest();
   PDU response = event.getResponse();
   int cols = request.size();
       OID requested = event.getRequest().get(c).getOid();
       if (id.compareTo(requested) <= 0) {
        if (!row.orderError) {

代码示例来源：origin: org.snmp4j/snmp4j

@SuppressWarnings("unchecked")
public void onResponse(ResponseEvent event) {
  session.cancel(event.getRequest(), this);
  if (finished) {
    return;
      ColumnsOfRequest colsOfRequest = (ColumnsOfRequest) event.getUserObject();
      boolean receivedInOrder = removePending(colsOfRequest.getRequestSerial());
      PDU request = event.getRequest();
      PDU response = event.getResponse();
      int cols = request.size();
              OID requested = event.getRequest().get(c).getOid();
              if (id.compareTo(requested) <= 0) {
                if (!row.orderError) {

代码示例来源：origin: org.opennms.lib.snmp/org.opennms.lib.snmp.snmp4j

public void onResponse(ResponseEvent responseEvent) {
  // need to cancel the request here otherwise SNMP4J Keeps it around forever... go figure
  m_session.cancel(responseEvent.getRequest(), this);
  // Check to see if we got an interrupted exception
  if (responseEvent.getError() instanceof InterruptedException) {
    if (log().isDebugEnabled()) {
      log().debug("Interruption event.  We have probably tried to close the session due to an error: " + responseEvent.getError(), responseEvent.getError());
    }
  // Check to see if the response is null, indicating a timeout
  } else if (responseEvent.getResponse() == null) {
    handleTimeout(getName()+": snmpTimeoutError for: " + getAddress());
  // Check to see if we got any kind of error
  } else if (responseEvent.getError() != null){
    handleError(getName()+": snmpInternalError: " + responseEvent.getError() + " for: " + getAddress(), responseEvent.getError());
  // If we have a PDU in the response, process it
  } else {
    processResponse(responseEvent.getResponse());
  }
  
}

代码示例来源：origin: org.snmp4j/snmp4j

public void onResponse(ResponseEvent event) {
 session.cancel(event.getRequest(), this);
 PDU respPDU = event.getResponse();
 if (respPDU == null) {

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.snmp4j

public void onResponse(ResponseEvent event) {
 session.cancel(event.getRequest(), this);
 PDU respPDU = event.getResponse();
 if (respPDU == null) {

代码示例来源：origin: org.kaazing/snmp4j

public synchronized void onResponse(ResponseEvent event) {
 session.cancel(event.getRequest(), this);
 if (finished) {
  return;
  PDU request = event.getRequest();
  PDU response = event.getResponse();
  int cols = request.size();

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.snmp4j

public synchronized void onResponse(ResponseEvent event) {
 session.cancel(event.getRequest(), this);
 if (finished) {
  return;
  PDU request = event.getRequest();
  PDU response = event.getResponse();
  int cols = request.size();

代码示例来源：origin: org.kaazing/snmp4j

public void onResponse(ResponseEvent event) {
 session.cancel(event.getRequest(), this);
 PDU respPDU = event.getResponse();
 if (respPDU == null) {

代码示例来源：origin: org.snmp4j/snmp4j

public synchronized void onResponse(ResponseEvent event) {
  session.cancel(event.getRequest(), this);
  if (finished) {
    return;
    PDU request = event.getRequest();
    PDU response = event.getResponse();
    int cols = request.size();

代码示例来源：origin: org.apache.nifi/nifi-snmp-processors

flowFile = SNMPUtils.addAttribute(SNMPUtils.SNMP_PROP_PREFIX + "error", error, flowFile, processSession);
processSession.transfer(processSession.penalize(flowFile), REL_FAILURE);
this.getLogger().error("Failed while executing SNMP Set [{}] via " + this.targetResource + ". Error = {}", new Object[]{response.getRequest().getVariableBindings(), error});

内容来源于网络，如有侵权，请联系作者删除！

ResponseEvent

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com