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

Log.<init>介绍

暂无

代码示例

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

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

代码示例来源：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.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
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 Log aggregate(Log eventLog, Event event) {
  if (eventLog == null) {
    eventLog = new Log();
    eventLog.addEvent(event);
  }
  eventLog.addEvent(event);
  return eventLog;
}

代码示例来源：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 sendNowSync(Event event) {
  Objects.requireNonNull(event);
  Events events = new Events();
  events.addEvent(event);
  Log eventLog = new Log();
  eventLog.setEvents(events);
  sendNowSync(eventLog);
}

代码示例来源：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

/**
 * {@inheritDoc}
 *
 * Called by a service to send an event to other listeners.
 */
@Override
public void sendNow(Event event) {
  Assert.notNull(event, "event argument cannot be null");
  Events events = new Events();
  events.addEvent(event);
  Log eventLog = new Log();
  eventLog.setEvents(events);
  sendNow(eventLog);
}

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

/**
 * {@inheritDoc}
 *
 * Called by a service to send an event to other listeners.
 */
@Override
public void sendNow(Event event) {
  Assert.notNull(event, "event argument cannot be null");
  Events events = new Events();
  events.addEvent(event);
  Log eventLog = new Log();
  eventLog.setEvents(events);
  sendNow(eventLog);
}

代码示例来源：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: OpenNMS/opennms

/**
 * {@inheritDoc}
 *
 * This method is called to send the event out
 * @exception UndeclaredThrowableException
 *                thrown if the send fails for any reason
 */
@Override
public void send(Event event) throws EventProxyException {
  Log elog = new Log();
  Events events = new Events();
  events.addEvent(event);
  elog.setEvents(events);
  send(elog);
}

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

/**
 * {@inheritDoc}
 *
 * This method is called to send the event out
 * @exception UndeclaredThrowableException
 *                thrown if the send fails for any reason
 */
@Override
public void send(Event event) throws EventProxyException {
  Log elog = new Log();
  Events events = new Events();
  events.addEvent(event);
  elog.setEvents(events);
  send(elog);
}

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

/**
 * <p>sendAllEvents</p>
 */
public void sendAllEvents() {
  if (m_events.size() > 0) {
    try {
      Log log = new Log();
      Events events = new Events();
      for (Event e : m_events) {
        events.addEvent(e);
      }
      log.setEvents(events);
      EventIpcManagerFactory.getIpcManager().sendNow(log);
    } catch (Throwable e) {
      LOG.info("sendAllEvents: Failed sending threshold events", e);
    }
    removeAllEvents();
  }
}

代码示例来源：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: 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: 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

protected static Log toNewSuspectEvents(DiscoveryJob job, PingSweepSummary summary) {
  final Log eventLog = new Log();
  for (Entry<InetAddress, Double> entry : summary.getResponses().entrySet()) {
    EventBuilder eb = new EventBuilder(EventConstants.NEW_SUSPECT_INTERFACE_EVENT_UEI, Discovery.DAEMON_NAME);
    eb.setInterface(entry.getKey());
    eb.addParam("RTT", entry.getValue());
    if (job.getForeignSource() != null) {
      eb.addParam(EventConstants.PARM_FOREIGN_SOURCE, job.getForeignSource());
    }
    if (job.getLocation() != null) {
      eb.addParam(EventConstants.PARM_LOCATION, job.getLocation());
    }
    eventLog.addEvent(eb.getEvent());
  }
  return eventLog;
}

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

protected static Log toNewSuspectEvents(DiscoveryJob job, PingSweepSummary summary) {
  final Log eventLog = new Log();
  for (Entry<InetAddress, Double> entry : summary.getResponses().entrySet()) {
    EventBuilder eb = new EventBuilder(EventConstants.NEW_SUSPECT_INTERFACE_EVENT_UEI, Discovery.DAEMON_NAME);
    eb.setInterface(entry.getKey());
    eb.addParam("RTT", entry.getValue());
    if (job.getForeignSource() != null) {
      eb.addParam(EventConstants.PARM_FOREIGN_SOURCE, job.getForeignSource());
    }
    if (job.getLocation() != null) {
      eb.addParam(EventConstants.PARM_LOCATION, job.getLocation());
    }
    eventLog.addEvent(eb.getEvent());
  }
  return 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;
}