diff --git a/src/main/java/org/bdware/sc/event/EventBroker.java b/src/main/java/org/bdware/sc/event/EventBroker.java index a6a72c5..b0dad0c 100644 --- a/src/main/java/org/bdware/sc/event/EventBroker.java +++ b/src/main/java/org/bdware/sc/event/EventBroker.java @@ -173,7 +173,8 @@ public class EventBroker { topic2cIds.get(topic).add(cId); switch (consumer.getType()) { case Contract: - LOGGER.info("contract " + ((ContractConsumer) consumer).getContract() + " subscribes topic " + topic); + LOGGER.info("contract " + ((ContractConsumer) consumer).getContract() + + " subscribes topic " + topic); break; case Node: LOGGER.info("node " + consumer.getId() + " subscribes topic " + topic); diff --git a/src/main/java/org/bdware/sc/event/clients/WSClientConsumer.java b/src/main/java/org/bdware/sc/event/clients/WSClientConsumer.java index 49096c2..6f6361f 100644 --- a/src/main/java/org/bdware/sc/event/clients/WSClientConsumer.java +++ b/src/main/java/org/bdware/sc/event/clients/WSClientConsumer.java @@ -41,6 +41,7 @@ public class WSClientConsumer implements IEventConsumer { } JsonObject ret = new JsonObject(); ret.addProperty("action", "onEvent"); + ret.addProperty("status", "Success"); ret.add("data", JsonUtil.parseString(msg)); channel.writeAndFlush(new TextWebSocketFrame(ret.toString())); }