X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Foutbox;a=blobdiff_plain;f=postage%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Foutbox%2Fpostage%2FOutboxEvent.java;fp=postage%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Foutbox%2Fpostage%2FOutboxEvent.java;h=6c87b12acf7ce385535007b1cc780be1cd9d0274;hp=0000000000000000000000000000000000000000;hb=fbd0ca0df5004d13a5e93cdb8373bafc60440c8b;hpb=bdc7b089e14ddc16f7e76f6a736b27b608e35ab4

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
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;
+  }
+}