निवर्तमान कनेक्शन धारा को बंद कर दिया

Question

मैं व्यवहार के साथ एक अभिनेता है:

def receive: Receive = { 
    case Info(message) => 
     val res = send("INFO:" + message) 
     installAckHook(res) 
    case Warning(message) => 
     val res = send("WARNING:" + message) 
     installAckHook(res) 
    case Error(message) => 
     val res = send("ERROR:" + message) 
     installAckHook(res) 
    } 

private def installAckHook[T](fut: Future[T]): Unit = { 
    val answerTo = sender() 

    fut.onComplete { 
     case Success(_) => answerTo ! "OK" 
     case Failure(ex) => answerTo ! ex 
    } 
    } 


    private def send(message: String): Future[HttpResponse] = { 
    import context.system 
    val payload: Payload = Payload(text = message, 
     username = slackConfig.username, icon_url = slackConfig.iconUrl, 
     icon_emoji = slackConfig.iconEmoji, channel = slackConfig.channel) 
     .validate 
    Http().singleRequest(RequestBuilding.Post(slackConfig.hookAddress, payload)) 
    } 

और एक परीक्षण

val actorRef = system.actorOf(SlackHookActor.props(SlackEndpointConfig(WebHookUrl,iconEmoji = Some(":ghost:")))) 
actorRef ! Error("Some error message") 
actorRef ! Warning("Some warning message") 
actorRef ! Info("Some info message") 
receiveN(3) 

और afterAll() विधि में मैं TestKit का उपयोग कर अभिनेता सिस्टम पर एक बंद करो।

यह काम करता है, अनुरोध सर्वर के लिए बनाता है, लेकिन वहाँ अक्का से त्रुटियाँ हैं हिस्सा धाराओं:

[ERROR] [06/26/2015 11:34:55.118] [SlackHookTestingSystem-akka.actor.default-dispatcher-10] [ActorSystem(SlackHookTestingSystem)] Outgoing request stream error (akka.stream.AbruptTerminationException) 
[ERROR] [06/26/2015 11:34:55.120] [SlackHookTestingSystem-akka.actor.default-dispatcher-13] [ActorSystem(SlackHookTestingSystem)] Outgoing request stream error (akka.stream.AbruptTerminationException) 
[ERROR] [06/26/2015 11:34:55.121] [SlackHookTestingSystem-akka.actor.default-dispatcher-8] [ActorSystem(SlackHookTestingSystem)] Outgoing request stream error (akka.stream.AbruptTerminationException) 

लगता है की तरह के बाद से मैं एक भविष्य बाहर जाने वाले कनेक्शन पहले से ही बंद किया जाना चाहिए पूरा है, तो है यह एक बग है या मैं sth याद कर रहा हूँ?

Answer 1

तुम भी नीचे http कनेक्शन पूल की तरह

Http().shutdownAllConnectionPools().onComplete{ _ => 
    system.shutdown() 
} 

कुछ बंद करने के लिए, की जरूरत है हो सकता है कि अक्का http testkit कुछ सहायकों