本文整理了Java中org.opennms.netmgt.xml.event.Event
类的一些代码示例,展示了Event
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Event
类的具体详情如下:
包路径:org.opennms.netmgt.xml.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());
}
内容来源于网络,如有侵权,请联系作者删除!