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

Log介绍

[英]Class Log.
[中]课堂日志。

代码示例

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

@Override
public void sendNow(final Log log) {
  if (log != null && log.getEvents() != null && log.getEvents().getEventCount() > 0) {
    m_events.addAll(log.getEvents().getEventCollection());
  }
}

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

@Override
public void sendNowSync(Event event) {
  Objects.requireNonNull(event);
  Events events = new Events();
  events.addEvent(event);
  Log eventLog = new Log();
  eventLog.setEvents(events);
  sendNowSync(eventLog);
}

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

@Override
public Log aggregate(Log eventLog, Event event) {
  if (eventLog == null) {
    eventLog = new Log();
    eventLog.addEvent(event);
  }
  eventLog.addEvent(event);
  return eventLog;
}

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

public void addAllEvents(final Log log) {
  assertEventsExists();
  this._events.addAllEvents(log.getEvents());
}

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

@Override
public void process(Log eventLog, boolean synchronous) throws EventProcessorException {
  if (eventLog != null && eventLog.getEvents() != null && eventLog.getEvents().getEvent() != null) {
    try (Context context = logBroadcastTimer.time()) {
      for(Event eachEvent : eventLog.getEvents().getEvent()) {
        process(eventLog.getHeader(), eachEvent, synchronous);
        eventBroadcastMeter.mark();
      }
    }
  }
}

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

@Override
public void run() {
  final RateLimiter rateLimiter = RateLimiter.create(eventsPerSecondPerThread);
  while (true) {
    Log log = new Log();
    log.setEvents(new Events());
    for (int i=0; i<batchSize; i++) {
      log.getEvents().getEventCollection().add(getNextEvent());
    }
    rateLimiter.acquire(batchSize);
    if (isSynchronous) {
      eventForwarder.sendNowSync(log);
    } else {
      eventForwarder.sendNow(log);
    }
    eventsGenerated.mark(batchSize);
    if (Thread.interrupted()) {
      break;
    }
  }
}

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

private Log createLog(List<Event> eventList) {
  final Header header = new Header();
  header.setCreated(StringUtils.toStringEfficiently(new Date()));
  final Events events = new Events();
  events.setEvent(eventList);
  final Log log = new Log();
  log.setEvents(events);
  log.setHeader(header);
  return log;
}

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

/**
 * Create an instance of {@link Log }
 * 
 */
public Log createLog() {
  LOG.debug("createLog");
  return new Log();
}

代码示例来源：origin: org.opennms.features/org.opennms.features.opennms-es-rest

private Log createLog(List<Event> eventList) {
  final Header header = new Header();
  header.setCreated(StringUtils.toStringEfficiently(new Date()));
  final Events events = new Events();
  events.setEvent(eventList);
  final Log log = new Log();
  log.setEvents(events);
  log.setHeader(header);
  return log;
}

代码示例来源：origin: org.opennms.features.events/org.opennms.features.events.daemon

@Override
public void process(Log eventLog, boolean synchronous) throws EventProcessorException {
  if (eventLog != null && eventLog.getEvents() != null && eventLog.getEvents().getEvent() != null) {
    try (Context context = logBroadcastTimer.time()) {
      for(Event eachEvent : eventLog.getEvents().getEvent()) {
        process(eventLog.getHeader(), eachEvent, synchronous);
        eventBroadcastMeter.mark();
      }
    }
  }
}

代码示例来源：origin: org.opennms.features.events/org.opennms.features.events.api

public void addAllEvents(final Log log) {
  assertEventsExists();
  this._events.addAllEvents(log.getEvents());
}

代码示例来源：origin: org.opennms.features.events/org.opennms.features.events.api

/**
 * Create an instance of {@link Log }
 * 
 */
public Log createLog() {
  LOG.debug("createLog");
  return new Log();
}

代码示例来源：origin: org.opennms/opennms-provisiond

@Override
public void sendNow(final Log log) {
  if (log != null && log.getEvents() != null && log.getEvents().getEventCount() > 0) {
    m_events.addAll(log.getEvents().getEventCollection());
  }
}

代码示例来源：origin: org.opennms.features.events/org.opennms.features.events.daemon

@Override
public void sendNowSync(Event event) {
  Objects.requireNonNull(event);
  Events events = new Events();
  events.addEvent(event);
  Log eventLog = new Log();
  eventLog.setEvents(events);
  sendNowSync(eventLog);
}

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

public Log getLog() {
  Event event = getEvent();
  Events events = new Events();
  events.setEvent(new Event[]{event});
  Header header = new Header();
  header.setCreated(StringUtils.toStringEfficiently(event.getCreationTime()));
  Log log = new Log();
  log.setHeader(header);
  log.setEvents(events);
  return log;
}

代码示例来源：origin: org.opennms.features.events/org.opennms.features.events.daemon

@Override
public Log aggregate(Log eventLog, Event event) {
  if (eventLog == null) {
    eventLog = new Log();
    eventLog.addEvent(event);
  }
  eventLog.addEvent(event);
  return eventLog;
}

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

@Override
public void process(Log eventLog) throws EventProcessorException {
  if (eventLog != null && eventLog.getEvents() != null && eventLog.getEvents().getEvent() != null) {
    for (Event eachEvent : eventLog.getEvents().getEvent()) {
      process(eachEvent);
    }
  }
}

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

/** {@inheritDoc} */
@Override
public void sendNow(Event event) {
  Log eventLog = new Log();
  Events events = new Events();
  eventLog.setEvents(events);
  events.addEvent(event);
  sendNow(eventLog);
}

代码示例来源：origin: org.opennms.features/org.opennms.features.eif-adapter

@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) throws Exception {
  buffer.append(msg.toString(charset));
  if ( buffer.toString().contains("<START>>") && buffer.toString().contains(";END") ) {
    int eifStart = buffer.indexOf("<START>>");
    int eifEnd = buffer.lastIndexOf(";END");
    final StringBuilder eif = new StringBuilder(buffer.substring(eifStart,eifEnd+4));
    buffer.delete(eifStart,eifEnd+4);
    List<Event> e = EifParser.translateEifToOpenNMS(nodeDao, eif);
    if (e != null) {
      Log eifEvents = new Log();
      e.forEach(event -> eifEvents.addEvent(event));
      out.add(eifEvents);
    }
  }
}

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

@Override
public void sendNow(Log eventLog) {
  if (eventLog != null && eventLog.getEvents() != null) {
    for (Event event : eventLog.getEvents().getEvent()) {
      sendNow(event);
    }
  }
}