Merge branch 'main' into setupeco-fix

galasa-parent/dev.galasa.framework/src/main/java/dev/galasa/framework/internal/events/FrameworkEventsService.java

@@ -5,14 +5,18 @@
  */
 package dev.galasa.framework.internal.events;
 
+import dev.galasa.framework.spi.events.IEvent;
 import dev.galasa.framework.spi.IEventsService;
 
 public class FrameworkEventsService implements IEventsService {
 
-    // The implementation of an Events Service would be in here, but there is no implementation for local runs...
+    // The Events Service has no implementation for local runs...
 
-
+    @Override
+    public void produceEvent(String topic, IEvent event) {
+    }
 
+    @Override
     public void shutdown(){
         // Nothing to shut down
     }

galasa-parent/dev.galasa.framework/src/main/java/dev/galasa/framework/spi/IEventProducer.java

@@ -0,0 +1,11 @@
+package dev.galasa.framework.spi;
+
+import dev.galasa.framework.spi.events.IEvent;
+
+public interface IEventProducer {
+
+    void sendEvent(IEvent event);
+
+    void close();
+
+}

galasa-parent/dev.galasa.framework/src/main/java/dev/galasa/framework/spi/IEventsService.java

@@ -5,8 +5,12 @@
  */
 package dev.galasa.framework.spi;
 
+import dev.galasa.framework.spi.events.IEvent;
+
 public interface IEventsService {
 
+    void produceEvent(String topic, IEvent event) throws EventsException;
+
     void shutdown();
 
 }

galasa-parent/dev.galasa.framework/src/main/java/dev/galasa/framework/spi/events/IEvent.java

@@ -0,0 +1,22 @@
+/*
+ * Copyright contributors to the Galasa project
+ *
+ * SPDX-License-Identifier: EPL-2.0
+ */
+package dev.galasa.framework.spi.events;
+
+public interface IEvent {
+
+    String getId();
+
+    void setId(String id);
+
+    String getTimestamp();
+
+    void setTimestamp(String timestamp);
+
+    String getMessage();
+
+    void setMessage(String message);
+
+}

galasa-parent/dev.galasa.framework/src/test/java/dev/galasa/framework/mocks/MockEventsService.java

@@ -6,9 +6,15 @@
 package dev.galasa.framework.mocks;
 
 import dev.galasa.framework.spi.IEventsService;
+import dev.galasa.framework.spi.events.IEvent;
 
 public class MockEventsService implements IEventsService {
 
+    @Override
+    public void produceEvent(String topic, IEvent event) {
+        throw new UnsupportedOperationException("Unimplemented method 'produceEvent'");
+    }
+
     @Override
     public void shutdown() {
         throw new UnsupportedOperationException("Unimplemented method 'shutdown'");