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

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

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

ResponseEvent.getResponse介绍

[英]Gets the response PDU.
[中]获取PDU的响应。

代码示例

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

if("GET".equals(context.getProperty(SNMP_STRATEGY).getValue())) {
  final ResponseEvent response = this.targetResource.get();
  if (response.getResponse() != null){
    FlowFile flowFile = processSession.create();
    PDU pdu = response.getResponse();
    flowFile = SNMPUtils.updateFlowFileAttributesWithPduProperties(pdu, flowFile, processSession);
    flowFile = SNMPUtils.addAttribute(SNMPUtils.SNMP_PROP_PREFIX + "textualOid",

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

try {
  ResponseEvent response = this.targetResource.set(pdu);
  if(response.getResponse() == null) {
    processSession.transfer(processSession.penalize(flowFile), REL_FAILURE);
    this.getLogger().error("Set request timed out or parameters are incorrect.");
    context.yield();
  } else if(response.getResponse().getErrorStatus() == PDU.noError) {
    flowFile = SNMPUtils.updateFlowFileAttributesWithPduProperties(pdu, flowFile, processSession);
    processSession.transfer(flowFile, REL_SUCCESS);
    processSession.getProvenanceReporter().send(flowFile, this.snmpTarget.getAddress().toString());
  } else {
    final String error = response.getResponse().getErrorStatusText();
    flowFile = SNMPUtils.addAttribute(SNMPUtils.SNMP_PROP_PREFIX + "error", error, flowFile, processSession);
    processSession.transfer(processSession.penalize(flowFile), REL_FAILURE);

代码示例来源:origin: stackoverflow.com

IResponseListener listener = new IResponseListener() {
  public void response(ResponseEvent event) {
    float f = event.getResponse();
  } 
};

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

private static SnmpValue[] convertResponseToValues(ResponseEvent responseEvent) {
  SnmpValue[] retvalues = new Snmp4JValue[responseEvent.getResponse().getVariableBindings().size()];
  
  for (int i = 0; i < retvalues.length; i++) {
    retvalues[i] = new Snmp4JValue(responseEvent.getResponse().get(i).getVariable());
  }
  
  return retvalues;
}

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

private static SnmpValue[] convertResponseToValues(ResponseEvent responseEvent) {
  SnmpValue[] retvalues = new Snmp4JValue[responseEvent.getResponse().getVariableBindings().size()];
  
  for (int i = 0; i < retvalues.length; i++) {
    retvalues[i] = new Snmp4JValue(responseEvent.getResponse().get(i).getVariable());
  }
  
  return retvalues;
}

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

private SnmpValue[] convertResponseToValues(ResponseEvent responseEvent) {
  SnmpValue[] retvalues = new Snmp4JValue[responseEvent.getResponse().getVariableBindings().size()];
  
  for (int i = 0; i < retvalues.length; i++) {
    retvalues[i] = new Snmp4JValue(responseEvent.getResponse().get(i).getVariable());
  }
  
  return retvalues;
}

代码示例来源:origin: org.openhab.binding/org.openhab.binding.snmp

/**
 * Called when a response from a GET is received
 *
 * @see org.snmp4j.event.ResponseListener#onResponse(org.snmp4j.event.ResponseEvent )
 */
@Override
public void onResponse(ResponseEvent event) {
  dispatchPdu(event.getPeerAddress(), 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: stackoverflow.com

private void processRegisterResponse(ResponseEvent responseReceivedEvent) throws TransactionUnavailableException, ParseException, InvalidArgumentException, SipException, NoSuchAlgorithmException {
  Response response = (Response) responseReceivedEvent.getResponse();

  if(response.getStatusCode() == Response.UNAUTHORIZED) {
    sendRegister(response);
  }
  else if (response.getStatusCode() == Response.OK) {
    contactHeader=(ContactHeader)response.getHeader(ContactHeader.NAME);
    sendInvite();
  }               
}

代码示例来源:origin: griddynamics/jagger

public int getAsInt(OID oid) throws IOException {
  ResponseEvent event = get(Arrays.asList(oid));
  return event.getResponse().get(0).getVariable().toInt();
}

代码示例来源:origin: griddynamics/jagger

public long getAsLong(OID oid) throws IOException {
  ResponseEvent event = get(Arrays.asList(oid));
  return event.getResponse().get(0).getVariable().toLong();
}

代码示例来源:origin: griddynamics/jagger

public String getAsString(OID oid) throws IOException {
  ResponseEvent event = get(Arrays.asList(oid));
  return event.getResponse().get(0).getVariable().toString();
}

代码示例来源:origin: jrask/snmp-blog

public static String extractSingleString(ResponseEvent event) {
    return event.getResponse().get(0).getVariable().toString();
  }
}

代码示例来源:origin: jrask/snmp-blog

public String getAsString(OID oid) throws IOException {
  ResponseEvent event = get(new OID[]{oid});
  return event.getResponse().get(0).getVariable().toString();
}

代码示例来源:origin: com.rogueai/snmp2bean

private <T> T get(Class<T> scalarClass, PDU requestPDU) throws IOException, SnmpException, SnmpAnnotationException {
  try {
    checkRequestError(requestPDU);
    ResponseEvent event = getSnmp().get(requestPDU, snmpSession.getReadTarget());
    checkEventError(event);
    PDU responsePDU = event.getResponse();
    checkResponseError(responsePDU);
    T mibObj = scalarClass.newInstance();
    populateProperties(mibObj, responsePDU);
    return mibObj;
  } catch (InstantiationException | IllegalAccessException e) {
    throw new SnmpAnnotationException(e);
  }
}

代码示例来源:origin: com.rogueai/snmp2bean

private <T> T getEntryByIndex(T entry, PDU requestPDU) throws IOException, SnmpException, InstantiationException, IllegalAccessException {
  checkRequestError(requestPDU);
  ResponseEvent event = getSnmp().get(requestPDU, snmpSession.getReadTarget());
  checkEventError(event);
  PDU responsePDU = event.getResponse();
  checkResponseError(responsePDU);
  populateProperties(entry, responsePDU);
  return entry;
}

代码示例来源:origin: com.rogueai/snmp2bean

public void create(Object entry) throws IOException, SnmpException, SnmpAnnotationException {
  try {
    PDU requestPDU = buildCreatePDU(entry);
    checkRequestError(requestPDU);
    ResponseEvent event = getSnmp().set(requestPDU, snmpSession.getWriteTarget());
    checkEventError(event);
    PDU responsePDU = event.getResponse();
    checkResponseError(responsePDU);
  } catch (IllegalArgumentException | IllegalAccessException | SecurityException | NoSuchMethodException | InstantiationException | InvocationTargetException e) {
    throw new SnmpAnnotationException(e);
  }
}

代码示例来源:origin: com.rogueai/snmp2bean

public void delete(Object entry) throws IOException, SnmpException, SnmpAnnotationException {
  try {
    PDU requestPDU = buildDeletPDU(entry);
    checkRequestError(requestPDU);
    ResponseEvent event = getSnmp().set(requestPDU, snmpSession.getWriteTarget());
    checkEventError(event);
    PDU responsePDU = event.getResponse();
    checkResponseError(responsePDU);
  } catch (IllegalArgumentException | IllegalAccessException e) {
    throw new SnmpAnnotationException(e);
  }
}

代码示例来源:origin: com.rogueai/snmp2bean

public void set(Object entry) throws IOException, SnmpException, SnmpAnnotationException {
  try {
    PDU requestPDU = buildSetPDU(entry);
    checkRequestError(requestPDU);
    ResponseEvent event = getSnmp().set(requestPDU, snmpSession.getWriteTarget());
    checkEventError(event);
    PDU responsePDU = event.getResponse();
    checkResponseError(responsePDU);
  } catch (InstantiationException | IllegalAccessException | IllegalArgumentException | SecurityException | NoSuchMethodException | InvocationTargetException e) {
    throw new SnmpAnnotationException(e);
  }
}

代码示例来源:origin: net.itransformers.snmp2xml4j/snmptoolkit

private VariableBinding getSingleVariable(OID oid) throws IOException {
  PDU pdu = this.pduFactory.createPDU(getTarget());
  pdu.setType(PDU.GETNEXT);
  pdu.add(new VariableBinding(oid));
  ResponseEvent responseEvent = snmp.send(pdu, getTarget());
  PDU responsePDU = null;
  if (responseEvent != null) responsePDU = responseEvent.getResponse();
  VariableBinding vb = null;
  if (responsePDU != null) vb = responsePDU.get(0);
  return vb;
}

相关文章