public ListenableFuture<Boolean> shutdown() {
LOGGER.debug("Shutdown summoned");
if(serverFacade == null){
- LOGGER.debug("Can not shutdown - not configured or started");
+ LOGGER.warn("Can not shutdown - not configured or started");
throw new IllegalStateException("SwitchConnectionProvider is not started or not configured.");
}
return serverFacade.shutdown();
consumer.consume(dataObject);\r
}\r
} catch(Exception e) {\r
- LOGGER.error("Message deserialization failed");\r
- LOGGER.error(e.getMessage(), e);\r
+ LOGGER.warn("Message deserialization failed");\r
+ LOGGER.warn(e.getMessage(), e);\r
// TODO: delegate exception to allow easier deserialization\r
// debugging / deserialization problem awareness\r
} finally {\r
out.add(dataObject);
}
} catch(Exception e) {
- LOGGER.error("Message deserialization failed");
- LOGGER.error(e.getMessage(), e);
+ LOGGER.warn("Message deserialization failed");
+ LOGGER.warn(e.getMessage(), e);
// TODO: delegate exception to allow easier deserialization
// debugging / deserialization problem awareness
} finally {
@Override
public void checkClientTrusted(X509Certificate[] chain, String authType) {
- LOGGER.error("UNKNOWN CLIENT CERTIFICATE: " + chain[0].getSubjectDN());
+ LOGGER.warn("UNKNOWN CLIENT CERTIFICATE: {}", chain[0].getSubjectDN());
}
@Override
public void checkServerTrusted(X509Certificate[] chain, String authType) {
- LOGGER.error("UNKNOWN SERVER CERTIFICATE: " + chain[0].getSubjectDN());
+ LOGGER.warn("UNKNOWN SERVER CERTIFICATE: {}", chain[0].getSubjectDN());
}
};
InetAddress switchAddress = ch.remoteAddress().getAddress();
int port = ch.localAddress().getPort();
int remotePort = ch.remoteAddress().getPort();
- LOGGER.info("Incoming connection from (remote address): " + switchAddress.toString()
+ LOGGER.debug("Incoming connection from (remote address): " + switchAddress.toString()
+ ":" + remotePort + " --> :" + port);
if (!getSwitchConnectionHandler().accept(switchAddress)) {
ch.disconnect();
- LOGGER.info("Incoming connection rejected");
+ LOGGER.debug("Incoming connection rejected");
return;
}
- LOGGER.info("Incoming connection accepted - building pipeline");
+ LOGGER.debug("Incoming connection accepted - building pipeline");
allChannels.add(ch);
ConnectionFacade connectionFacade = null;
connectionFacade = connectionAdapterFactory.createConnectionFacade(ch, null);
connectionFacade.fireConnectionReadyNotification();
}
} catch (Exception e) {
- LOGGER.error("Failed to initialize channel", e);
+ LOGGER.warn("Failed to initialize channel", e);
ch.close();
}
}