diff --git a/data-bus/src/main/java/com/iluwatar/databus/members/StatusMember.java b/data-bus/src/main/java/com/iluwatar/databus/members/StatusMember.java index f11e1e0ab..803e2df20 100644 --- a/data-bus/src/main/java/com/iluwatar/databus/members/StatusMember.java +++ b/data-bus/src/main/java/com/iluwatar/databus/members/StatusMember.java @@ -29,6 +29,7 @@ import com.iluwatar.databus.data.MessageData; import com.iluwatar.databus.data.StartingData; import com.iluwatar.databus.data.StoppingData; +import java.time.LocalDateTime; import java.util.logging.Logger; /** @@ -42,6 +43,10 @@ public class StatusMember implements Member { private final int id; + private LocalDateTime started; + + private LocalDateTime stopped; + public StatusMember(int id) { this.id = id; } @@ -56,12 +61,22 @@ public class StatusMember implements Member { } private void handleEvent(StartingData data) { - LOGGER.info(String.format("Receiver #%d sees application started at %s", id, data.getWhen())); + started = data.getWhen(); + LOGGER.info(String.format("Receiver #%d sees application started at %s", id, started)); } private void handleEvent(StoppingData data) { - LOGGER.info(String.format("Receiver #%d sees application stopping at %s", id, data.getWhen())); + stopped = data.getWhen(); + LOGGER.info(String.format("Receiver #%d sees application stopping at %s", id, stopped)); LOGGER.info(String.format("Receiver #%d sending goodbye message", id)); data.getDataBus().publish(MessageData.of(String.format("Goodbye cruel world from #%d!", id))); } + + public LocalDateTime getStarted() { + return started; + } + + public LocalDateTime getStopped() { + return stopped; + } }