c# - Azure Service Bus timeout exception with NancyFX -


i have nancyfx api, , when 1 of endpoints hit, need kick of longer running asynchonous task that's decoupled endpoint itself. i'm trying use azure service bus queue.

i'm writing message queue when nancyfx endpoint hit. can subscribe , read queue other nancyfx (i tested linqpad).

however, if try subscribe nancyfx app, timeout exception within second or 2 starting app. i'm doing in thread kicked off nancyfx bootstrapper.applicationstartup override.

i'm unsure why different doing not in nancyfx app. can't see of relevance in web.config file.

below code i'm using subscribe queue ...

var tokenprovider = tokenprovider.createsharedaccesssignaturetokenprovider("main", accesskey); var factory = await messagingfactory.createasync("sb://myapp.servicebus.windows.net", tokenprovider); var receiver = await factory.createmessagereceiverasync("myqueue");  receiver.onmessage(bm => {     // here }, new onmessageoptions {     maxconcurrentcalls = 1, });

below exception ...

system.servicemodel.faultexception`1[system.servicemodel.exceptiondetail]: timeout has occurred during operation. b6b8e25a-714f-4f55-8a79-91e390f47a96_g25 (fault detail equal exceptiondetail, created includeexceptiondetailinfaults=true, value is: system.timeoutexception: timeout has occurred during operation. ).

and here callstack when caught in debugger ...

microsoft.servicebus.dll!microsoft.servicebus.messaging.sbmp.duplexrequestbindingelement.duplexrequestsessionchannel.throwiffaultmessage(system.servicemodel.channels.message wcfmessage) line 463 c# microsoft.servicebus.dll!microsoft.servicebus.messaging.sbmp.duplexrequestbindingelement.duplexrequestsessionchannel.handlemessagereceived(system.iasyncresult result) line 313 c# microsoft.servicebus.dll!microsoft.servicebus.messaging.sbmp.duplexrequestbindingelement.duplexrequestsessionchannel.onmessagereceived(system.iasyncresult result) line 381 c# system.servicemodel.internals.dll!system.runtime.asyncresult.complete(bool completedsynchronously) unknown system.servicemodel.dll!system.servicemodel.channels.transportduplexsessionchannel.tryreceiveasyncresult.onreceive(system.iasyncresult result) unknown system.servicemodel.internals.dll!system.runtime.fx.asyncthunk.unhandledexceptionframe(system.iasyncresult result) unknown system.servicemodel.internals.dll!system.runtime.asyncresult.complete(bool completedsynchronously) unknown system.servicemodel.dll!system.servicemodel.channels.synchronizedmessagesource.receiveasyncresult.onreceivecomplete(object state) unknown system.servicemodel.dll!system.servicemodel.channels.sessionconnectionreader.onasyncreadcomplete(object state) unknown system.servicemodel.internals.dll!system.runtime.fx.asyncthunk.unhandledexceptionframe(system.iasyncresult result) unknown system.dll!system.net.lazyasyncresult.complete(system.intptr usertoken) unknown system.dll!system.net.lazyasyncresult.protectedinvokecallback(object result, system.intptr usertoken) unknown system.dll!system.net.security._sslstream.processframebody(int readbytes, byte[] buffer, int offset, int count, system.net.asyncprotocolrequest asyncrequest) unknown system.dll!system.net.security._sslstream.readframecallback(system.net.asyncprotocolrequest asyncrequest) unknown system.dll!system.net.asyncprotocolrequest.completerequest(int result) unknown system.dll!system.net.fixedsizereader.checkcompletionbeforenextread(int bytes) unknown system.dll!system.net.fixedsizereader.readcallback(system.iasyncresult transportresult) unknown system.servicemodel.internals.dll!system.runtime.asyncresult.complete(bool completedsynchronously) unknown system.servicemodel.dll!system.servicemodel.channels.connectionstream.ioasyncresult.onasynciocomplete(object state) unknown system.dll!system.net.sockets.socketasynceventargs.oncompleted(system.net.sockets.socketasynceventargs e) unknown system.dll!system.net.sockets.socketasynceventargs.finishoperationsuccess(system.net.sockets.socketerror socketerror, int bytestransferred, system.net.sockets.socketflags flags) unknown system.dll!system.net.sockets.socketasynceventargs.completionportcallback(uint errorcode, uint numbytes, system.threading.nativeoverlapped* nativeoverlapped) unknown mscorlib.dll!system.threading._iocompletioncallback.performiocompletioncallback(uint errorcode, uint numbytes, system.threading.nativeoverlapped* poverlap) unknown [native managed transition]

the exception got indication of client not being able go past asb gateway talk backend. use provided tracking id (b6b8e25a-714f-4f55-8a79-91e390f47a96_g25) open support case. in case exception persists, try different namespace see if rules out.


-

Comments

Post a Comment

Popular posts from this blog

amazon web services - S3 Pre-signed POST validate file type? -

i know it's possible put limit on file size content-length-range header. possible validate file type? https://docs.aws.amazon.com/amazons3/latest/dev/httppostforms.html#policyconditions i see there content-type header, if set say, audio/mp3 allow mp3 files , return error if file not mp3? i found previous question answers mention validating file size: s3 direct upload restricting file size , type you can specify content-type @ post request. you can specify @ signature, post must done content-type: { "expiration": "2007-12-01t12:00:00.000z", "conditions": [ {"acl": "public-read" }, {"bucket": "johnsmith" }, {"content-type: "audio/mp3"} ] } creating html form (using aws signature version 4) edit: @ previous question found, checking content-type.
Read more

c# - Check Keyboard Input Winforms -

i wondering if instead of doing this protected override void onkeydown(keyeventargs e) { if (e.keycode == keys.a) console.writeline("the key down."); } i set bool method , this: if(keydown(keys.a)) // whatever here i've been sitting here ages trying figure out how it. can't wrap head around it. in case wondering, plan call bool inside different method, check input. since want perform action after pressing key, using keydown event enough. but in cases suppose want check if specific key down in middle of process, can use getkeystate method way: [dllimport("user32.dll", charset = charset.auto, exactspelling = true)] public static extern short getkeystate(int keycode); public const int key_pressed = 0x8000; public static bool iskeydown(keys key) { return convert.toboolean(getkeystate((int)key) & key_pressed); } you should know, each time check key state using example iskeydown(keys.a) method returns true if ke...
Read more