dont propagate error event messages if the adapter is already stopped

Author: marregui

hivemq-edge/src/main/java/com/hivemq/bootstrap/ioc/Injector.java

@@ -57,11 +57,10 @@
 import com.hivemq.uns.ioc.UnsServiceModule;
 import dagger.BindsInstance;
 import dagger.Component;
-
 import jakarta.inject.Singleton;
+
 import java.util.Set;
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.ScheduledExecutorService;
 
 @SuppressWarnings({"NullabilityAnnotations", "UnusedReturnValue"})
 @Component(modules = {
@@ -123,11 +122,8 @@ public interface Injector {
 
 //    UnsServiceModule uns();
 
-    // Executor accessors for coordinated shutdown
     ExecutorService executorService();
 
-    ScheduledExecutorService scheduledExecutor();
-
     @Component.Builder
     interface Builder {
 

hivemq-edge/src/main/java/com/hivemq/edge/modules/adapters/impl/ProtocolAdapterStateImpl.java

@@ -85,7 +85,8 @@ public void reportErrorMessage(
         // This is can be sent through the API to give an indication of the
         // status of an adapter runtime.
         lastErrorMessage.set(errorMessage == null ? throwable == null ? null : throwable.getMessage() : errorMessage);
-        if (sendEvent) {
+        // Don't send error events if the adapter is already stopped
+        if (sendEvent && runtimeStatus.get() != RuntimeStatus.STOPPED) {
             final var eventBuilder = eventService.createAdapterEvent(adapterId, protocolId)
                     .withSeverity(EventImpl.SEVERITY.ERROR)
                     .withMessage(String.format("Adapter '%s' encountered an error.", adapterId));