diff --git a/src/main/java/de/hottis/mbusMaster/ADataObject.java b/src/main/java/de/hottis/mbusMaster/ADataObject.java index 6dd1f78..e7e206d 100644 --- a/src/main/java/de/hottis/mbusMaster/ADataObject.java +++ b/src/main/java/de/hottis/mbusMaster/ADataObject.java @@ -9,17 +9,17 @@ import org.apache.logging.log4j.Logger; public abstract class ADataObject implements Serializable { private static final long serialVersionUID = 1L; - static final String KIND_KEY = "kind"; + static final String KIND_KEY = "kind"; final protected Logger logger = LogManager.getRootLogger(); private String name; private Map values; - private String kind; + private String kind; public ADataObject(String name, String kind) { this.name = name; - this.kind = kind; + this.kind = kind; } public void setValues(Map values) { @@ -39,7 +39,11 @@ public abstract class ADataObject implements Serializable { public String getName() { return name; } - + + public String getKind() { + return this.kind; + } + public String toString() { StringBuffer sb = new StringBuffer(); sb.append("{\"name\":\""); diff --git a/src/main/java/de/hottis/mbusMaster/DummyDequeuer.java b/src/main/java/de/hottis/mbusMaster/DummyDequeuer.java index 239cca6..cfc42bb 100644 --- a/src/main/java/de/hottis/mbusMaster/DummyDequeuer.java +++ b/src/main/java/de/hottis/mbusMaster/DummyDequeuer.java @@ -37,6 +37,9 @@ public class DummyDequeuer extends Thread { if (o.hasKey(ERROR_RATIO_KEY) && ((Double)o.getValues().get(ERROR_RATIO_KEY)) > 0.25) { System.out.print(ANSI_RED); } + if ("Statistics".equals(o.getKind())) { + System.out.print(ANSI_BLUE); + } System.out.print("DummyDequeuer: " + o.toString()); System.out.println(ANSI_RESET); } catch (InterruptedException e) {