}
public static class LoggingThread implements Runnable {
-
+ private final Random random = new Random();
private final ActorRef clientActor;
+
private volatile boolean stopLogging = false;
public LoggingThread(final ActorRef clientActor) {
@Override
public void run() {
- Random random = new Random();
while (true) {
if (stopLogging) {
LOG.info("Logging stopped for client: {}", clientActor.path());