gistfile1.txt

public class RemoteErrorActor extends UntypedActor {

    @SuppressWarnings("rawtypes")
    @Override
    public void onReceive(Object o) throws Exception {
        if (o instanceof RemoteClientWriteFailed) {
            RemoteClientWriteFailed fail = (RemoteClientWriteFailed) o;
            if (fail.getRequest() instanceof Tuple3) {
                Tuple3 t3 = (Tuple3) fail.getRequest();
                if (t3._2() instanceof Some) {
                    Some s = (Some) t3._2();
                    if (s.get() instanceof PromiseActorRef) {
                        PromiseActorRef par = (PromiseActorRef) s.get();
                        par.tell(/*something useful*/, self());
                    }
                }
            }
        }
    }
}

system.eventStream().subscribe(system.actorOf(new Props(RemoteErrorActor.class)),
                        RemoteClientWriteFailed.class);