exception - mongodb casbah, check connection -


i'm using akka-http , casbah interacting mongodb. can't catch exception thrown com.mongodb.connection.socketstreamhelper , therefore can't complete request , hangs long time... don't understand why it's not possible catch, may exception thrown in thread, or smth else.. sorry, don't know code apply question

stacktrace printed though:

[info] starting application server in background ... server starting adstorage.akka.main.main() server listening transport dt_socket @ address: 5005 [success] total time: 1 s, completed apr 6, 2017 12:54:15 pm > server[error] slf4j: failed load class "org.slf4j.impl.staticloggerbinder". server[error] slf4j: defaulting no-operation (nop) logger implementation server[error] slf4j: see http://www.slf4j.org/codes.html#staticloggerbinder further details. server server started 8080... server[error] apr 06, 2017 12:54:34 pm com.mongodb.diagnostics.logging.jullogger log server[error] info: cluster created settings {hosts=[localhost:27017], mode=single, requiredclustertype=unknown, serverselectiontimeout='30000 ms', maxwaitqueuesize=500} server[error] apr 06, 2017 12:54:34 pm com.mongodb.diagnostics.logging.jullogger log server[error] info: exception in monitor thread while connecting server localhost:27017 server[error] com.mongodb.mongosocketopenexception: exception opening socket server[error]   @ com.mongodb.connection.socketstream.open(socketstream.java:63) server[error]   @ com.mongodb.connection.internalstreamconnection.open(internalstreamconnection.java:114) server[error]   @ com.mongodb.connection.defaultservermonitor$servermonitorrunnable.run(defaultservermonitor.java:128) server[error]   @ java.lang.thread.run(thread.java:745) server[error] caused by: java.net.connectexception: connection refused (connection refused) server[error]   @ java.net.plainsocketimpl.socketconnect(native method) server[error]   @ java.net.abstractplainsocketimpl.doconnect(abstractplainsocketimpl.java:350) server[error]   @ java.net.abstractplainsocketimpl.connecttoaddress(abstractplainsocketimpl.java:206) server[error]   @ java.net.abstractplainsocketimpl.connect(abstractplainsocketimpl.java:188) server[error]   @ java.net.sockssocketimpl.connect(sockssocketimpl.java:392) server[error]   @ java.net.socket.connect(socket.java:589) server[error]   @ com.mongodb.connection.socketstreamhelper.initialize(socketstreamhelper.java:50) server[error]   @ com.mongodb.connection.socketstream.open(socketstream.java:58) server[error]   ... 3 more server[error]  server[error] apr 06, 2017 12:55:50 pm com.mongodb.diagnostics.logging.jullogger log server[error] info: no server chosen readpreferenceserverselector{readpreference=primary} cluster description clusterdescription{type=unknown, connectionmode=single, all=[serverdescription{address=localhost:27017, type=unknown, state=connecting, exception={com.mongodb.mongosocketopenexception: exception opening socket}, caused {java.net.connectexception: connection refused (connection refused)}}]}. waiting 30000 ms before timing out

[added]

i try mongo-scala-driver.

val client = mongoclient("mongodb://localhost:27017")     client.getdatabase("profile_5").getcollection("campaigns").find[document](document.parse(json.obj(       "name" -> "asd"     ).tostring())).subscribe(new observer[document] {       def onerror(e: throwable): unit = println(s"onerror: ${e.getmessage}")       def oncomplete(): unit = println("oncomplete")       def onnext(result: document): unit = println(s"onnext: $result")     })

result is:

> mongo 13:09:02.573 [main] info org.mongodb.driver.cluster - cluster created settings {hosts=[localhost:27017], mode=single, requiredclustertype=unknown, serverselectiontimeout='30000 ms', maxwaitqueuesize=500} mongo 13:09:02.675 [main] debug org.mongodb.driver.cluster - updating cluster description  {type=unknown, servers=[{address=localhost:27017, type=unknown, state=connecting}] mongo 13:09:02.770 [cluster-clusterid{value='58e7653e7285c53714b770e5', description='null'}-localhost:27017] debug org.mongodb.driver.connection - closing connection connectionid{localvalue:1} mongo 13:09:02.778 [cluster-clusterid{value='58e7653e7285c53714b770e5', description='null'}-localhost:27017] info org.mongodb.driver.cluster - exception in monitor thread while connecting server localhost:27017 mongo com.mongodb.mongosocketopenexception: exception opening socket mongo   @ com.mongodb.connection.asynchronoussocketchannelstream$opencompletionhandler.failed(asynchronoussocketchannelstream.java:253) mongo   @ sun.nio.ch.invoker.invokeunchecked(invoker.java:128) mongo   @ sun.nio.ch.invoker$2.run(invoker.java:218) mongo   @ sun.nio.ch.asynchronouschannelgroupimpl$1.run(asynchronouschannelgroupimpl.java:112) mongo   @ java.util.concurrent.threadpoolexecutor.runworker(threadpoolexecutor.java:1142) mongo   @ java.util.concurrent.threadpoolexecutor$worker.run(threadpoolexecutor.java:617) mongo   @ java.lang.thread.run(thread.java:745) mongo caused by: java.net.connectexception: connection refused mongo   @ sun.nio.ch.unixasynchronoussocketchannelimpl.checkconnect(native method) mongo   @ sun.nio.ch.unixasynchronoussocketchannelimpl.finishconnect(unixasynchronoussocketchannelimpl.java:252) mongo   @ sun.nio.ch.unixasynchronoussocketchannelimpl.finish(unixasynchronoussocketchannelimpl.java:198) mongo   @ sun.nio.ch.unixasynchronoussocketchannelimpl.onevent(unixasynchronoussocketchannelimpl.java:213) mongo   @ sun.nio.ch.epollport$eventhandlertask.run(epollport.java:293) mongo   ... 1 common frames omitted mongo 13:09:02.780 [cluster-clusterid{value='58e7653e7285c53714b770e5', description='null'}-localhost:27017] debug org.mongodb.driver.cluster - updating cluster description  {type=unknown, servers=[{address=localhost:27017, type=unknown, state=connecting, exception={com.mongodb.mongosocketopenexception: exception opening socket}, caused {java.net.connectexception: connection refused}}] mongo 13:09:02.973 [main] info org.mongodb.driver.cluster - no server chosen readpreferenceserverselector{readpreference=primary} cluster description clusterdescription{type=unknown, connectionmode=single, serverdescriptions=[serverdescription{address=localhost:27017, type=unknown, state=connecting, exception={com.mongodb.mongosocketopenexception: exception opening socket}, caused {java.net.connectexception: connection refused}}]}. waiting 30000 ms before timing out mongo ... finished exit code 0

i expected see onerror there's nothing...


Comments

Post a Comment

Popular posts from this blog

commonjs - How to write a typescript definition file for a node module that exports a function? -

consider, toml node module can use: // toml.d.ts declare module toml { export function parse(value:string):any; } declare module "toml" { export = toml; } then: /// <reference path="../../../../../defs/toml/toml.d.ts"/> import toml = require('toml'); toml.parse(...); however, node module export single function, such 'glob' ( https://github.com/isaacs/node-glob ). the node usage of module be: var glob = require("glob") glob("*.js", {}, callback(err, files) { ... }); you'd naively expect this: // glob.d.ts declare function globs(paths:string, options:any, callback:{(err:any, files:string[]):void; ...but because typescripts 'import' semantics bit strange, seems can use 'import .. = require()' statement alias modules . trying call: /// <reference path="../../../../../defs/glob/glob.d.ts"/> import blog = require('glob'); results in: error ts2072: mod
Read more

openid - Okta: Failed to get authorization code through API call -

i'm integrating okta own idp server using okta's api. i'm implementing authorization code flow following steps below: in own server, use /api/v1/authn endpoint sessiontoken. use sessiontoken obtain authorization calling endpoint: /oauth2/v1/authorize?client_id=" + clientid + "&sessiontoken=" + sessiontoken + "&response_type=code&response_mode=query&scope=openid&redirect_uri=" + redirecturl + "&state=evanyang&nonce=" it's supposed return response status code 302 , location header containing redirect url code value. however, keep getting response status code 200 , without location header, html body saying "you using unsupported browser." , "javascript disabled on browser." according api documentation: http://developer.okta.com/docs/api/resources/oidc.html#authentication-request , sessiontoken parameter sufficient this: an okta one-time sessiontoken. allows api-based
Read more

thorough guide for profiling racket code -

did googling ("racket profiling", "racket measure performance"), didn't find , there no examples in docs. did google "profile" search on htdp - no luck. (profile (f ...)) output isn't obvious other small snippets. ideally want python's python -m cprofile usage examples. when search "python profiling", both duckduckgo , google give top result: 26.4. python profilers . (although scanned quickly, seems more of reference "thorough usage guide" examples. if had else in mind, perhaps please link that?) the equivalent racket documentation be: profile: statistical profiler . a usage example: #lang racket (require profile) (profile-thunk (thunk (function-to-profile arg0 arg1) )) here (thunk e) convenience (lambda () e) . bigger example: #lang racket (module mod racket (provide f) (define (f) (for/list ([i 10000]) i))) (require (prefix-in mod: 'mod)) (define (f) (for ([i 10000
Read more