code: @SuppressWarnings({"rawtypes", "resource"})
      @Override
      public void onPrepare(Map stormConf, TopologyContext context)
      {
          // cleanupメソッドは呼ばれないため、リソースクローズはできない。
          // だが、1インスタンスのみしか生成されないため、リークはしない。
  
          // ElasticSearchClientを初期化
          // Serversは「host1:port1;host2:port2;host3:port3...」形式のため分割して生成
          Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name",
                  this.clusterName).build();
          TransportClient transportClient = new TransportClient(settings);
          for (String server : this.servers.split(";"))
          {
              String[] components = server.trim().split(":");
              String host = components[0];
              int port = DEFAULT_PORT;
              if (components.length > 1)
              {
                  port = Integer.parseInt(components[1]);
              }
  
              transportClient = transportClient.addTransportAddress(new InetSocketTransportAddress(
                      host, port));
          }
  
          this.client = transportClient;
      }
docs: {@inheritDoc}