appender.append(event);

        final List<LogNotificationEvent> events = ComponentUtil.getLogNotificationHelper().drainAll();
        assertEquals(0, events.size());
    }

    @Test
    public void test_append_excludedLogger_logNotificationJob() {

                for (final LogNotificationEvent event : batch) {
                    final Map<String, Object> source = new HashMap<>();
                    source.put("hostname", hostname);
                    source.put("level", event.getLevel());
                    source.put("loggerName", event.getLoggerName());
                    source.put("message", event.getMessage());

        }
    }

    /**
     * Dispatches an event to all registered handlers for the event name.
     *
     * @param event the event to dispatch.
     */
    protected void dispatchEvent(final EventInfo event) {
        final List<Consumer<EventInfo>> handlers = eventHandlers.get(event.name);
        if (handlers != null) {
            for (final Consumer<EventInfo> handler : handlers) {

            logNotificationTarget.flush();
        }
    }

    /**
     * Offers an event to the buffer. If the buffer exceeds the maximum size, the oldest event is dropped.
     *
     * @param event the log notification event to add
     */
    public void offer(final LogNotificationEvent event) {
        int maxBufferSize;
        try {

        coordinatorHelper.addEventHandler("config_updated", event -> {
            receivedData.set(event.data);
            receivedInstanceId.set(event.instanceId);
        });

        final EventInfo event = new EventInfo();
        event.name = "config_updated";
        event.data = "web_config";
        event.instanceId = "sender@host1";
        coordinatorHelper.dispatchEvent(event);

        activityHelper.login(OptionalThing.empty());
        assertEquals(
                "{\"@timestamp\":\"2022-01-01T00:00:00.000Z\",\"log.level\":\"INFO\",\"ecs.version\":\"1.2.0\",\"service.name\":\"fess\",\"event.dataset\":\"app\",\"process.thread.name\":\"main\",\"log.logger\":\"org.codelibs.fess.helper.ActivityHelperTest$1\",\"labels.action\":\"LOGIN\",\"labels.user\":\"-\",\"labels.permissions\":\"-\"}",
                localLogMsg.get());

    }

    @Override
    public void append(final LogEvent event) {
        final String loggerName = event.getLoggerName();
        if (loggerName != null) {
            for (final String excluded : EXCLUDED_LOGGERS) {
                if (loggerName.startsWith(excluded)) {
                    return;
                }
            }
        }

        if (!event.getLevel().isMoreSpecificThan(getEffectiveMinLevel())) {

    /**
     * Sends a Server-Sent Event (SSE) to the client.
     *
     * @param writer the print writer to write the event to
     * @param event the event name
     * @param data the event data to serialize as JSON
     */
    protected void sendSseEvent(final PrintWriter writer, final String event, final Map<String, Object> data) {
        try {
            writer.write("event: " + event + "\n");

            events.add(new LogNotificationEvent(timestamp, "ERROR", "org.codelibs.fess.TestClass", longMessage, null));
        }

        String details = testableJob.testFormatDetails(events);

        assertNotNull(details);
        // Max 50 events displayed, message truncated to 200 chars
        assertTrue(details.contains("Total: 100 event(s) (showing 50)"));

     */
    public void setEcsServiceName(final String ecsServiceName) {
        this.ecsServiceName = ecsServiceName;
    }

    /**
     * Set the ECS event dataset.
     * @param ecsEventDataset The ECS event dataset.
     */
    public void setEcsEventDataset(final String ecsEventDataset) {
        this.ecsEventDataset = ecsEventDataset;
    }