Thread.currentThread().setContextClassLoader(contextClassLoader);
}
LOGGER.debug("Completed {}.", displayName);
} finally {
LOGGER.debug("Stopping client connection.");
client.stop();
}
}
MessagingClient createClient() {
return new TcpMessagingClient(getClass().getClassLoader(), serverAddress);