Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS does not have any effect?

[Binita Bharati]

Hi all,

Why isnt my Spout's fail method being invoked? I have the following
topology:

Spout1 -> Bolt1

Spout1 emits anchored tuples and has overidden fail method.

public void nextTuple() {

logger.info("nextTuple: entered");

String emitWord = sentences[random.nextInt(MAX_RANDOM)];

 UUID msgId = UUID.randomUUID();

 logger.info("nextTuple: emitting word = "+emitWord +", msgId = "+msgId);

 collector.emit(new Values(emitWord), msgId);

  }