public void emit()

in sdk-java/src/main/java/com/spotify/confidence/EventSenderEngineImpl.java [77:92]

• 16 lines of code
• 3 McCabe index (conditional complexity)

  public void emit(
      String name, ConfidenceValue.Struct context, Optional<ConfidenceValue.Struct> data) {
    if (intakeClosed) {
      log.warn("EventSenderEngine is closed, dropping event {}", name);
      return;
    }
    final Event event =
        EventUploader.event(name, context, data).setEventTime(clock.getTimestamp()).build();
    if (estimatedMemoryConsumption.get() + event.getSerializedSize() > maxMemoryConsumption) {
      log.warn("EventSenderEngine is overloaded, dropping event {}", name);
      return;
    }
    sendQueue.add(event);
    estimatedMemoryConsumption.addAndGet(event.getSerializedSize());
    LockSupport.unpark(pollingThread);
  }