IForwardingRulesManager frm = (IForwardingRulesManager) ServiceHelper.getInstance(
IForwardingRulesManager.class, "default", this);
if (frm.getStaticFlow(flowName, ofNode) != null) {
- logger.debug("Remove Egress Flow exists : {} for Flow {} on {} / {}", flowName, ofNode, node);
+ logger.debug("Remote Egress Flow exists : {} for Flow {} on {} / {}", flowName, ofNode, node);
return;
}
FlowConfig flow = new FlowConfig();
public void processResult(JsonNode response) throws NoSuchMethodException {
+ logger.trace("Response : {}", response.toString());
CallContext returnCtxt = methodContext.get(response.get("id").asText());
if (returnCtxt == null) return;
JavaType javaType = TypeFactory.defaultInstance().constructType (retType.getType());
JsonNode result = response.get("result");
- logger.trace("Response : {}", result.toString());
+ logger.trace("Result : {}", result.toString());
Object result1 = objectMapper.convertValue(result, javaType);
JsonNode error = response.get("error");
- if (error != null) {
+ if (error != null && !error.isNull()) {
logger.error("Error : {}", error.toString());
}
}
public void channelClosed(Node node) throws Exception {
- logger.error("Connection to Node : {} closed", node);
+ logger.info("Connection to Node : {} closed", node);
inventoryServiceInternal.removeNode(node);
}