D:\Users\crolke\git\amqpnetlite\TransactionTestProgram\bin\Debug>TransactionTestProgram.exe amqp://testbroker:5672 q1 [05:13:27.124] SEND AMQP 0 1.0.0 [05:13:27.134] SEND (ch=0) open(container-id:65a5ca44-9376-4c73-a7ac-b941e6eadf99,host-name:testbroker,max-frame-size:262144,channel-max:256) [05:13:27.139] RECV AMQP 0 1 0 0 [05:13:27.140] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:27.144] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:13:27.146] RECV (ch=0) open(container-id:TestAmqpBroker:6a09a5ca,host-name:localhost,max-frame-size:65536,channel-max:999) [05:13:27.148] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:27.149] SEND (ch=0) flow(next-in-id:0,in-window:2048,next-out-id:4294967293,out-window:2048,handle:0,delivery-count:0,link-credit:200,drain:False) [05:13:27.152] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,source:source(address:q1),target:target(),initial-delivery-count:0) [05:13:28.152] SEND (ch=0) detach(handle:0,closed:True) [05:13:28.152] RECV (ch=0) detach(handle:0,closed:True) [05:13:28.158] SEND (ch=0) end() [05:13:28.158] RECV (ch=0) end() [05:13:28.160] SEND (ch=0) close() [05:13:28.161] RECV (ch=0) close() [05:13:28.164] SEND AMQP 0 1.0.0 [05:13:28.164] SEND (ch=0) open(container-id:7f0f6eae-5532-4feb-9fc1-7bbc5999823b,host-name:testbroker,max-frame-size:262144,channel-max:256) [05:13:28.164] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:28.165] SEND (ch=0) attach(name:sender-TransactedPosting,handle:0,role:False,source:source(),target:target(address:q1),initial-delivery-count:0) TransactedPosting nMsgs= 5 Creating transaction scope [05:13:28.172] RECV AMQP 0 1 0 0 [05:13:28.173] RECV (ch=0) open(container-id:TestAmqpBroker:6a09a5ca,host-name:localhost,max-frame-size:65536,channel-max:999) [05:13:28.173] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:28.173] RECV (ch=0) attach(name:sender-TransactedPosting,handle:0,role:True,source:source(),target:target(address:q1),initial-delivery-count:0) [05:13:28.174] RECV (ch=0) flow(next-in-id:4294967293,in-window:2048,next-out-id:0,out-window:2048,handle:0,delivery-count:0,link-credit:200,drain:False) Writing message with id commit0 [05:13:28.183] SEND (ch=1) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:28.184] RECV (ch=1) begin(remote-channel:1,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:28.185] SEND (ch=1) attach(name:controller-link-813e0,handle:0,role:False,source:source(),target:coordinator(),initial-delivery-count:0) [05:13:28.185] RECV (ch=1) attach(name:controller-link-813e0,handle:0,role:True,source:source(),target:coordinator(),initial-delivery-count:0) [05:13:28.186] RECV (ch=1) flow(next-in-id:4294967293,in-window:2048,next-out-id:0,out-window:2048,handle:0,delivery-count:0,link-credit:100,drain:False) [05:13:28.201] SEND (ch=1) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 7 [05:13:28.202] RECV (ch=1) disposition(role:True,first:0,settled:True,state:declared(txn-id:11000000)) [05:13:28.207] SEND (ch=0) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,state:txn-state(txn-id:11000000),batchable:True) payload 52 [05:13:28.208] RECV (ch=0) disposition(role:True,first:0,settled:True,state:txn-state(txn-id:11000000,outcome:accepted())) Writing message with id commit1 [05:13:28.209] SEND (ch=0) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,state:txn-state(txn-id:11000000),batchable:True) payload 52 [05:13:28.210] RECV (ch=0) disposition(role:True,first:1,settled:True,state:txn-state(txn-id:11000000,outcome:accepted())) Writing message with id commit2 [05:13:28.213] SEND (ch=0) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,state:txn-state(txn-id:11000000),batchable:True) payload 52 [05:13:28.213] RECV (ch=0) disposition(role:True,first:2,settled:True,state:txn-state(txn-id:11000000,outcome:accepted())) Writing message with id commit3 [05:13:28.216] SEND (ch=0) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,state:txn-state(txn-id:11000000),batchable:True) payload 52 [05:13:28.217] RECV (ch=0) disposition(role:True,first:3,settled:True,state:txn-state(txn-id:11000000,outcome:accepted())) Writing message with id commit4 [05:13:28.220] SEND (ch=0) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,state:txn-state(txn-id:11000000),batchable:True) payload 52 [05:13:28.221] RECV (ch=0) disposition(role:True,first:4,settled:True,state:txn-state(txn-id:11000000,outcome:accepted())) Calling scope Complete() [05:13:28.234] SEND (ch=1) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 16 [05:13:28.234] RECV (ch=1) disposition(role:True,first:1,settled:True,state:accepted()) Creating transaction scope Writing message with id rollback5 [05:13:28.240] SEND (ch=1) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 7 [05:13:28.240] RECV (ch=1) disposition(role:True,first:2,settled:True,state:declared(txn-id:12000000)) [05:13:28.241] SEND (ch=0) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,state:txn-state(txn-id:12000000),batchable:True) payload 54 [05:13:28.242] RECV (ch=0) disposition(role:True,first:5,settled:True,state:txn-state(txn-id:12000000,outcome:accepted())) Writing message with id rollback6 [05:13:28.244] SEND (ch=0) transfer(handle:0,delivery-id:6,delivery-tag:00000006,message-format:0,settled:False,state:txn-state(txn-id:12000000),batchable:True) payload 54 [05:13:28.245] RECV (ch=0) disposition(role:True,first:6,settled:True,state:txn-state(txn-id:12000000,outcome:accepted())) Writing message with id rollback7 [05:13:28.248] SEND (ch=0) transfer(handle:0,delivery-id:7,delivery-tag:00000007,message-format:0,settled:False,state:txn-state(txn-id:12000000),batchable:True) payload 54 [05:13:28.248] RECV (ch=0) disposition(role:True,first:7,settled:True,state:txn-state(txn-id:12000000,outcome:accepted())) Writing message with id rollback8 [05:13:28.250] SEND (ch=0) transfer(handle:0,delivery-id:8,delivery-tag:00000008,message-format:0,settled:False,state:txn-state(txn-id:12000000),batchable:True) payload 54 [05:13:28.250] RECV (ch=0) disposition(role:True,first:8,settled:True,state:txn-state(txn-id:12000000,outcome:accepted())) Writing message with id rollback9 [05:13:28.260] SEND (ch=0) transfer(handle:0,delivery-id:9,delivery-tag:00000009,message-format:0,settled:False,state:txn-state(txn-id:12000000),batchable:True) payload 54 [05:13:28.261] RECV (ch=0) disposition(role:True,first:9,settled:True,state:txn-state(txn-id:12000000,outcome:accepted())) Exiting transaction scope without calling complete [05:13:28.263] SEND (ch=1) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 16 Creating transaction scope [05:13:28.264] RECV (ch=1) disposition(role:True,first:3,settled:True,state:accepted()) Writing message with id commit0 [05:13:28.281] SEND (ch=1) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 7 [05:13:28.282] RECV (ch=1) disposition(role:True,first:4,settled:True,state:declared(txn-id:13000000)) [05:13:28.292] SEND (ch=0) transfer(handle:0,delivery-id:10,delivery-tag:0000000A,message-format:0,settled:False,state:txn-state(txn-id:13000000),batchable:True) payload 52 [05:13:28.292] RECV (ch=0) disposition(role:True,first:10,settled:True,state:txn-state(txn-id:13000000,outcome:accepted())) Writing message with id commit1 [05:13:28.303] SEND (ch=0) transfer(handle:0,delivery-id:11,delivery-tag:0000000B,message-format:0,settled:False,state:txn-state(txn-id:13000000),batchable:True) payload 52 [05:13:28.304] RECV (ch=0) disposition(role:True,first:11,settled:True,state:txn-state(txn-id:13000000,outcome:accepted())) Writing message with id commit2 [05:13:28.323] SEND (ch=0) transfer(handle:0,delivery-id:12,delivery-tag:0000000C,message-format:0,settled:False,state:txn-state(txn-id:13000000),batchable:True) payload 52 [05:13:28.323] RECV (ch=0) disposition(role:True,first:12,settled:True,state:txn-state(txn-id:13000000,outcome:accepted())) Writing message with id commit3 [05:13:28.326] SEND (ch=0) transfer(handle:0,delivery-id:13,delivery-tag:0000000D,message-format:0,settled:False,state:txn-state(txn-id:13000000),batchable:True) payload 52 [05:13:28.326] RECV (ch=0) disposition(role:True,first:13,settled:True,state:txn-state(txn-id:13000000,outcome:accepted())) Writing message with id commit4 [05:13:28.328] SEND (ch=0) transfer(handle:0,delivery-id:14,delivery-tag:0000000E,message-format:0,settled:False,state:txn-state(txn-id:13000000),batchable:True) payload 52 [05:13:28.329] RECV (ch=0) disposition(role:True,first:14,settled:True,state:txn-state(txn-id:13000000,outcome:accepted())) Calling scope Complete() [05:13:28.331] SEND (ch=1) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 16 [05:13:28.332] RECV (ch=1) disposition(role:True,first:5,settled:True,state:accepted()) Receiving messages that should have been accepted under Txn scope [05:13:28.344] SEND (ch=0) attach(name:receiver-TransactedPosting,handle:1,role:True,source:source(address:q1),target:target()) [05:13:28.345] SEND (ch=0) flow(next-in-id:0,in-window:2048,next-out-id:12,out-window:2033,handle:1,delivery-count:0,link-credit:200,drain:False) [05:13:28.344] RECV (ch=0) attach(name:receiver-TransactedPosting,handle:1,role:False,source:source(address:q1),target:target(),initial-delivery-count:0) [05:13:28.347] RECV (ch=0) transfer(handle:1,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 52 [05:13:28.352] RECV (ch=0) transfer(handle:1,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 52 [05:13:28.352] receive: commit0 [05:13:28.356] RECV (ch=0) transfer(handle:1,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 52 [05:13:28.358] SEND (ch=0) disposition(role:True,first:0,settled:True,state:accepted()) [05:13:28.358] RECV (ch=0) transfer(handle:1,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 52 [05:13:28.359] receive: commit1 [05:13:28.360] RECV (ch=0) transfer(handle:1,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 52 [05:13:28.361] SEND (ch=0) disposition(role:True,first:1,settled:True,state:accepted()) [05:13:28.372] receive: commit2 [05:13:28.371] RECV (ch=0) transfer(handle:1,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 52 [05:13:28.373] SEND (ch=0) disposition(role:True,first:2,settled:True,state:accepted()) [05:13:28.381] RECV (ch=0) transfer(handle:1,delivery-id:6,delivery-tag:00000006,message-format:0,settled:False,batchable:True) payload 52 [05:13:28.382] receive: commit3 [05:13:28.390] SEND (ch=0) disposition(role:True,first:3,settled:True,state:accepted()) [05:13:28.389] RECV (ch=0) transfer(handle:1,delivery-id:7,delivery-tag:00000007,message-format:0,settled:False,batchable:True) payload 52 [05:13:28.407] RECV (ch=0) transfer(handle:1,delivery-id:8,delivery-tag:00000008,message-format:0,settled:False,batchable:True) payload 52 [05:13:28.407] RECV (ch=0) transfer(handle:1,delivery-id:9,delivery-tag:00000009,message-format:0,settled:False,batchable:True) payload 52 [05:13:28.405] receive: commit4 [05:13:28.411] SEND (ch=0) disposition(role:True,first:4,settled:True,state:accepted()) [05:13:28.412] receive: commit0 [05:13:28.412] SEND (ch=0) disposition(role:True,first:5,settled:True,state:accepted()) [05:13:28.414] receive: commit1 [05:13:28.416] SEND (ch=0) disposition(role:True,first:6,settled:True,state:accepted()) [05:13:28.424] receive: commit2 [05:13:28.431] SEND (ch=0) disposition(role:True,first:7,settled:True,state:accepted()) [05:13:28.432] receive: commit3 [05:13:28.433] SEND (ch=0) disposition(role:True,first:8,settled:True,state:accepted()) [05:13:28.440] receive: commit4 [05:13:28.451] SEND (ch=0) disposition(role:True,first:9,settled:True,state:accepted()) [05:13:28.451] SEND (ch=0) close() [05:13:28.451] RECV (ch=0) close() [05:13:28.463] SEND AMQP 0 1.0.0 [05:13:28.468] SEND (ch=0) open(container-id:fc3ee793-017a-4b1e-8ff7-849f3f8c208e,host-name:testbroker,max-frame-size:262144,channel-max:256) [05:13:28.469] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:28.469] RECV AMQP 0 1 0 0 [05:13:28.487] RECV (ch=0) open(container-id:TestAmqpBroker:6a09a5ca,host-name:localhost,max-frame-size:65536,channel-max:999) [05:13:28.484] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:13:28.496] SEND (ch=0) flow(next-in-id:0,in-window:2048,next-out-id:4294967293,out-window:2048,handle:0,delivery-count:0,link-credit:200,drain:False) [05:13:28.495] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:28.504] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,source:source(address:q1),target:target(),initial-delivery-count:0) [05:13:29.504] SEND (ch=0) detach(handle:0,closed:True) [05:13:29.504] RECV (ch=0) detach(handle:0,closed:True) [05:13:29.507] SEND (ch=0) end() [05:13:29.507] RECV (ch=0) end() [05:13:29.509] SEND (ch=0) close() [05:13:29.510] RECV (ch=0) close() TransactedPosting exiting with status PASS Test: TransactedRetiring nMsgs= 10 Pretest - draining target queue... [05:13:29.537] SEND AMQP 0 1.0.0 [05:13:29.543] SEND (ch=0) open(container-id:dbdd7f03-d8ee-40ad-8f32-9ea1efaf81e9,host-name:testbroker,max-frame-size:262144,channel-max:256) [05:13:29.552] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:29.552] RECV AMQP 0 1 0 0 [05:13:29.557] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:13:29.566] SEND (ch=0) flow(next-in-id:0,in-window:2048,next-out-id:4294967293,out-window:2048,handle:0,delivery-count:0,link-credit:200,drain:False) [05:13:29.565] RECV (ch=0) open(container-id:TestAmqpBroker:6a09a5ca,host-name:localhost,max-frame-size:65536,channel-max:999) [05:13:29.576] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:29.583] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,source:source(address:q1),target:target(),initial-delivery-count:0) [05:13:30.575] SEND (ch=0) detach(handle:0,closed:True) [05:13:30.576] RECV (ch=0) detach(handle:0,closed:True) [05:13:30.578] SEND (ch=0) end() [05:13:30.579] RECV (ch=0) end() [05:13:30.581] SEND (ch=0) close() [05:13:30.582] RECV (ch=0) close() [05:13:30.585] SEND AMQP 0 1.0.0 [05:13:30.586] SEND (ch=0) open(container-id:227edf7a-4927-452a-af6c-2bfc4df9f9f7,host-name:testbroker,max-frame-size:262144,channel-max:256) [05:13:30.587] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:30.588] SEND (ch=0) attach(name:sender-TransactedRetiring,handle:0,role:False,source:source(),target:target(address:q1),initial-delivery-count:0) Send N+1 with no transaction scope Sending message with Id msg0 [05:13:30.594] RECV AMQP 0 1 0 0 [05:13:30.595] RECV (ch=0) open(container-id:TestAmqpBroker:6a09a5ca,host-name:localhost,max-frame-size:65536,channel-max:999) [05:13:30.596] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:30.597] RECV (ch=0) attach(name:sender-TransactedRetiring,handle:0,role:True,source:source(),target:target(address:q1),initial-delivery-count:0) [05:13:30.598] RECV (ch=0) flow(next-in-id:4294967293,in-window:2048,next-out-id:0,out-window:2048,handle:0,delivery-count:0,link-credit:200,drain:False) [05:13:30.599] SEND (ch=0) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.602] RECV (ch=0) disposition(role:True,first:0,settled:True,state:accepted()) Sending message with Id msg1 [05:13:30.610] SEND (ch=0) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.610] RECV (ch=0) disposition(role:True,first:1,settled:True,state:accepted()) Sending message with Id msg2 [05:13:30.620] SEND (ch=0) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.620] RECV (ch=0) disposition(role:True,first:2,settled:True,state:accepted()) Sending message with Id msg3 [05:13:30.630] SEND (ch=0) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.631] RECV (ch=0) disposition(role:True,first:3,settled:True,state:accepted()) Sending message with Id msg4 [05:13:30.639] SEND (ch=0) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.640] RECV (ch=0) disposition(role:True,first:4,settled:True,state:accepted()) Sending message with Id msg5 [05:13:30.657] SEND (ch=0) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.658] RECV (ch=0) disposition(role:True,first:5,settled:True,state:accepted()) Sending message with Id msg6 [05:13:30.668] SEND (ch=0) transfer(handle:0,delivery-id:6,delivery-tag:00000006,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.668] RECV (ch=0) disposition(role:True,first:6,settled:True,state:accepted()) Sending message with Id msg7 [05:13:30.680] SEND (ch=0) transfer(handle:0,delivery-id:7,delivery-tag:00000007,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.680] RECV (ch=0) disposition(role:True,first:7,settled:True,state:accepted()) Sending message with Id msg8 [05:13:30.701] SEND (ch=0) transfer(handle:0,delivery-id:8,delivery-tag:00000008,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.701] RECV (ch=0) disposition(role:True,first:8,settled:True,state:accepted()) Sending message with Id msg9 [05:13:30.704] SEND (ch=0) transfer(handle:0,delivery-id:9,delivery-tag:00000009,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.704] RECV (ch=0) disposition(role:True,first:9,settled:True,state:accepted()) Sending message with Id msg10 [05:13:30.715] SEND (ch=0) transfer(handle:0,delivery-id:10,delivery-tag:0000000A,message-format:0,settled:False,batchable:True) payload 51 [05:13:30.715] RECV (ch=0) disposition(role:True,first:10,settled:True,state:accepted()) [05:13:30.725] SEND (ch=0) attach(name:receiver-TransactedRetiring,handle:1,role:True,source:source(address:q1),target:target()) Receive N messages but don't accept any [05:13:30.725] RECV (ch=0) attach(name:receiver-TransactedRetiring,handle:1,role:False,source:source(address:q1),target:target(),initial-delivery-count:0) [05:13:30.745] SEND (ch=0) flow(next-in-id:0,in-window:2048,next-out-id:8,out-window:2037,handle:1,delivery-count:0,link-credit:200,drain:False) [05:13:30.746] RECV (ch=0) transfer(handle:1,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.755] RECV (ch=0) transfer(handle:1,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 50 Received: msg0 [05:13:30.756] RECV (ch=0) transfer(handle:1,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 50 Received: msg1 [05:13:30.767] RECV (ch=0) transfer(handle:1,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 50 Received: msg2 [05:13:30.775] RECV (ch=0) transfer(handle:1,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 50 Received: msg3 Received: msg4 [05:13:30.793] RECV (ch=0) transfer(handle:1,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 50 Received: msg5 [05:13:30.797] RECV (ch=0) transfer(handle:1,delivery-id:6,delivery-tag:00000006,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.799] RECV (ch=0) transfer(handle:1,delivery-id:7,delivery-tag:00000007,message-format:0,settled:False,batchable:True) payload 50 Received: msg6 [05:13:30.800] RECV (ch=0) transfer(handle:1,delivery-id:8,delivery-tag:00000008,message-format:0,settled:False,batchable:True) payload 50 [05:13:30.811] RECV (ch=0) transfer(handle:1,delivery-id:9,delivery-tag:00000009,message-format:0,settled:False,batchable:True) payload 50 Received: msg7 Received: msg8 Received: msg9 [05:13:30.816] RECV (ch=0) transfer(handle:1,delivery-id:10,delivery-tag:0000000A,message-format:0,settled:False,batchable:True) payload 51 Create txn scope and accept half the messages Accepting to-be-committed messageId: msg0 [05:13:30.846] SEND (ch=1) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:30.846] RECV (ch=1) begin(remote-channel:1,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:30.853] SEND (ch=1) attach(name:controller-link-19368,handle:0,role:False,source:source(),target:coordinator(),initial-delivery-count:0) [05:13:30.854] RECV (ch=1) attach(name:controller-link-19368,handle:0,role:True,source:source(),target:coordinator(),initial-delivery-count:0) [05:13:30.864] RECV (ch=1) flow(next-in-id:4294967293,in-window:2048,next-out-id:0,out-window:2048,handle:0,delivery-count:0,link-credit:100,drain:False) [05:13:30.872] SEND (ch=1) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 7 [05:13:30.874] RECV (ch=1) disposition(role:True,first:0,settled:True,state:declared(txn-id:14000000)) [05:13:30.876] SEND (ch=0) disposition(role:True,first:0,settled:False,state:txn-state(txn-id:14000000,outcome:accepted())) Accepting to-be-committed messageId: msg1 [05:13:30.886] SEND (ch=0) disposition(role:True,first:1,settled:False,state:txn-state(txn-id:14000000,outcome:accepted())) Accepting to-be-committed messageId: msg2 [05:13:30.895] SEND (ch=0) disposition(role:True,first:2,settled:False,state:txn-state(txn-id:14000000,outcome:accepted())) Accepting to-be-committed messageId: msg3 [05:13:30.911] SEND (ch=0) disposition(role:True,first:3,settled:False,state:txn-state(txn-id:14000000,outcome:accepted())) Accepting to-be-committed messageId: msg4 [05:13:30.915] SEND (ch=0) disposition(role:True,first:4,settled:False,state:txn-state(txn-id:14000000,outcome:accepted())) Txn scope complete [05:13:30.924] SEND (ch=1) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 16 [05:13:30.924] RECV (ch=1) disposition(role:True,first:1,settled:True,state:accepted()) Create txn scope and accept other half BUT do that in a failed txn scope that should roll back. Accepting to-be-rolled-back messageId: msg5 [05:13:30.950] SEND (ch=1) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 7 [05:13:30.951] RECV (ch=1) disposition(role:True,first:2,settled:True,state:declared(txn-id:15000000)) [05:13:30.961] SEND (ch=0) disposition(role:True,first:5,settled:False,state:txn-state(txn-id:15000000,outcome:accepted())) Accepting to-be-rolled-back messageId: msg6 [05:13:30.970] SEND (ch=0) disposition(role:True,first:6,settled:False,state:txn-state(txn-id:15000000,outcome:accepted())) Accepting to-be-rolled-back messageId: msg7 [05:13:30.979] SEND (ch=0) disposition(role:True,first:7,settled:False,state:txn-state(txn-id:15000000,outcome:accepted())) Accepting to-be-rolled-back messageId: msg8 [05:13:30.989] SEND (ch=0) disposition(role:True,first:8,settled:False,state:txn-state(txn-id:15000000,outcome:accepted())) Accepting to-be-rolled-back messageId: msg9 [05:13:30.998] SEND (ch=0) disposition(role:True,first:9,settled:False,state:txn-state(txn-id:15000000,outcome:accepted())) Close txn scope without calling complete [05:13:31.008] SEND (ch=1) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 16 [05:13:31.008] RECV (ch=1) disposition(role:True,first:3,settled:True,state:accepted()) after rollback, messages should be still acquired Receiving a single message Releasing last message received, the extra one [05:13:31.044] SEND (ch=0) disposition(role:True,first:10,settled:True,state:released()) [05:13:31.044] RECV (ch=0) transfer(handle:1,delivery-id:11,delivery-tag:0000000B,message-format:0,settled:False,batchable:True) payload 51 Creating txn scope to accept 2nd half for real this time Accepting to-be-committed messageId msg5 [05:13:31.066] SEND (ch=1) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 7 [05:13:31.067] RECV (ch=1) disposition(role:True,first:4,settled:True,state:declared(txn-id:16000000)) [05:13:31.069] SEND (ch=0) disposition(role:True,first:5,settled:False,state:txn-state(txn-id:16000000,outcome:accepted())) Accepting to-be-committed messageId msg6 [05:13:31.085] SEND (ch=0) disposition(role:True,first:6,settled:False,state:txn-state(txn-id:16000000,outcome:accepted())) Accepting to-be-committed messageId msg7 [05:13:31.094] SEND (ch=0) disposition(role:True,first:7,settled:False,state:txn-state(txn-id:16000000,outcome:accepted())) Accepting to-be-committed messageId msg8 [05:13:31.104] SEND (ch=0) disposition(role:True,first:8,settled:False,state:txn-state(txn-id:16000000,outcome:accepted())) Accepting to-be-committed messageId msg9 [05:13:31.114] SEND (ch=0) disposition(role:True,first:9,settled:False,state:txn-state(txn-id:16000000,outcome:accepted())) Txn scope Complete() [05:13:31.117] SEND (ch=1) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 16 [05:13:31.117] RECV (ch=1) disposition(role:True,first:5,settled:True,state:accepted()) Receive last message again Acccept last message [05:13:31.145] SEND (ch=0) disposition(role:True,first:11,settled:True,state:accepted()) [05:13:31.146] SEND (ch=0) detach(handle:1,closed:True) [05:13:31.146] RECV (ch=0) detach(handle:1,closed:True) [05:13:31.163] SEND (ch=0) detach(handle:0,closed:True) [05:13:31.163] RECV (ch=0) detach(handle:0,closed:True) [05:13:31.171] SEND (ch=0) end() [05:13:31.172] RECV (ch=0) end() [05:13:31.183] SEND (ch=0) close() [05:13:31.183] RECV (ch=0) close() [05:13:31.192] SEND AMQP 0 1.0.0 [05:13:31.193] SEND (ch=0) open(container-id:1e97a6f7-51fc-467e-a87a-b8d0547f766f,host-name:testbroker,max-frame-size:262144,channel-max:256) [05:13:31.199] RECV AMQP 0 1 0 0 [05:13:31.200] RECV (ch=0) open(container-id:TestAmqpBroker:6a09a5ca,host-name:localhost,max-frame-size:65536,channel-max:999) [05:13:31.199] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:31.208] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:31.219] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,source:source(address:q1),target:target(),initial-delivery-count:0) [05:13:31.218] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:13:31.223] SEND (ch=0) flow(next-in-id:0,in-window:2048,next-out-id:4294967293,out-window:2048,handle:0,delivery-count:0,link-credit:200,drain:False) [05:13:32.224] SEND (ch=0) detach(handle:0,closed:True) [05:13:32.225] RECV (ch=0) detach(handle:0,closed:True) [05:13:32.227] SEND (ch=0) end() [05:13:32.228] RECV (ch=0) end() [05:13:32.230] SEND (ch=0) close() [05:13:32.231] RECV (ch=0) close() TransactedRetiring exiting with status PASS Test: TransactedRetiringAndPosting nMsgs= 10 Pretest - draining target queue... [05:13:32.245] SEND AMQP 0 1.0.0 [05:13:32.246] SEND (ch=0) open(container-id:2f45a950-da32-40c5-8f6f-18c9cbf081b7,host-name:testbroker,max-frame-size:262144,channel-max:256) [05:13:32.253] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:32.255] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:13:32.255] RECV AMQP 0 1 0 0 [05:13:32.262] SEND (ch=0) flow(next-in-id:0,in-window:2048,next-out-id:4294967293,out-window:2048,handle:0,delivery-count:0,link-credit:200,drain:False) [05:13:32.270] RECV (ch=0) open(container-id:TestAmqpBroker:6a09a5ca,host-name:localhost,max-frame-size:65536,channel-max:999) [05:13:32.273] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:32.283] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,source:source(address:q1),target:target(),initial-delivery-count:0) [05:13:33.271] SEND (ch=0) detach(handle:0,closed:True) [05:13:33.272] RECV (ch=0) detach(handle:0,closed:True) [05:13:33.274] SEND (ch=0) end() [05:13:33.275] RECV (ch=0) end() [05:13:33.276] SEND (ch=0) close() [05:13:33.276] RECV (ch=0) close() [05:13:33.280] SEND AMQP 0 1.0.0 [05:13:33.280] SEND (ch=0) open(container-id:08e84902-ce3e-4556-980c-c131b8be79bb,host-name:testbroker,max-frame-size:262144,channel-max:256) [05:13:33.282] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:33.284] SEND (ch=0) attach(name:sender-TransactedRetiringAndPosting,handle:0,role:False,source:source(),target:target(address:q1),initial-delivery-count:0) Send N messages with no transaction scope Sending message with Id msg0 [05:13:33.282] RECV AMQP 0 1 0 0 [05:13:33.290] RECV (ch=0) open(container-id:TestAmqpBroker:6a09a5ca,host-name:localhost,max-frame-size:65536,channel-max:999) [05:13:33.291] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:33.292] RECV (ch=0) attach(name:sender-TransactedRetiringAndPosting,handle:0,role:True,source:source(),target:target(address:q1),initial-delivery-count:0) [05:13:33.293] RECV (ch=0) flow(next-in-id:4294967293,in-window:2048,next-out-id:0,out-window:2048,handle:0,delivery-count:0,link-credit:200,drain:False) [05:13:33.295] SEND (ch=0) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.297] RECV (ch=0) disposition(role:True,first:0,settled:True,state:accepted()) Sending message with Id msg1 [05:13:33.306] SEND (ch=0) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.306] RECV (ch=0) disposition(role:True,first:1,settled:True,state:accepted()) Sending message with Id msg2 [05:13:33.322] SEND (ch=0) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.322] RECV (ch=0) disposition(role:True,first:2,settled:True,state:accepted()) Sending message with Id msg3 [05:13:33.338] SEND (ch=0) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.338] RECV (ch=0) disposition(role:True,first:3,settled:True,state:accepted()) Sending message with Id msg4 [05:13:33.350] SEND (ch=0) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.350] RECV (ch=0) disposition(role:True,first:4,settled:True,state:accepted()) Sending message with Id msg5 [05:13:33.360] SEND (ch=0) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.360] RECV (ch=0) disposition(role:True,first:5,settled:True,state:accepted()) Sending message with Id msg6 [05:13:33.379] SEND (ch=0) transfer(handle:0,delivery-id:6,delivery-tag:00000006,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.379] RECV (ch=0) disposition(role:True,first:6,settled:True,state:accepted()) Sending message with Id msg7 [05:13:33.388] SEND (ch=0) transfer(handle:0,delivery-id:7,delivery-tag:00000007,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.389] RECV (ch=0) disposition(role:True,first:7,settled:True,state:accepted()) Sending message with Id msg8 [05:13:33.415] SEND (ch=0) transfer(handle:0,delivery-id:8,delivery-tag:00000008,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.415] RECV (ch=0) disposition(role:True,first:8,settled:True,state:accepted()) Sending message with Id msg9 [05:13:33.425] SEND (ch=0) transfer(handle:0,delivery-id:9,delivery-tag:00000009,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.425] RECV (ch=0) disposition(role:True,first:9,settled:True,state:accepted()) Receive two messages [05:13:33.443] SEND (ch=0) attach(name:receiver-TransactedRetiringAndPosting,handle:1,role:True,source:source(address:q1),target:target()) [05:13:33.444] SEND (ch=0) flow(next-in-id:0,in-window:2048,next-out-id:7,out-window:2038,handle:1,delivery-count:0,link-credit:2,drain:False) [05:13:33.445] RECV (ch=0) attach(name:receiver-TransactedRetiringAndPosting,handle:1,role:False,source:source(address:q1),target:target(),initial-delivery-count:0) [05:13:33.459] RECV (ch=0) transfer(handle:1,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.461] RECV (ch=0) transfer(handle:1,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 60 Received message1 id:msg0 Received message2 id:msg1 ack message1 and send a new message in a txn [05:13:33.481] SEND (ch=1) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:33.482] RECV (ch=1) begin(remote-channel:1,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:33.490] RECV (ch=1) attach(name:controller-link-0dabc,handle:0,role:True,source:source(),target:coordinator(),initial-delivery-count:0) [05:13:33.489] SEND (ch=1) attach(name:controller-link-0dabc,handle:0,role:False,source:source(),target:coordinator(),initial-delivery-count:0) [05:13:33.491] RECV (ch=1) flow(next-in-id:4294967293,in-window:2048,next-out-id:0,out-window:2048,handle:0,delivery-count:0,link-credit:100,drain:False) [05:13:33.493] SEND (ch=1) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 7 [05:13:33.494] RECV (ch=1) disposition(role:True,first:0,settled:True,state:declared(txn-id:17000000)) [05:13:33.502] SEND (ch=0) disposition(role:True,first:0,settled:False,state:txn-state(txn-id:17000000,outcome:accepted())) [05:13:33.510] SEND (ch=0) transfer(handle:0,delivery-id:10,delivery-tag:0000000A,message-format:0,settled:False,state:txn-state(txn-id:17000000),batchable:True) payload 61 [05:13:33.511] RECV (ch=0) disposition(role:True,first:10,settled:True,state:txn-state(txn-id:17000000,outcome:accepted())) Sent message id: msg10 Transaction Complete() [05:13:33.523] SEND (ch=1) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 16 [05:13:33.523] RECV (ch=1) disposition(role:True,first:1,settled:True,state:accepted()) ack message2 and send a new message in a txn but abort the txn [05:13:33.535] SEND (ch=1) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 7 [05:13:33.535] RECV (ch=1) disposition(role:True,first:2,settled:True,state:declared(txn-id:18000000)) [05:13:33.544] SEND (ch=0) disposition(role:True,first:1,settled:False,state:txn-state(txn-id:18000000,outcome:accepted())) [05:13:33.559] SEND (ch=0) transfer(handle:0,delivery-id:11,delivery-tag:0000000B,message-format:0,settled:False,state:txn-state(txn-id:18000000),batchable:True) payload 60 [05:13:33.560] RECV (ch=0) disposition(role:True,first:11,settled:True,state:txn-state(txn-id:18000000,outcome:accepted())) Sent message id: msg11 [05:13:33.571] SEND (ch=1) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 16 Release message 2 [05:13:33.573] SEND (ch=0) disposition(role:True,first:1,settled:True,state:released()) Receive and Accept all messages. Expect msg1..msg(N+1) [05:13:33.575] SEND (ch=0) flow(next-in-id:2,in-window:2048,next-out-id:9,out-window:2036,handle:1,delivery-count:2,link-credit:10,drain:False) [05:13:33.571] RECV (ch=1) disposition(role:True,first:3,settled:True,state:accepted()) [05:13:33.584] RECV (ch=0) transfer(handle:1,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.592] RECV (ch=0) transfer(handle:1,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.592] SEND (ch=0) disposition(role:True,first:2,settled:True,state:accepted()) receive: msg1 [05:13:33.593] RECV (ch=0) transfer(handle:1,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.605] RECV (ch=0) transfer(handle:1,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.606] RECV (ch=0) transfer(handle:1,delivery-id:6,delivery-tag:00000006,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.603] SEND (ch=0) disposition(role:True,first:3,settled:True,state:accepted()) receive: msg2 [05:13:33.613] RECV (ch=0) transfer(handle:1,delivery-id:7,delivery-tag:00000007,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.616] RECV (ch=0) transfer(handle:1,delivery-id:8,delivery-tag:00000008,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.616] SEND (ch=0) disposition(role:True,first:4,settled:True,state:accepted()) receive: msg3 [05:13:33.624] RECV (ch=0) transfer(handle:1,delivery-id:9,delivery-tag:00000009,message-format:0,settled:False,batchable:True) payload 60 [05:13:33.633] SEND (ch=0) disposition(role:True,first:5,settled:True,state:accepted()) receive: msg4 [05:13:33.636] SEND (ch=0) disposition(role:True,first:6,settled:True,state:accepted()) [05:13:33.634] RECV (ch=0) transfer(handle:1,delivery-id:10,delivery-tag:0000000A,message-format:0,settled:False,batchable:True) payload 60 receive: msg5 [05:13:33.646] RECV (ch=0) transfer(handle:1,delivery-id:11,delivery-tag:0000000B,message-format:0,settled:False,batchable:True) payload 61 [05:13:33.649] SEND (ch=0) disposition(role:True,first:7,settled:True,state:accepted()) receive: msg6 [05:13:33.652] SEND (ch=0) disposition(role:True,first:8,settled:True,state:accepted()) receive: msg7 [05:13:33.661] SEND (ch=0) disposition(role:True,first:9,settled:True,state:accepted()) receive: msg8 [05:13:33.670] SEND (ch=0) disposition(role:True,first:10,settled:True,state:accepted()) receive: msg9 [05:13:33.688] SEND (ch=0) disposition(role:True,first:11,settled:True,state:accepted()) receive: msg10 [05:13:33.690] SEND (ch=0) close() [05:13:33.690] RECV (ch=0) close() [05:13:33.707] SEND AMQP 0 1.0.0 [05:13:33.708] SEND (ch=0) open(container-id:5bff68ad-fe3a-48d5-a5fc-37eabdad205a,host-name:testbroker,max-frame-size:262144,channel-max:256) [05:13:33.714] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:13:33.715] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:13:33.714] RECV AMQP 0 1 0 0 [05:13:33.725] SEND (ch=0) flow(next-in-id:0,in-window:2048,next-out-id:4294967293,out-window:2048,handle:0,delivery-count:0,link-credit:200,drain:False) [05:13:33.725] RECV (ch=0) open(container-id:TestAmqpBroker:6a09a5ca,host-name:localhost,max-frame-size:65536,channel-max:999) [05:13:33.729] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:0,incoming-window:2048,outgoing-window:2048,handle-max:63) [05:13:33.737] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,source:source(address:q1),target:target(),initial-delivery-count:0) [05:13:34.742] SEND (ch=0) detach(handle:0,closed:True) [05:13:34.743] RECV (ch=0) detach(handle:0,closed:True) [05:13:34.746] SEND (ch=0) end() [05:13:34.746] RECV (ch=0) end() [05:13:34.748] SEND (ch=0) close() [05:13:34.749] RECV (ch=0) close() TransactedRetiringAndPosting exiting with status PASS D:\Users\crolke\git\amqpnetlite\TransactionTestProgram\bin\Debug>