raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

fix typo: excpetion -> exception (#26352)

Browse source
This commit is contained in:
László van den Hoek 2019-02-11 17:25:05 +01:00 • committed by Christopher Batey
parent f0b976d557
commit 8e2d378228
3 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor-tests/src/test/scala/akka/actor/TypedActorSpec.scala
View file

@ -269,7 +269,7 @@ class TypedActorSpec extends AkkaSpec(TypedActorSpec.config)
TypedActor(system).stop(null) should ===(false)
}
"throw an IllegalStateExcpetion when TypedActor.self is called in the wrong scope" in {
"throw an IllegalStateException when TypedActor.self is called in the wrong scope" in {
filterEvents(EventFilter[IllegalStateException]("Calling")) {
(intercept[IllegalStateException] {
TypedActor.self[Foo]

2
akka-actor/src/main/mima-filters/2.5.21.backwards.excludes Normal file
View file

@ -0,0 +1,2 @@
# Typo in Akka internal method - PR #26352
ProblemFilters.exclude[DirectMissingMethodProblem]("akka.pattern.AskableActorRef.recipientTerminatedExcpetion")

6
akka-actor/src/main/scala/akka/pattern/AskSupport.scala
View file

@ -284,7 +284,7 @@ object AskableActorRef {
/**
* INTERNAL API
*/
@InternalApi private[akka] def recipientTerminatedExcpetion(recipient: Any, message: Any, sender: ActorRef): AskTimeoutException = {
@InternalApi private[akka] def recipientTerminatedException(recipient: Any, message: Any, sender: ActorRef): AskTimeoutException = {
new AskTimeoutException(s"Recipient [$recipient] had already been terminated. " +
messagePartOfException(message, sender))
}
@ -327,7 +327,7 @@ final class AskableActorRef(val actorRef: ActorRef) extends AnyVal {
private[pattern] def internalAsk(message: Any, timeout: Timeout, sender: ActorRef) = actorRef match {
case ref: InternalActorRef if ref.isTerminated ⇒
actorRef ! message
Future.failed[Any](AskableActorRef.recipientTerminatedExcpetion(actorRef, message, sender))
Future.failed[Any](AskableActorRef.recipientTerminatedException(actorRef, message, sender))
case ref: InternalActorRef ⇒
if (timeout.duration.length <= 0)
Future.failed[Any](AskableActorRef.negativeTimeoutException(actorRef, message, sender))
@ -359,7 +359,7 @@ final class ExplicitlyAskableActorRef(val actorRef: ActorRef) extends AnyVal {
case ref: InternalActorRef if ref.isTerminated ⇒
val message = messageFactory(ref.provider.deadLetters)
actorRef ! message
Future.failed[Any](AskableActorRef.recipientTerminatedExcpetion(actorRef, message, sender))
Future.failed[Any](AskableActorRef.recipientTerminatedException(actorRef, message, sender))
case ref: InternalActorRef ⇒
if (timeout.duration.length <= 0) {
val message = messageFactory(ref.provider.deadLetters)