Skip to content

Commit

Permalink
Spelling fix: timout => timeout
Browse files Browse the repository at this point in the history
  • Loading branch information
JoshRosen committed Nov 14, 2014
1 parent 3200c33 commit 0f0913b
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -918,10 +918,10 @@ private[nio] class ConnectionManager(
}
}

val timoutTaskHandle = ackTimeoutMonitor.newTimeout(timeoutTask, ackTimeout, TimeUnit.SECONDS)
val timeoutTaskHandle = ackTimeoutMonitor.newTimeout(timeoutTask, ackTimeout, TimeUnit.SECONDS)

val status = new MessageStatus(message, connectionManagerId, s => {
timoutTaskHandle.cancel()
timeoutTaskHandle.cancel()
s match {
case scala.util.Failure(e) =>
// Indicates a failure where we either never sent or never got ACK'd
Expand Down

0 comments on commit 0f0913b

Please sign in to comment.