c# - NServiceBus Saga handle a message-type multiple times gives concurrency exception -



c# - NServiceBus Saga handle a message-type multiple times gives concurrency exception -

we have nservicebus implementation handles multiple message-types:

public class statecoordinator : saga<messagedata>, iamstartedbymessages<createmessage>, iamstartedbymessages<confirmmessage>

messagedata this:

public class flowdata : icontainsagadata { [unique] public guid mappingid { get; set; } public guid id { get; set; } public string originalmessageid { get; set; } public string originator { get; set; } public list<messagepart> messageparts { get; set; } } public messagepart { public int id { get; set; } public string status { get; set; } }

the createmessage has messagepart added messageparts in handler. confirmmessage updates status of particular messagepart.

this scenario:

1) first createmessage received. creates saga in raven , adds messagepart (with status "1") messageparts.

2) first confirmmessage received. updates status of first added messagepart in saga "1 2". vissible in browser when going document in ravendb.

3) sec createmessage received. adds sec messagepart messageparts. when looking data, status of first messagepart still "1" , not "1 2" , throws concurrency-exception (the actualetag not equals expectedetag):

a first chance exception of type 'raven.abstractions.exceptions.concurrencyexception' occurred in raven.client.lightweight additional information: set attempted on document 'flow/79a7ee20-f090-4648-9b62-a3da00d87c93' using non current etag

it looks saga-data cached per message-type. so? there solution?

note:

we using multiple iamstartedbymessages when confirmmessage before createmessage, message added queue until createmessage handled.

after few tests can there not real problem. think can't solve concurrency-exceptions (this exception logged) when exception occurs, message send queue retry.

i afraid logic handle executed twice guess because i've transactions enabled, not case. example: 1 of actions send message bus persist event (perister-queue). action called before exceptions occurs (after handle, info saved in saga , exceptions thrown) there no message added persister-queue. after retry of message succeeds (this updates info there isn't concurrency-exception anymore), persister-message added persister-queue.

conclusion: not real problem, line in log-file.

c# nservicebus bus saga nservicebus-sagas

Comments

Post a Comment

Popular posts from this blog

Delphi change the assembly code of a running process -

Delphi change the assembly code of a running process - i'm trying alter address 00741fa5 has push test.009e721c . alter push test.009e71c8 . procedure callback; asm force $9e71c8 end; procedure tform2.btn1click(sender: tobject); var ppid :dword; pprocess : cardinal; begin getwindowthreadprocessid(findwindow(nil,pchar('test')), @ppid); pprocess := openprocess(process_all_access, false, ppid); injectasm(pprocess, $741fa5, 10, integer(@callback), 0); end; here injectasm function (with error checking) function injectasm(process: longword; injectaddress, injectsize, codeaddress, codesize : integer): pointer; var csize, rsize : integer; replaced : array of byte; jmp : array [0..4] of byte; jmpaddress : integer; nopv : byte; : integer; nbr: ulong_ptr; begin //injectsize must equal or greater 5, because need space our //(far) jmp wwxxyyzz instruction //if there's no space, inject in place of few instructions if injectsize ...
Read more

json - Hibernate and Jackson (java.lang.IllegalStateException: Cannot call sendError() after the response has been committed) -

json - Hibernate and Jackson (java.lang.IllegalStateException: Cannot call sendError() after the response has been committed) - hello have problem hibernate , jackson. have 2 pojos @entity @table(name = "users") public class user implements serializable { static final long serialversionuid = 4235637833262722256l; @id @generatedvalue private int id; @column(name = "creation_date") private date creationdate; @column(name = "first_name") private string firstname; @column(name = "last_name") private string lastname; @version @column(name = "version") private int version; @column(name = "e_mail") private string email; @column(name = "enabled") private boolean enabled; @column(name = "login") private string login; @column(name = "password") private string password; @jsonmanagedreference("role") @onetomany(mappedby = "user", cascade = cascadetype.all,fetch = fetchtyp...
Read more

C++ 11 "class" keyword -

C++ 11 "class" keyword - i've started using c++ 11 little bit more , have few questions on special uses of class keyword. know it's used declare class, there's 2 instances have seen don't understand: method<class t>(); and class class_name *var; why precede typename keyword class in first example, , keyword pointer in sec example? that known elaborated type specifier , necessary when class name "shadowed" or "hidden" , need explicit. class t { }; // love of god don't t t; t t2; if compiler smart, give these warnings: main.cpp:15:5: error: must utilize 'class' tag refer type 't' in scope t t2; ^ class main.cpp:14:7: note: class 't' hidden non-type declaration of 't' here t t; ^ if class not defined, deed forwards declaration. for example: template <typename t> void method() { using type = typename t::value_type; } method...
Read more