本文整理了Java中backtype.storm.Config.setMessageTimeoutSecs()方法的一些代码示例，展示了Config.setMessageTimeoutSecs()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Config.setMessageTimeoutSecs()方法的具体详情如下：
包路径：backtype.storm.Config
类名称：Config
方法名：setMessageTimeoutSecs

Config.setMessageTimeoutSecs介绍

暂无

代码示例

代码示例来源：origin: alibaba/jstorm

public void setMessageTimeoutSecs(int secs) {
  setMessageTimeoutSecs(this, secs);
}

代码示例来源：origin: com.n3twork.storm/storm-core

public void setMessageTimeoutSecs(int secs) {
  setMessageTimeoutSecs(this, secs);
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

public void setMessageTimeoutSecs(int secs) {
  setMessageTimeoutSecs(this, secs);
}

代码示例来源：origin: com.twitter.heron/heron-storm

public void setMessageTimeoutSecs(int secs) {
 setMessageTimeoutSecs(this, secs);
}

代码示例来源：origin: apache/eagle

int messageTimeoutSecs = config.hasPath(MESSAGE_TIMEOUT_SECS)?config.getInt(MESSAGE_TIMEOUT_SECS) : DEFAULT_MESSAGE_TIMEOUT_SECS;
LOG.info("Set topology.message.timeout.secs as {}",messageTimeoutSecs);
stormConfig.setMessageTimeoutSecs(messageTimeoutSecs);

代码示例来源：origin: apache/eagle

stormConfig.setMessageTimeoutSecs(messageTimeoutSecs);

代码示例来源：origin: davidkiss/storm-twitter-word-count

public static void main(String[] args) {
  Config config = new Config();
  config.setMessageTimeoutSecs(120);
  TopologyBuilder b = new TopologyBuilder();
  b.setSpout("TwitterSampleSpout", new TwitterSampleSpout());
  b.setBolt("WordSplitterBolt", new WordSplitterBolt(5)).shuffleGrouping("TwitterSampleSpout");
  b.setBolt("IgnoreWordsBolt", new IgnoreWordsBolt()).shuffleGrouping("WordSplitterBolt");
  b.setBolt("WordCounterBolt", new WordCounterBolt(10, 5 * 60, 50)).shuffleGrouping("IgnoreWordsBolt");
  final LocalCluster cluster = new LocalCluster();
  cluster.submitTopology(TOPOLOGY_NAME, config, b.createTopology());
  Runtime.getRuntime().addShutdownHook(new Thread() {
    @Override
    public void run() {
      cluster.killTopology(TOPOLOGY_NAME);
      cluster.shutdown();
    }
  });
}

代码示例来源：origin: P7h/StormTweetsSentimentAnalysis

public static final void main(final String[] args) throws Exception {
  try {
    final Config config = new Config();
    config.setMessageTimeoutSecs(120);
    config.setDebug(false);