code: @SuppressWarnings({"rawtypes"})
      @Override
      public void open(Map conf, TopologyContext context, SpoutOutputCollector collector)
      {
          super.open(conf, context, collector);
  
          Number timeout = (Number) conf.get(KESTREL_TIMEOUT);
          this.messageTimeoutMs = (int) TimeUnit.SECONDS.toMillis(timeout.intValue());
  
          this.restrictWatcher = new RestrictWatcher(this.restrictFilePath);
  
          // Spoutの番号に併せて取得対象となるQueue番号をQueue名称に設定
          int componentIndex = context.getThisTaskIndex();
          String baseQueueName = getQueueName();
          String queueName = baseQueueName + "_" + componentIndex;
          setQueueName(queueName);
      }
docs: {@inheritDoc}