code: private void blacklist(KestrelClientInfo info, Throwable t)
      {
          logger.warn("Failed to read from Kestrel at " + info.host + ":" + info.port, t);
  
          //this case can happen when it fails to connect to Kestrel (and so never stores the connection)
          info.closeClient();
          info.blacklistTillTimeMs = System.currentTimeMillis() + DEFAULT_BLACKLIST_TIME_MS;
  
          int index = this.clientInfoList.indexOf(info);
  
          // we just closed the connection, so all open reliable reads will be aborted. empty buffers.
          for (Iterator<EmitItem> i = this.emitBuffer.iterator(); i.hasNext();)
          {
              EmitItem item = i.next();
              if (item.getSourceId().getIndex() == index)
              {
                  i.remove();
              }
          }
      }
docs: メッセージの取得失敗したクライアントに除外設定を行う。
  
  @param info クライアント接続情報
  @param t 発生例外