diff --git a/src/main/java/com/teragrep/akv_01/time/EnqueuedTimeImpl.java b/src/main/java/com/teragrep/akv_01/time/EnqueuedTimeImpl.java index 785b05d..77b4cf3 100644 --- a/src/main/java/com/teragrep/akv_01/time/EnqueuedTimeImpl.java +++ b/src/main/java/com/teragrep/akv_01/time/EnqueuedTimeImpl.java @@ -57,7 +57,10 @@ public EnqueuedTimeImpl(final Object origin) { @Override public ZonedDateTime zonedDateTime() { - return ZonedDateTime.parse(origin.toString() + "Z"); + if (origin == null) { + throw new IllegalArgumentException("EnqueuedTime origin is null"); + } + return ZonedDateTime.parse(origin + "Z"); } @Override