* @param unreachablePeerId the unreachable peer
* @return forwarder
*/
private BaseRelayForwarderRPC extractRelayForwarder(final Message message) {
final Dispatcher dispatcher = peer.connectionBean().dispatcher();
final Map<Integer, DispatchHandler> ioHandlers = dispatcher.searchHandlerMap(peer.peerID(), message.recipient().peerId());
for (DispatchHandler handler : ioHandlers.values()) {
if (handler instanceof BaseRelayForwarderRPC) {
return (BaseRelayForwarderRPC) handler;
}
}