akka http - Outgoing connection stream closed -

-

i have actor behaviour:

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))   }

and test

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)

and in afterall() method shutdown on actor system using testkit.

it works, request makes server, there errors akka streams part:

[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)

seems since have future completed outgoing connection should closed, bug or missing sth?

you need shut down http connection pools, like

http().shutdownallconnectionpools().oncomplete{ _ =>   system.shutdown() }

maybe akka http testkit provides helpers


Comments

Post a Comment

Popular posts from this blog

python - No exponential form of the z-axis in matplotlib-3D-plots -

-
Image
i have similar problem described in how prevent numbers being changed exponential form in python matplotlib figure : i don't want (in special case) weird scientific formatting of axis. problem different have problem @ z -axis. 2-d plots can use ax.get_yaxis().get_major_formatter().set_useoffset(false) . , there no function ax.get_zaxis() what use format z -axis same way? edit: example: from mpl_toolkits.mplot3d import axes3d import numpy np import sys import matplotlib import matplotlib.pyplot pyplot def func(xi, ti): res = 10e3 + np.cos(ti) * np.sin(xi) return res if __name__ == '__main__': timespacing = 20 timestart = 0 timeend = 1 time = np.linspace(timestart, timeend, timespacing) widthspacing = 50 widthstart = 0 widthend = 3 width = np.linspace(widthstart, widthend, widthspacing) reslist = [] matplotlib.rcparams['legend.fontsize'] = 10 fig = pyplot.figure() ax = fig.gca(projection = '3d...
Read more

php - Best Light server (Linux + Web server + Database) for Raspberry Pi -

-
i install web server database on raspberry pi (little computer). computer has 1gb ram. i want know best combination: linux distribution , web server , dbms run local server multiple users minimal latency, use php on server. , best settings performance , not have bugs (memory usage, disable plugin, disable service, etc)? i thought light debian , lighttpd server , sqlite database. solution? i think lighttpd + sqlite great choice. linux distro, debian @ centos or tiny core linux , although i'm not sure of compatibility pi. obviously, can't go wrong raspbian if want use in production , more stable performance, few more pi's , set them in cluster .
Read more

c# - "Newtonsoft.Json.JsonSerializationException unable to find constructor to use for types" error when deserializing class -

-
i developing app in xamarin android. have splash screen serialize class , pass mainactivity using intent . when try deserialize in mainactivity error message : "serializationexception unable find constructor use types" serialization : void loaddata() { currency currency = new currency(this); intent = new intent(this, typeof(mainactivity)); intent.putextra("currency", newtonsoft.json.jsonconvert.serializeobject(currency)); startactivity(intent); } deserialization : cur = newtonsoft.json.jsonconvert.deserializeobject<currency> (intent.getstringextra("currency")); // error here class constructor : public currency(context context) { thiscontext = context; } i began experiencing problem after added parameter context context constructor. has caused this? how can solve it? possible serialize/deserialize class has parameters? you need have empty constructor in currency class in order deserialize it. ...
Read more