org.opennms.netmgt.xml.event.Event类的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(11.2k)|赞(0)|评价(0)|浏览(132)

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

Event介绍

暂无

代码示例

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

/**
 * <p>Constructor for PendingPollEvent.</p>
 *
 * @param event a {@link org.opennms.netmgt.xml.event.Event} object.
 */
public PendingPollEvent(final Event event) {
  super(Scope.fromUei(event.getUei()));
  m_event = event;
  m_date = m_event.getTime();
  m_expirationTimeInMillis = m_date.getTime() + PENDING_EVENT_TIMEOUT;
}

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

@Override
  public String getValue(String parm, String parsedParm, Event event, EventUtil eventUtil) {
    return String.valueOf(event.getParmCollection().size());
  }
},

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

private static String listEvents(String prefix, Collection<Event> events) {
  final StringBuilder b = new StringBuilder();
  for (final Event event : events) {
    b.append(prefix);
    b.append(event.getUei() + " / " + event.getNodeid() + " / " + event.getInterface() + " / " + event.getService());
    b.append("\n");
  }
  return b.toString();
}

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

Event event = events.get(position);
holder.resname.setText(event.getResturant());
 holder.resadd.setText(event.getAddress());
 holder.restim.setText(event.getTime());
 holder.imageView.setImageResource(event.getImage());

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

@Override
  public String getValue(String parm, String parsedParm, Event event, EventUtil eventUtil) {
    if (event.hasDbid()) {
      return Integer.toString(event.getDbid());
    } else {
      return "eventid-unknown";
    }
  }
},

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

@Override
public String getValue(String parm, String parsedParm, Event event, EventUtil eventUtil) {
  if (event.getNodeid() > 0 && event.getInterface() != null) {
    try {
      return eventUtil.getIfAlias(event.getNodeid(), event.getInterface());
    } catch (SQLException e) {
      // do nothing
      LoggerFactory.getLogger(getClass()).info("ifAlias Unavailable for {}:{}", event.getNodeid(), event.getInterface(), e);
    }
  }
  return event.getInterface();
}

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

Integer eventId = getNextEventId();
if (e.getCreationTime() == null) {
  e.setCreationTime(new Date());
    e.getSource(),
    e.getUei(),
    new Timestamp(e.getCreationTime().getTime()),
    new Timestamp(e.getTime().getTime()),
    Integer.valueOf(OnmsSeverity.get(e.getSeverity()).getId()),
    (e.hasNodeid() ? new Long(e.getNodeid()) : null),
    e.getInterface(),
    getServiceID(e.getService()),
    e.getDistPoller() == null ? "00000000-0000-0000-0000-000000000000" : e.getDistPoller(),
    "Y",
    "Y",
    e.getTticket() == null ? "" : e.getTticket().getContent(),
    Integer.valueOf(e.getTticket() == null ? "0" : e.getTticket().getState()),
    e.getLogmsg() == null? null : e.getLogmsg().getContent()
};
e.setDbid(eventId);
update("insert into events (" +
    "eventId, eventSource, eventUei, eventCreateTime, eventTime, eventSeverity, " +
if (e.getParmCollection() != null || e.getParmCollection().size() > 0) {
  for (final Parm parm : e.getParmCollection()) {
    Object[] parmValues = {
        eventId,

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

@Test
public void testGetEventForStateDefaultUEIS() {
  Threshold threshold = new Threshold();
  threshold.setType(ThresholdType.RELATIVE_CHANGE);
  threshold.setDsName("ds-name");
  threshold.setDsType("node");
  threshold.setValue(99.0);
  threshold.setRearm(95.0);
  threshold.setTrigger(1);
  ThresholdConfigWrapper wrapper=new ThresholdConfigWrapper(threshold);
  ThresholdEvaluatorStateRelativeChange item = new ThresholdEvaluatorStateRelativeChange(wrapper);
  Event event=item.getEventForState(Status.TRIGGERED, new Date(), 100.0, null);
  assertEquals("UEI should be the relativeChangeThresholdTriggerd", EventConstants.RELATIVE_CHANGE_THRESHOLD_EVENT_UEI, event.getUei());
}

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

public void createOutage(MockService svc, Event svcLostEvent) {
  createOutage(svc, svcLostEvent.getDbid(), new Timestamp(svcLostEvent.getTime().getTime()));
}

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

final Integer id = event.getDbid();
body.put("id", Integer.toString(id));
body.put("eventuei", event.getUei());
if (event.getTime() == null) {
  LOG.debug("using local time because no event creation time for event.getTime: {}", event);
  cal.setTime(new Date());
} else {
  cal.setTime(event.getTime());
body.put("hour",Integer.toString(cal.get(Calendar.HOUR_OF_DAY)));
body.put("dom", Integer.toString(cal.get(Calendar.DAY_OF_MONTH)));
body.put("eventsource", event.getSource());
body.put("ipaddr", event.getInterfaceAddress()!=null ? event.getInterfaceAddress().toString() : null );
body.put("servicename", event.getService());
body.put("eventseverity_text", event.getSeverity());
body.put("eventseverity", Integer.toString(OnmsSeverity.get(event.getSeverity()).getId()));
  body.put("eventdescr", event.getDescr());
body.put("host",event.getHost());
body.put("interface", event.getInterface());
body.put("logmsg", ( event.getLogmsg()!=null ? event.getLogmsg().getContent() : null ));
body.put("logmsgdest", ( event.getLogmsg()!=null ? event.getLogmsg().getDest() : null ));
if(event.getNodeid()!=null){
  body.put("nodeid", Long.toString(event.getNodeid()));

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

OutageChecker(MockService svc, Event lostSvcEvent,
    Event regainedSvcEvent) {
  super(m_db,
      "select * from outages where nodeid = ? and ipAddr = ? and serviceId = ?");
  m_svc = svc;
  m_lostSvcEvent = lostSvcEvent;
  m_lostSvcTime = new Timestamp(m_lostSvcEvent.getTime().getTime());
  m_regainedSvcEvent = regainedSvcEvent;
  if (m_regainedSvcEvent != null) {
    m_regainedSvcTime = new Timestamp(m_regainedSvcEvent.getTime().getTime());
  }
}

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

public Date currentEventTime() {
  if (m_event.getTime() == null && zonedDateTimeBuilder != null) {
    ZonedDateTime time = zonedDateTimeBuilder.build();
    return Date.from(time.toInstant());
  } else {
    return m_event.getTime();
  }
}

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

private void process(final Event event) throws EventProcessorException {
  LOG.debug("Writing event: {}", event);
  final OnmsEvent oe = new OnmsEvent();
  oe.setEventAutoAction((event.getAutoactionCount() > 0) ? AutoAction.format(event.getAutoaction(), EVENT_AUTOACTION_FIELD_SIZE) : null);
  oe.setEventCorrelation((event.getCorrelation() != null) ? org.opennms.netmgt.dao.util.Correlation.format(event.getCorrelation(), EVENT_CORRELATION_FIELD_SIZE) : null);
  oe.setEventCreateTime(event.getCreationTime());
  oe.setId(event.getDbid());
  oe.setEventDescr(event.getDescr());
  try {
    oe.setDistPoller(m_distPollerDao.get(event.getDistPoller()));
  } catch (final DataAccessException e) {
    throw new EventProcessorException(e);
  oe.setEventHost(event.getHost());
  oe.setEventForward((event.getForwardCount() > 0) ? org.opennms.netmgt.dao.util.Forward.format(event.getForward(), EVENT_FORWARD_FIELD_SIZE) : null);
  oe.setIfIndex(event.getIfIndex());
  oe.setIpAddr(event.getInterfaceAddress());
  if (event.getLogmsg() != null) {
    oe.setEventLogMsg(EventDatabaseConstants.format(event.getLogmsg().getContent(), 0));
    final String logdest = event.getLogmsg().getDest();
    if (logdest.equals("logndisplay")) {
  oe.setEventMouseOverText(event.getMouseovertext());
  try {
    oe.setNode(m_nodeDao.get(event.getNodeid().intValue()));
  } catch (final DataAccessException e) {
    throw new EventProcessorException(e);

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

.setId(event.getDbid())
    .setUei(event.getUei())
    .setSource(event.getSource())
    .setSeverity(toSeverity(OnmsSeverity.get(event.getSeverity())))
    .setLabel(eventConfDao.getEventLabel(event.getUei()));
if (event.getDescr() != null) {
  builder.setDescription(event.getDescr());
if (event.getLogmsg() != null) {
  builder.setLogMessage(event.getLogmsg().getContent());
if (event.getNodeid() != null) {
  try {
    builder.setNodeCriteria(nodeIdToCriteriaCache.get(event.getNodeid()));
  } catch (ExecutionException e) {
    LOG.warn("An error occurred when building node criteria for node with id: {}." +
        " The node foreign source and foreign id (if set) will be missing from the event with id: {}.",
        event.getNodeid(), event.getDbid(), e);
    builder.setNodeCriteria(OpennmsModelProtos.NodeCriteria.newBuilder()
        .setId(event.getNodeid()));
      .setId(event.getNodeid()));
if (event.getInterface() != null) {
  builder.setIpAddress(event.getInterface());
setTimeIfNotNull(event.getTime(), builder::setTime);

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

/**
 * <p>handleDeleteService</p>
 *
 * @param event a {@link org.opennms.netmgt.xml.event.Event} object.
 */
@EventHandler(uei=EventConstants.DELETE_SERVICE_EVENT_UEI)
public void handleDeleteService(Event event) {
  try {
  doDeleteService(event.getNodeid(), event.getInterfaceAddress() == null ? null : event.getInterfaceAddress(), event.getService());
  } catch (Throwable e) {
    LOG.error("Unexpected exception processing event: {}", event.getUei(), e);
  }
}

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

private void validateTranslatedEvent(Event event) {
  assertEquals(m_translator.getName(), event.getSource());
  assertEquals(Long.valueOf(3), event.getNodeid());
  assertEquals("www.opennms.org", event.getHost());
  assertEquals("a generated event", event.getDescr());
  assertEquals("192.168.1.1", event.getInterface());
  assertEquals("Switch", EventUtils.getParm(event, "nodeLabel"));
  assertEquals("PSV", event.getService());
  assertEquals("Down", EventUtils.getParm(event, "passiveStatus"));
}

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

private static boolean checkEventSanityAndDoWeProcess(final Event event) {
  if (event.getLogmsg() != null && LogDestType.DONOTPERSIST.toString().equalsIgnoreCase(event.getLogmsg().getDest())) {
    if (LOG.isDebugEnabled()) {
      LOG.debug("checkEventSanity: uei '{}' marked as '{}'; not processing event.", event.getUei(), LogDestType.DONOTPERSIST);
    }
    return false;
  }
  if (event.getAlarmData() == null) {
    if (LOG.isDebugEnabled()) {
      LOG.debug("checkEventSanity: uei '{}' has no alarm data; not processing event.", event.getUei());
    }
    return false;
  }
  if (event.getDbid() <= 0) {
    throw new IllegalArgumentException("Incoming event has an illegal dbid (" + event.getDbid() + "), aborting");
  }
  return true;
}

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

private void process(Header eventHeader, Event event, boolean synchronous) {
  if (event.getLogmsg() != null && event.getLogmsg().getDest().equals("suppress")) {
    LOG.debug("process: skip sending event {} to other daemons because is marked as suppress", event.getUei());
  } else {
    m_eventIpcBroadcaster.broadcastNow(event, synchronous);
  }
}

代码示例来源:origin: org.opennms.features.activemq/org.opennms.features.activemq.event-receiver

@Override
  public void process(final Exchange exchange) throws Exception {
    final Event event = exchange.getIn().getBody(Event.class);
    
    String systemId = exchange.getIn().getHeader(EVENT_HEADER_SYSTEMID, String.class);

    if (event.getNodeid() > 0) {
      String foreignSource = exchange.getIn().getHeader(EVENT_HEADER_FOREIGNSOURCE, String.class);
      String foreignId = exchange.getIn().getHeader(EVENT_HEADER_FOREIGNID, String.class);

      OnmsNode node = nodeDao.findByForeignId(foreignSource, foreignId);

      if (node != null && node.getId() != null) {
        event.setNodeid(node.getId().longValue());
        event.setDistPoller(systemId);
        event.setSource("Endpoint="+systemId+":"+event.getSource());
      } else {
        LOG.warn("Could not find node {}/{} in the database, cannot update node ID to local value; discarding event", foreignSource, foreignId);
        // Halt the route if we cannot translate the node ID
        exchange.setProperty(Exchange.ROUTE_STOP, Boolean.TRUE);
      }
    }
  }
}

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

private boolean eventMatches(final Event e) {
  if (m_ueiList == null)
    return true;
  return m_ueiList.contains(e.getUei());
}

相关文章

微信公众号

最新文章

更多