sql server - Service Broker messages inside a transaction -


i writing stored procedure perform following operations:

  1. begin transaction
  2. perform tasks
  3. use service broker kick-off background process
  4. wait response message (with job status) service broker
  5. commit or rollback transaction, depending on response message

the issue service broker communication not working inside transaction:

  • the message queue has activation enabled, associated stored procedure not executed (print statements in stored procedure not written errorlog file)
  • receive command times out

here's extract of code:

-- comment out following line make work begin tran t1  declare @update_msg xml([sb].[service_broker_xxx_schemas]) = ' <request xmlns="xxx">   <table xmlns="xxx">     <fields>       xxx     </fields>   </table>   <requested_by>xxx</requested_by> </request>'  declare @conversation_handle uniqueidentifier             ,@message_body varbinary(max)             ,@message_type_name nvarchar(256)             ,@timestamp datetime2          begin dialog conversation @conversation_handle         service [xxx_initiating_service]         service 'xxx_target_service'         on contract xxx_contract         encryption = off;          send on conversation @conversation_handle         message type [xxx_command](@update_msg);   select * sys.transmission_queue with(nolock) --print @conversation_handle  waitfor (     -- handle 1 message @ time     receive top(1)   @conversation_handle = conversation_handle     -- identifier of dialog message received on                     ,@message_type_name = message_type_name                     ,@message_body=message_body                     -- message contents                     ,@timestamp = getdate()                     [sb].[xxx_initiator_queue]                     conversation_handle = @conversation_handle ), timeout 1000  -- if queue empty 1 second, give update , go away if @@rowcount > 0 begin         select @@rowcount, @message_type_name, convert(xml, @message_body)         end conversation @conversation_handle; end else begin     print 'did not receive response service broker.' end  -- comment out following line make work commit tran t1

what correct way implement service broker messaging inside transaction?

sending messages via service broker transactional. is, if begin tran; send;, message isn't sent until commit.


-

Comments

Post a Comment

Popular posts from this blog

javascript - Thinglink image not visible until browser resize -

Image
i trying repurpose pre-existing theme, includes drop down menu displays image. trying embed thinglink drop down menu's content section, not visible until resize browser window. here menu looks like: then when clicked, can see empty space image should show: then when browser resized, image appears: this code content of menu: <div class="ajax_accordion_content" style="display: none;"> <div class="report-detail"> <table border="0" cellpadding="0" cellspacing="0" width="100%" class="table_basic"> <tbody> <!-- thinglink image embedded --> <img style="max-width: 100%;" src="http://cdn.thinglink.me/api/image/832705713204625409/1024/10/scaletowidth#tl-832705713204625409;1043138249'" class="alwaysthinglink"/> <script async charset="utf-8" src="http://cdn.thinglink.me/jse/embed.j...
Read more

firebird - Error "invalid transaction handle (expecting explicit transaction start)" executing script from Delphi -

i'm developing update app delphi 10. i'm running windows 7 64x, firebird 2.5.1.26351 32x. execution order: checks current version(select statement firebird database) downloads update(via ftp) apply it(.exe files, , execute .sql) error code -901 pops out when try execute .sql files. know there incompatibility issue w7 64x , fdb 32x, but, can everything: backup , restore(gbak), db commands(all). tried fdb 64x instead, , not working. code: //components fdwaitcursor: tfdguixwaitcursor; fddriverlink: tfdphysfbdriverlink; fdconnection:tfdconnection; fdscript: tfdscript; function tthr_script.createcomponents:boolean; begin try fddriverlink := tfdphysfbdriverlink.create(fddriverlink); fdwaitcursor := tfdguixwaitcursor.create(fdwaitcursor); fdconnection := tfdconnection.create(fdconnection); fdconnection begin drivername := 'fb'; params.username := thrbanco.bduser; params.password := thrbanco.bdpass; params.database := ...
Read more

Sound is not coming out while implementing Text-to-speech in Android activity -

i using texttospeak in 1 of app. while adding speech string texttospeech object instance, doesn't produce sound. though not getting error in log still sound not coming out. want device speak value of textview gets set resultmsg.settext() method. public class resultactivity extends activity { @override protected void oncreate(bundle savedinstancestate){ ............ resultmsg.settext(resultmsg_str); texttospeech = new texttospeech(getapplicationcontext(),newtexttospeech.oninitlistener(){ @override public void oninit(int status) { system.out.println("txt speech status = "+status); system.out.println("txt speech error status = "+texttospeech.error); system.out.println("txt speech success status = "+texttospeech.success); if(status == texttospeech.success){ texttospeech.setlanguage(locale.english); ...
Read more