code: protected void notifyAllPendingSenders(String message) {
          for (ChannelFuture future : _futureMap.values()) {
              future.setFailure(new Error(message));
          }
      }
docs: Notify all the senders of all pending requests