Gist of forwarding actor test

gistfile1.java

@Test
public void shouldForwardLookupMessageLookupActor(){
	createActorWithPath("lookup-source-"+SOURCE_ID, testProbe);
	ActorRef ref = testProbe.ref();
	lookupActor.tell(new GetContent(SOURCE_ID, SYSTEM_ENTRY_TIME), ref);
	
	LookupResponse actual = testProbe.expectMsgClass(LookupResponse.class);
	assertEquals(EXPECTED_CONTENT, actual.getContent());
}


protected void createActorWithPath(String path,TestProbe probe) {
	TestActorRef.create(actorSystem, Props.create(ForwardingActor.class, probe.ref()), path);
}


public class ForwardingActor extends UntypedActor {

	private static final Logger LOGGER = LoggerFactory.getLogger(ForwardingActor.class.getName());
	
    final ActorRef target;
    public ForwardingActor(ActorRef target) {
        this.target = target;
    }
    @Override
    public void onReceive(Object msg) {
    	LOGGER.warn("forwarding message given to me {} to actor {}, thread {}, dispatcher is {}",self().path(),target.path().toString(),Thread.currentThread().getName(),getContext().dispatcher());
        target.forward(msg, getContext());
    }
    
    @Override
    public void postStop(){

    	LOGGER.info("stopped forwarding actor  fowarding from {} -> {}",getSelf().path(), target.path().toString());
    }
    
    @Override
    public void preStart(){

    	LOGGER.info("started forwarding actor fowarding from {} -> {}",getSelf().path(),target.path().toString());
    }
    
}