X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FClientMessage.java;h=a15890720ba62a3334a9631b06e2ff486e4468ab;hb=a8aed63e92d58731176dde8b7cec4f5a022ac813;hp=d18800bc15cf420b60bfe6b24875e12a245504fd;hpb=536c9c5320e52101bda5e1931bc84c5e0e0137f2;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/ClientMessage.java b/src/main/java/de/juplo/kafka/ClientMessage.java
index d18800b..a158907 100644
--- a/src/main/java/de/juplo/kafka/ClientMessage.java
+++ b/src/main/java/de/juplo/kafka/ClientMessage.java
@@ -1,11 +1,22 @@
 package de.juplo.kafka;
 
-import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
 
 
-@Data
-public class ClientMessage
+@Getter
+@Setter
+@EqualsAndHashCode
+@ToString
+public class ClientMessage extends ValidMessage
 {
   String client;
   String message;
+
+  ClientMessage()
+  {
+    super(Type.CLIENT_MESSAGE);
+  }
 }