Moved postage of messages into a reusable standalone implementation

[demos/kafka/outbox] / postage / src / main / java / de / juplo / kafka / outbox / postage / OutboxEvent.java

diff --git a/postage/src/main/java/de/juplo/kafka/outbox/postage/OutboxEvent.java b/postage/src/main/java/de/juplo/kafka/outbox/postage/OutboxEvent.java
new file mode 100644 (file)
index 0000000..6c87b12
--- /dev/null
+++ b/postage/src/main/java/de/juplo/kafka/outbox/postage/OutboxEvent.java
@@ -0,0 +1,30 @@
+package de.juplo.kafka.outbox.postage;
+
+import lombok.EqualsAndHashCode;
+import lombok.Getter;
+import lombok.ToString;
+import org.springframework.context.ApplicationEvent;
+
+import java.time.ZonedDateTime;
+
+
+@ToString
+@EqualsAndHashCode
+public class OutboxEvent extends ApplicationEvent
+{
+  @Getter
+  private final String key;
+  @Getter
+  private final Object value;
+  @Getter
+  private final ZonedDateTime time;
+
+
+  public OutboxEvent(Object source, String key, Object value, ZonedDateTime time)
+  {
+    super(source);
+    this.key = key;
+    this.value = value;
+    this.time = time;
+  }
+}