added actor names

src/main/java/akka/common/CounterActor.java

@@ -42,12 +42,13 @@ public class CounterActor extends UntypedActor {
 
 	private void onTerminating() {
 		LOGGER.debug("Terminating...");
+		LOGGER.trace("Current thread: " + Thread.currentThread());
 	}
 
 	@Override
 	public void postStop() throws Exception {
-		LOGGER.info("stopped: " + numMessages + " messages");
-		LOGGER.debug("Threads (" + threads.size() + "): " + threads);
+		LOGGER.trace("Threads (" + threads.size() + "): " + threads);
+		LOGGER.info(self().path().name() + ": " + numMessages + " messages");
 		super.postStop();
 	}
 }

src/main/java/akka/io/net/TcpRecordReconstructionActor.java

@@ -100,9 +100,6 @@ public class TcpRecordReconstructionActor extends UntypedActor {
 	}
 
 	private void terminate() {
-//		ActorSelection rootActorSelection = context().system().actorSelection(self().path().root());
-//		ActorRef rootActor = rootActorSelection.anchor();
-		// rootActor.tell(PoisonPill.getInstance(), rootActor);
 		self().tell(PoisonPill.getInstance(), getSelf());
 	}
 

src/main/java/akka/io/net/TcpTraceReconstructionActor.java

@@ -38,8 +38,8 @@ public class TcpTraceReconstructionActor extends UntypedActor implements ISendTr
 			final Props validTraceReceiverProps, final Props invalidTraceReceiverProps, final ActorRef watchActor) {
 		super();
 		this.reconstructor = new TraceReconstructor(traceId2trace, this);
-		this.validTraceReceiver = context().actorOf(validTraceReceiverProps);
-		this.invalidTraceReceiver = context().actorOf(invalidTraceReceiverProps);
+		this.validTraceReceiver = context().actorOf(validTraceReceiverProps, "Valid-receiver");
+		this.invalidTraceReceiver = context().actorOf(invalidTraceReceiverProps, "Invalid-receiver");
 
 		watchActor.tell(new WatchMe(getSelf()), getSelf());
 	}
@@ -48,6 +48,7 @@ public class TcpTraceReconstructionActor extends UntypedActor implements ISendTr
 	public void onReceive(final Object message) throws Exception {
 		if (LOGGER.isTraceEnabled()) {
 			LOGGER.trace("onReceive: " + message);
+			LOGGER.trace("Current thread: " + Thread.currentThread());
 		}
 
 		threads.add(Thread.currentThread());
@@ -71,7 +72,8 @@ public class TcpTraceReconstructionActor extends UntypedActor implements ISendTr
 	}
 
 	private void onTerminating() {
-		LOGGER.trace("traces left: " + reconstructor.getTraceId2trace().keySet());
+		LOGGER.debug("traces left: " + reconstructor.getTraceId2trace().keySet());
+		LOGGER.trace("Current thread: " + Thread.currentThread());
 		reconstructor.terminate();
 		LOGGER.debug("Threads (" + threads.size() + "): " + threads);
 	}