fix: getMetaByMap logic

JustKode · Aug 4, 2023 · 892b5c2 · 892b5c2
1 parent 29532e6
commit 892b5c2
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 6 deletions.
diff --git a/src/main/java/justkode/kafka/event/producer/meta/DoubleMeta.java b/src/main/java/justkode/kafka/event/producer/meta/DoubleMeta.java
@@ -45,7 +45,7 @@ public static DoubleMeta getMetaByMap(String key, Map<String, Object> map) {
         Double minValue = (Double) map.get("min_value");
         Double maxValue = (Double) map.get("max_value");
 
-        if (isManual && manualValues != null) {
+        if (isManual && manualValues == null) {
             throw new RuntimeException("manual_integers doesn't exists.");
         }
 

diff --git a/src/main/java/justkode/kafka/event/producer/meta/FloatMeta.java b/src/main/java/justkode/kafka/event/producer/meta/FloatMeta.java
@@ -44,7 +44,7 @@ public static FloatMeta getMetaByMap(String key, Map<String, Object> map) {
         Float minValue = (Float) map.get("min_value");
         Float maxValue = (Float) map.get("max_value");
 
-        if (isManual && manualValues != null) {
+        if (isManual && manualValues == null) {
             throw new RuntimeException("manual_integers doesn't exists.");
         }
 

diff --git a/src/main/java/justkode/kafka/event/producer/meta/IntegerMeta.java b/src/main/java/justkode/kafka/event/producer/meta/IntegerMeta.java
@@ -43,8 +43,8 @@ public static IntegerMeta getMetaByMap(String key, Map<String, Object> map) {
         Integer minValue = (Integer) map.get("min_value");
         Integer maxValue = (Integer) map.get("max_value");
 
-        if (isManual && manualValues != null) {
-            throw new RuntimeException("manual_integers doesn't exists.");
+        if (isManual && manualValues == null) {
+            throw new RuntimeException("manual_values doesn't exists.");
         }
         IntegerMeta integerMeta = new IntegerMeta(isManual, manualValues, minValue, maxValue);
         integerMeta.validCheck(key);

diff --git a/src/main/java/justkode/kafka/event/producer/meta/LongMeta.java b/src/main/java/justkode/kafka/event/producer/meta/LongMeta.java
@@ -45,7 +45,7 @@ public static LongMeta getMetaByMap(String key, Map<String, Object> map) {
         Long minValue = (Long) map.get("min_value");
         Long maxValue = (Long) map.get("max_value");
 
-        if (isManual && manualValues != null) {
+        if (isManual && manualValues == null) {
             throw new RuntimeException("manual_integers doesn't exists.");
         }
         LongMeta longMeta = new LongMeta(isManual, manualValues, minValue, maxValue);

diff --git a/src/main/java/justkode/kafka/event/producer/meta/StringMeta.java b/src/main/java/justkode/kafka/event/producer/meta/StringMeta.java
@@ -55,7 +55,7 @@ public static StringMeta getMetaByMap(String key, Map<String, Object> map) {
         Integer minLength = (Integer) map.get("min_length");
         Integer maxLength = (Integer) map.get("max_length");
 
-        if (isManual && manualValues != null) {
+        if (isManual && manualValues == null) {
             throw new RuntimeException("manual_integers doesn't exists.");
         }
         StringMeta stringMeta = new StringMeta(isManual, manualValues, minLength, maxLength);