c# - Best practice for ServiceBus message versioning -

-

i setting system transport messages between several internal services on servicebus topics. messages hold serialized objects. model objects defined quite complex trees of classes. means not practical maintain duplet versions of model structures in code.

we expect model structure change have exposed model version property on brokered message.

what best way handle transition when need upgrade model version?

i don't think need support 2 parallell model versions. concerned don't loose messages during transition. assume strategy upgrade sending services first , let subscribers continue process messages. when messages of previous version processed, time upgrade subscribing services.

what best mechanism skipping messages new version listening service not handling?

  1. i know go old school , define parallell model versions using schemas json or xml, making possible listening service handle parallell versions. cumbersome, want avoid that.

  2. i noticed brokeredmessage has defer method. useful? looked promising until realized messages "moved" live queue separate state need pulled referencing them key. not practical.

  3. is possible postpone message modifying delivery time? couple of minutes fine. if same service still running time can postponed once again. (a working code example appreciated!)

  4. do need create separate subscriptions based on model version? far allow different message types travel on same topic call redesign.

i have been looking @ similar yet implement can't provide full guidance, answer question on #3... have messages have flag re-queue message run again, e.g. process run every 5 minutes.

so during process extract object brokeredmessage:

  var myobject = receivedmessage.getbody<mymodel>();

i complete message remove queue , create new brokeredmessage based on object , can set scheduledenqueuetimeutc field in future.

 brokeredmessage brokeredmsg = new brokeredmessage(myobject);  brokeredmsg.scheduledenqueuetimeutc = datetime.utcnow.addminutes(5);  client.send(brokeredmsg);

so if want process 1 model version @ time, assign version number model , code in processor model number. if model higher, re-queue future time (until have updated code). if lower (a missed message), perhaps have exception handling.


Comments

Post a Comment

Popular posts from this blog

javascript - Any ideas when Firefox is likely to implement lengthAdjust and textLength? -

-
any ideas when firefox implement lengthadjust andtextlength?..... working svg application. lengthadjust , textlength working fine in chrome not working in fire fox . <svg viewbox = "0 0 500 300" version = "1.1"> <defs> <path id="s3" d="m 10,90 q 100,15 200,70" /> </defs> <g> <text font-size = "20"> <textpath xlink:href="#s3" textlength="205"> short text</textpath> </text> <use xlink:href="#s3" fill="none" stroke="black" stroke-width="1"/> </g> </svg> this implemented in firefox text elements (not textpath or tspan) in case that's ok though can move attribute text element. <svg viewbox = "0 0 500 300" version = "1.1"> <defs>
Read more

matlab - "Contour not rendered for non-finite ZData" -

-
i'm trying plot frequency characteristic equation using ezplot, matlab gives following warning, "contour not rendered non-finite zdata". have used command plot frequency equations warning , plot display empty , not change axis range well. can please help. appreciated. here's code i'm using. % transfer matrix case-i, thin rotor clear all; clc; ei = 1626; l = 0.15; m = 0.44108; = 2.178*10^-4; i_p = 2.205*10^-5; itr = 0.24; i_pr = 0.479; syms p n; f = [1 l*1i l^2/(2*ei)*1i l^3/(6*ei); 0 1 l/ei -l^2/(2*ei)*1i; 0 0 1 -l*1i; 0 0 0 l]; p = [ 1 0 0 0; 0 1 0 0; 0 -it*p^2+i_p*n*p 1 0; -m*p^2 0 0 1]; p_r = [1 0 0 0; 0 1 0 0; 0 -itr*p^2+i_pr*n*p 1 0; -m*p^2 0 0 1]; = f*p*f*p*f*p*f; b = p_r*f*p*f*p*f; r = a(1,2)/a(1,4); a12_p = 0; a22_p = a(2,2)-r*a(2,4); a32_p = a(3,2)-r*a(3,4); a42_p = a(4,2)-r*a(4,4); ap(2,2) = a22_p; ap(3,2) = a32_p; ap(4,2) = a42_p; ap(4,4) = 1; c = b*ap; m = [c(3,2) c(3,4); c(4,2) c(4,
Read more

delphi - Indy UDP Read Contents of Adata -

-
i using indy udp server read string of data. however, not know how work adata parameter. can around converting binary using bytetobin function below , convert hex using bintohex1 . feel stupid , works slow. know how can directly results without 2 conversions? thanks!! here codes: procedure tform1.idudpserver1udpread(athread: tidudplistenerthread; const adata: tidbytes; abinding: tidsockethandle); var buf: tidbytes; buffer: string; data_received: string; begin if bytestostring(adata) <> 'hello' begin buffer := hextostring('00'); setlength(buf, length(buffer)); copytidstring(buffer, buf, 0); abinding.sendto(abinding.peerip, abinding.peerport, buf); data_received := bintohex1(bytetobin(adata[1]) + bytetobin(adata[2]) + bytetobin(adata[3]) + bytetobin(adata[4]) + bytetobin(adata[5]) + bytetobin(adata[6]) + bytetobin(adata[7]) + bytetobin(adata[8]) + bytetobin(adata[9]) + bytetobin(adata[10]) + bytetobin(adata[11
Read more