Storm Tick Tuple来自喷口

Answer 1

只有螺栓可以接收刻度元组。喷注只能发出元组。

我假设您正在尝试从spout中执行“read”，以便发出一个新的元组。

例如，若要Hibernate50毫秒，请读取：

@Override
public void nextTuple() {
   try {
      String message = _mqClient.getMessage();
      if (message != null) {
         _collector.emit(new Values(message));
      } 
      // sleep for 50 milliseconds
      Utils.sleep(50);
   } catch (Exception e) {
      _collector.reportError(e);
      LOG.error("MQ spout error {}", e);
   }
}