From 311bb7987017c65e5ac18c06abc09253cc69a17c Mon Sep 17 00:00:00 2001 From: Paul Campbell Date: Sat, 1 Apr 2017 19:16:55 +0100 Subject: [PATCH] #467 data-bus: members: StatusMember: records start and stop times --- .../databus/members/StatusMember.java | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) 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; + } }