D:\Users\crolke\git\amqpnetlite\TransactionTestProgram\bin\Debug>TransactionTestProgram.exe amqp://admin:password@ER14:5672 q1 [05:20:10.329] SEND AMQP 3 1 0 0 [05:20:10.341] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:ER14) [05:20:10.550] RECV AMQP 3 1 0 0 [05:20:10.555] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS]) [05:20:10.556] RECV sasl-outcome(code:0) [05:20:10.558] SEND AMQP 0 1.0.0 [05:20:10.559] SEND (ch=0) open(container-id:09bbc046-84eb-49f1-87ef-289675c9e1b9,host-name:ER14,max-frame-size:262144,channel-max:256) [05:20:10.563] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:10.567] RECV AMQP 0 1 0 0 [05:20:10.567] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:20:10.572] 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:20:10.620] RECV (ch=0) open(container-id:0.0.0.0,max-frame-size:4294967295,channel-max:65535,idle-time-out:30000,offered-capabilities:[sole-connection-for-container,DELAYED_DELIVERY,SHARED-SUBS],properties:[product:apache-activemq-artemis,version:1.5.1.amq-700001-redhat-1]) [05:20:10.664] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:10.667] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,snd-settle-mode:2,rcv-settle-mode:0,source:source(address:q1),target:target(),incomplete-unsettled:False,initial-delivery-count:0) [05:20:11.575] SEND (ch=0) detach(handle:0,closed:True) [05:20:11.799] RECV (ch=0) detach(handle:0,closed:True) [05:20:11.803] SEND (ch=0) end() [05:20:11.858] RECV (ch=0) end() [05:20:11.859] SEND (ch=0) close() [05:20:11.917] RECV (ch=0) close() [05:20:11.972] SEND AMQP 3 1 0 0 [05:20:11.972] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:ER14) [05:20:12.032] RECV AMQP 3 1 0 0 [05:20:12.032] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS]) [05:20:12.032] RECV sasl-outcome(code:0) [05:20:12.032] SEND AMQP 0 1.0.0 [05:20:12.032] SEND (ch=0) open(container-id:a8ce81f5-446e-494e-98d6-ef1d2102e4c0,host-name:ER14,max-frame-size:262144,channel-max:256) [05:20:12.033] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:12.034] 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:20:12.036] RECV AMQP 0 1 0 0 Writing message with id commit0 [05:20:12.049] SEND (ch=1) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:12.050] SEND (ch=1) attach(name:controller-link-404a2,handle:0,role:False,source:source(),target:coordinator(),initial-delivery-count:0) [05:20:12.090] RECV (ch=0) open(container-id:0.0.0.0,max-frame-size:4294967295,channel-max:65535,idle-time-out:30000,offered-capabilities:[sole-connection-for-container,DELAYED_DELIVERY,SHARED-SUBS],properties:[product:apache-activemq-artemis,version:1.5.1.amq-700001-redhat-1]) [05:20:12.097] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:12.098] RECV (ch=0) attach(name:sender-TransactedPosting,handle:0,role:True,snd-settle-mode:2,rcv-settle-mode:0,source:source(),target:target(address:q1)) [05:20:12.100] RECV (ch=0) flow(next-in-id:4294967293,in-window:2147483647,next-out-id:1,out-window:2147483647,handle:0,delivery-count:0,link-credit:100) [05:20:12.108] RECV (ch=1) begin(remote-channel:1,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:12.108] RECV (ch=1) attach(name:controller-link-404a2,handle:0,role:True,snd-settle-mode:2,rcv-settle-mode:0,source:source(),target:coordinator(capabilities:[amqp:local-transactions,amqp:multi-txns-per-ssn,amqp:multi-ssns-per-txn])) [05:20:12.109] RECV (ch=1) flow(next-in-id:4294967293,in-window:2147483647,next-out-id:1,out-window:2147483647,handle:0,delivery-count:0,link-credit:100) [05:20:12.121] SEND (ch=1) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 7 [05:20:12.178] RECV (ch=1) disposition(role:True,first:0,last:0,settled:True,state:declared(txn-id:61626336376266392D646463622D313165362D623939662D346365623432633765646139)) [05:20:12.183] SEND (ch=0) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,state:txn-state(txn-id:61626336376266392D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 52 [05:20:12.249] RECV (ch=0) disposition(role:True,first:0,last:0,settled:True,state:accepted()) Writing message with id commit1 [05:20:12.252] SEND (ch=0) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,state:txn-state(txn-id:61626336376266392D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 52 [05:20:12.307] RECV (ch=0) disposition(role:True,first:1,last:1,settled:True,state:accepted()) Writing message with id commit2 [05:20:12.310] SEND (ch=0) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,state:txn-state(txn-id:61626336376266392D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 52 [05:20:12.362] RECV (ch=0) disposition(role:True,first:2,last:2,settled:True,state:accepted()) Writing message with id commit3 [05:20:12.364] SEND (ch=0) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,state:txn-state(txn-id:61626336376266392D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 52 [05:20:12.417] RECV (ch=0) disposition(role:True,first:3,last:3,settled:True,state:accepted()) Writing message with id commit4 [05:20:12.420] SEND (ch=0) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,state:txn-state(txn-id:61626336376266392D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 52 [05:20:12.474] RECV (ch=0) disposition(role:True,first:4,last:4,settled:True,state:accepted()) Calling scope Complete() [05:20:12.478] SEND (ch=1) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 48 [05:20:12.532] RECV (ch=1) disposition(role:True,first:1,last:1,settled:True,state:accepted()) Creating transaction scope Writing message with id rollback5 [05:20:12.537] SEND (ch=1) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 7 [05:20:12.592] RECV (ch=1) disposition(role:True,first:2,last:2,settled:True,state:declared(txn-id:61633035663566612D646463622D313165362D623939662D346365623432633765646139)) [05:20:12.593] SEND (ch=0) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,state:txn-state(txn-id:61633035663566612D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 54 [05:20:12.647] RECV (ch=0) disposition(role:True,first:5,last:5,settled:True,state:accepted()) Writing message with id rollback6 [05:20:12.649] SEND (ch=0) transfer(handle:0,delivery-id:6,delivery-tag:00000006,message-format:0,settled:False,state:txn-state(txn-id:61633035663566612D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 54 [05:20:12.703] RECV (ch=0) disposition(role:True,first:6,last:6,settled:True,state:accepted()) Writing message with id rollback7 [05:20:12.706] SEND (ch=0) transfer(handle:0,delivery-id:7,delivery-tag:00000007,message-format:0,settled:False,state:txn-state(txn-id:61633035663566612D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 54 [05:20:12.757] RECV (ch=0) disposition(role:True,first:7,last:7,settled:True,state:accepted()) Writing message with id rollback8 [05:20:12.760] SEND (ch=0) transfer(handle:0,delivery-id:8,delivery-tag:00000008,message-format:0,settled:False,state:txn-state(txn-id:61633035663566612D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 54 [05:20:12.814] RECV (ch=0) disposition(role:True,first:8,last:8,settled:True,state:accepted()) Writing message with id rollback9 [05:20:12.816] SEND (ch=0) transfer(handle:0,delivery-id:9,delivery-tag:00000009,message-format:0,settled:False,state:txn-state(txn-id:61633035663566612D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 54 [05:20:12.869] RECV (ch=0) disposition(role:True,first:9,last:9,settled:True,state:accepted()) Exiting transaction scope without calling complete [05:20:12.872] SEND (ch=1) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 48 Creating transaction scope Writing message with id commit0 [05:20:12.876] SEND (ch=1) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 7 [05:20:12.926] RECV (ch=1) disposition(role:True,first:3,last:3,settled:True,state:accepted()) [05:20:12.927] RECV (ch=1) disposition(role:True,first:4,last:4,settled:True,state:declared(txn-id:61633339336166622D646463622D313165362D623939662D346365623432633765646139)) [05:20:12.929] SEND (ch=0) transfer(handle:0,delivery-id:10,delivery-tag:0000000A,message-format:0,settled:False,state:txn-state(txn-id:61633339336166622D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 52 [05:20:12.984] RECV (ch=0) disposition(role:True,first:10,last:10,settled:True,state:accepted()) Writing message with id commit1 [05:20:12.986] SEND (ch=0) transfer(handle:0,delivery-id:11,delivery-tag:0000000B,message-format:0,settled:False,state:txn-state(txn-id:61633339336166622D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 52 [05:20:13.041] RECV (ch=0) disposition(role:True,first:11,last:11,settled:True,state:accepted()) Writing message with id commit2 [05:20:13.044] SEND (ch=0) transfer(handle:0,delivery-id:12,delivery-tag:0000000C,message-format:0,settled:False,state:txn-state(txn-id:61633339336166622D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 52 [05:20:13.097] RECV (ch=0) disposition(role:True,first:12,last:12,settled:True,state:accepted()) Writing message with id commit3 [05:20:13.099] SEND (ch=0) transfer(handle:0,delivery-id:13,delivery-tag:0000000D,message-format:0,settled:False,state:txn-state(txn-id:61633339336166622D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 52 [05:20:13.151] RECV (ch=0) disposition(role:True,first:13,last:13,settled:True,state:accepted()) Writing message with id commit4 [05:20:13.154] SEND (ch=0) transfer(handle:0,delivery-id:14,delivery-tag:0000000E,message-format:0,settled:False,state:txn-state(txn-id:61633339336166622D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 52 [05:20:13.207] RECV (ch=0) disposition(role:True,first:14,last:14,settled:True,state:accepted()) Calling scope Complete() [05:20:13.209] SEND (ch=1) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 48 [05:20:13.264] RECV (ch=1) disposition(role:True,first:5,last:5,settled:True,state:accepted()) Receiving messages that should have been accepted under Txn scope [05:20:13.267] SEND (ch=0) attach(name:receiver-TransactedPosting,handle:1,role:True,source:source(address:q1),target:target()) [05:20:13.268] SEND (ch=0) flow(next-in-id:1,in-window:2048,next-out-id:12,out-window:2147483632,handle:1,delivery-count:0,link-credit:200,drain:False) [05:20:13.322] RECV (ch=0) attach(name:receiver-TransactedPosting,handle:1,role:False,snd-settle-mode:2,rcv-settle-mode:0,source:source(address:q1),target:target(),incomplete-unsettled:False,initial-delivery-count:0) [05:20:13.327] RECV (ch=0) transfer(handle:1,delivery-id:0,delivery-tag:30,message-format:0) payload 79 [05:20:13.334] RECV (ch=0) transfer(handle:1,delivery-id:1,delivery-tag:31,message-format:0) payload 79 [05:20:13.335] RECV (ch=0) transfer(handle:1,delivery-id:2,delivery-tag:32,message-format:0) payload 79 [05:20:13.336] RECV (ch=0) transfer(handle:1,delivery-id:3,delivery-tag:33,message-format:0) payload 79 [05:20:13.338] RECV (ch=0) transfer(handle:1,delivery-id:4,delivery-tag:34,message-format:0) payload 79 [05:20:13.339] RECV (ch=0) transfer(handle:1,delivery-id:5,delivery-tag:35,message-format:0) payload 79 [05:20:13.340] RECV (ch=0) transfer(handle:1,delivery-id:6,delivery-tag:36,message-format:0) payload 79 [05:20:13.342] RECV (ch=0) transfer(handle:1,delivery-id:7,delivery-tag:37,message-format:0) payload 79 [05:20:13.343] RECV (ch=0) transfer(handle:1,delivery-id:8,delivery-tag:38,message-format:0) payload 79 [05:20:13.343] receive: commit0 [05:20:13.353] SEND (ch=0) disposition(role:True,first:0,settled:True,state:accepted()) [05:20:13.354] receive: commit1 [05:20:13.356] SEND (ch=0) disposition(role:True,first:1,settled:True,state:accepted()) [05:20:13.358] receive: commit2 [05:20:13.375] SEND (ch=0) disposition(role:True,first:2,settled:True,state:accepted()) [05:20:13.376] receive: commit3 [05:20:13.379] RECV (ch=0) transfer(handle:1,delivery-id:9,delivery-tag:39,message-format:0) payload 79 [05:20:13.385] SEND (ch=0) disposition(role:True,first:3,settled:True,state:accepted()) [05:20:13.394] receive: commit4 [05:20:13.395] SEND (ch=0) disposition(role:True,first:4,settled:True,state:accepted()) [05:20:13.403] receive: commit0 [05:20:13.405] SEND (ch=0) disposition(role:True,first:5,settled:True,state:accepted()) [05:20:13.406] receive: commit1 [05:20:13.407] SEND (ch=0) disposition(role:True,first:6,settled:True,state:accepted()) [05:20:13.407] receive: commit2 [05:20:13.408] SEND (ch=0) disposition(role:True,first:7,settled:True,state:accepted()) [05:20:13.409] receive: commit3 [05:20:13.410] SEND (ch=0) disposition(role:True,first:8,settled:True,state:accepted()) [05:20:13.411] receive: commit4 [05:20:13.412] SEND (ch=0) disposition(role:True,first:9,settled:True,state:accepted()) [05:20:13.413] SEND (ch=0) close() [05:20:13.467] RECV (ch=0) close() [05:20:13.523] SEND AMQP 3 1 0 0 [05:20:13.524] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:ER14) [05:20:13.577] RECV AMQP 3 1 0 0 [05:20:13.577] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS]) [05:20:13.581] RECV sasl-outcome(code:0) [05:20:13.582] SEND AMQP 0 1.0.0 [05:20:13.583] SEND (ch=0) open(container-id:f62cacb4-7c6d-4e8a-9e72-b22e39e3efa4,host-name:ER14,max-frame-size:262144,channel-max:256) [05:20:13.585] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:13.587] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:20:13.589] 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:20:13.585] RECV AMQP 0 1 0 0 [05:20:13.635] RECV (ch=0) open(container-id:0.0.0.0,max-frame-size:4294967295,channel-max:65535,idle-time-out:30000,offered-capabilities:[sole-connection-for-container,DELAYED_DELIVERY,SHARED-SUBS],properties:[product:apache-activemq-artemis,version:1.5.1.amq-700001-redhat-1]) [05:20:13.641] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:13.643] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,snd-settle-mode:2,rcv-settle-mode:0,source:source(address:q1),target:target(),incomplete-unsettled:False,initial-delivery-count:0) [05:20:14.597] SEND (ch=0) detach(handle:0,closed:True) [05:20:14.861] RECV (ch=0) detach(handle:0,closed:True) [05:20:14.862] SEND (ch=0) end() [05:20:14.914] RECV (ch=0) end() [05:20:14.915] SEND (ch=0) close() [05:20:14.969] RECV (ch=0) close() TransactedPosting exiting with status PASS Test: TransactedRetiring nMsgs= 10 Pretest - draining target queue... [05:20:15.034] SEND AMQP 3 1 0 0 [05:20:15.035] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:ER14) [05:20:15.094] RECV AMQP 3 1 0 0 [05:20:15.095] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS]) [05:20:15.096] RECV sasl-outcome(code:0) [05:20:15.098] SEND AMQP 0 1.0.0 [05:20:15.100] SEND (ch=0) open(container-id:2b0f63aa-7b5f-4e66-9853-29fef73d5286,host-name:ER14,max-frame-size:262144,channel-max:256) [05:20:15.101] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:15.102] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:20:15.103] 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:20:15.101] RECV AMQP 0 1 0 0 [05:20:15.152] RECV (ch=0) open(container-id:0.0.0.0,max-frame-size:4294967295,channel-max:65535,idle-time-out:30000,offered-capabilities:[sole-connection-for-container,DELAYED_DELIVERY,SHARED-SUBS],properties:[product:apache-activemq-artemis,version:1.5.1.amq-700001-redhat-1]) [05:20:15.159] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:15.162] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,snd-settle-mode:2,rcv-settle-mode:0,source:source(address:q1),target:target(),incomplete-unsettled:False,initial-delivery-count:0) [05:20:16.105] SEND (ch=0) detach(handle:0,closed:True) [05:20:16.393] RECV (ch=0) detach(handle:0,closed:True) [05:20:16.394] SEND (ch=0) end() [05:20:16.449] RECV (ch=0) end() [05:20:16.449] SEND (ch=0) close() [05:20:16.501] RECV (ch=0) close() [05:20:16.554] SEND AMQP 3 1 0 0 [05:20:16.556] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:ER14) [05:20:16.614] RECV AMQP 3 1 0 0 [05:20:16.615] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS]) [05:20:16.615] RECV sasl-outcome(code:0) [05:20:16.617] SEND AMQP 0 1.0.0 [05:20:16.618] SEND (ch=0) open(container-id:47a9a6a1-3352-4d97-9fc7-99e44e1cf72f,host-name:ER14,max-frame-size:262144,channel-max:256) [05:20:16.619] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:16.620] RECV AMQP 0 1 0 0 [05:20:16.623] 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:20:16.672] RECV (ch=0) open(container-id:0.0.0.0,max-frame-size:4294967295,channel-max:65535,idle-time-out:30000,offered-capabilities:[sole-connection-for-container,DELAYED_DELIVERY,SHARED-SUBS],properties:[product:apache-activemq-artemis,version:1.5.1.amq-700001-redhat-1]) [05:20:16.677] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:16.678] RECV (ch=0) attach(name:sender-TransactedRetiring,handle:0,role:True,snd-settle-mode:2,rcv-settle-mode:0,source:source(),target:target(address:q1)) [05:20:16.679] RECV (ch=0) flow(next-in-id:4294967293,in-window:2147483647,next-out-id:1,out-window:2147483647,handle:0,delivery-count:0,link-credit:100) [05:20:16.681] SEND (ch=0) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 50 [05:20:16.738] RECV (ch=0) disposition(role:True,first:0,last:0,settled:True,state:accepted()) Sending message with Id msg1 [05:20:16.740] SEND (ch=0) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 50 [05:20:16.791] RECV (ch=0) disposition(role:True,first:1,last:1,settled:True,state:accepted()) Sending message with Id msg2 [05:20:16.794] SEND (ch=0) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 50 [05:20:16.847] RECV (ch=0) disposition(role:True,first:2,last:2,settled:True,state:accepted()) Sending message with Id msg3 [05:20:16.849] SEND (ch=0) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 50 [05:20:16.901] RECV (ch=0) disposition(role:True,first:3,last:3,settled:True,state:accepted()) Sending message with Id msg4 [05:20:16.904] SEND (ch=0) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 50 [05:20:16.957] RECV (ch=0) disposition(role:True,first:4,last:4,settled:True,state:accepted()) Sending message with Id msg5 [05:20:16.959] SEND (ch=0) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 50 [05:20:17.011] RECV (ch=0) disposition(role:True,first:5,last:5,settled:True,state:accepted()) Sending message with Id msg6 [05:20:17.014] SEND (ch=0) transfer(handle:0,delivery-id:6,delivery-tag:00000006,message-format:0,settled:False,batchable:True) payload 50 [05:20:17.067] RECV (ch=0) disposition(role:True,first:6,last:6,settled:True,state:accepted()) Sending message with Id msg7 [05:20:17.069] SEND (ch=0) transfer(handle:0,delivery-id:7,delivery-tag:00000007,message-format:0,settled:False,batchable:True) payload 50 [05:20:17.121] RECV (ch=0) disposition(role:True,first:7,last:7,settled:True,state:accepted()) Sending message with Id msg8 [05:20:17.126] SEND (ch=0) transfer(handle:0,delivery-id:8,delivery-tag:00000008,message-format:0,settled:False,batchable:True) payload 50 [05:20:17.177] RECV (ch=0) disposition(role:True,first:8,last:8,settled:True,state:accepted()) Sending message with Id msg9 [05:20:17.179] SEND (ch=0) transfer(handle:0,delivery-id:9,delivery-tag:00000009,message-format:0,settled:False,batchable:True) payload 50 [05:20:17.231] RECV (ch=0) disposition(role:True,first:9,last:9,settled:True,state:accepted()) Sending message with Id msg10 [05:20:17.234] SEND (ch=0) transfer(handle:0,delivery-id:10,delivery-tag:0000000A,message-format:0,settled:False,batchable:True) payload 51 [05:20:17.287] RECV (ch=0) disposition(role:True,first:10,last:10,settled:True,state:accepted()) [05:20:17.287] 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:20:17.293] SEND (ch=0) flow(next-in-id:1,in-window:2048,next-out-id:8,out-window:2147483636,handle:1,delivery-count:0,link-credit:200,drain:False) [05:20:17.341] RECV (ch=0) attach(name:receiver-TransactedRetiring,handle:1,role:False,snd-settle-mode:2,rcv-settle-mode:0,source:source(address:q1),target:target(),incomplete-unsettled:False,initial-delivery-count:0) [05:20:17.344] RECV (ch=0) transfer(handle:1,delivery-id:0,delivery-tag:30,message-format:0) payload 77 Received: msg0 [05:20:17.347] RECV (ch=0) transfer(handle:1,delivery-id:1,delivery-tag:31,message-format:0) payload 77 Received: msg1 [05:20:17.347] RECV (ch=0) transfer(handle:1,delivery-id:2,delivery-tag:32,message-format:0) payload 77 [05:20:17.349] RECV (ch=0) transfer(handle:1,delivery-id:3,delivery-tag:33,message-format:0) payload 77 [05:20:17.351] RECV (ch=0) transfer(handle:1,delivery-id:4,delivery-tag:34,message-format:0) payload 77 [05:20:17.352] RECV (ch=0) transfer(handle:1,delivery-id:5,delivery-tag:35,message-format:0) payload 77 [05:20:17.353] RECV (ch=0) transfer(handle:1,delivery-id:6,delivery-tag:36,message-format:0) payload 77 [05:20:17.353] RECV (ch=0) transfer(handle:1,delivery-id:7,delivery-tag:37,message-format:0) payload 77 [05:20:17.354] RECV (ch=0) transfer(handle:1,delivery-id:8,delivery-tag:38,message-format:0) payload 77 Received: msg2 Received: msg3 Received: msg4 Received: msg5 Received: msg6 Received: msg7 Received: msg8 [05:20:17.397] RECV (ch=0) transfer(handle:1,delivery-id:9,delivery-tag:39,message-format:0) payload 77 [05:20:17.398] RECV (ch=0) transfer(handle:1,delivery-id:10,delivery-tag:61,message-format:0) payload 78 Received: msg9 Create txn scope and accept half the messages Accepting to-be-committed messageId: msg0 [05:20:17.411] SEND (ch=1) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:17.412] SEND (ch=1) attach(name:controller-link-c5190,handle:0,role:False,source:source(),target:coordinator(),initial-delivery-count:0) [05:20:17.467] RECV (ch=1) begin(remote-channel:1,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:17.468] RECV (ch=1) attach(name:controller-link-c5190,handle:0,role:True,snd-settle-mode:2,rcv-settle-mode:0,source:source(),target:coordinator(capabilities:[amqp:local-transactions,amqp:multi-txns-per-ssn,amqp:multi-ssns-per-txn])) [05:20:17.470] RECV (ch=1) flow(next-in-id:4294967293,in-window:2147483647,next-out-id:1,out-window:2147483647,handle:0,delivery-count:0,link-credit:100) [05:20:17.472] SEND (ch=1) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 7 [05:20:17.524] RECV (ch=1) disposition(role:True,first:0,last:0,settled:True,state:declared(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139)) [05:20:17.525] SEND (ch=0) disposition(role:True,first:0,settled:False,state:txn-state(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) Accepting to-be-committed messageId: msg1 [05:20:17.528] SEND (ch=0) disposition(role:True,first:1,settled:False,state:txn-state(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) Accepting to-be-committed messageId: msg2 [05:20:17.530] SEND (ch=0) disposition(role:True,first:2,settled:False,state:txn-state(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) Accepting to-be-committed messageId: msg3 [05:20:17.533] SEND (ch=0) disposition(role:True,first:3,settled:False,state:txn-state(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) Accepting to-be-committed messageId: msg4 [05:20:17.536] SEND (ch=0) disposition(role:True,first:4,settled:False,state:txn-state(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) Txn scope complete [05:20:17.538] SEND (ch=1) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 48 [05:20:17.577] RECV (ch=0) disposition(role:False,first:0,last:0,settled:True,state:txn-state(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:17.579] RECV (ch=0) disposition(role:False,first:1,last:1,settled:True,state:txn-state(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:17.581] RECV (ch=0) disposition(role:False,first:2,last:2,settled:True,state:txn-state(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:17.584] RECV (ch=0) disposition(role:False,first:3,last:3,settled:True,state:txn-state(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:17.587] RECV (ch=0) disposition(role:False,first:4,last:4,settled:True,state:txn-state(txn-id:61656636616435302D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:17.591] RECV (ch=1) disposition(role:True,first:1,last: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:20:17.605] SEND (ch=1) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 7 [05:20:17.657] RECV (ch=1) disposition(role:True,first:2,last:2,settled:True,state:declared(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139)) [05:20:17.657] SEND (ch=0) disposition(role:True,first:5,settled:False,state:txn-state(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) Accepting to-be-rolled-back messageId: msg6 [05:20:17.662] SEND (ch=0) disposition(role:True,first:6,settled:False,state:txn-state(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) Accepting to-be-rolled-back messageId: msg7 [05:20:17.664] SEND (ch=0) disposition(role:True,first:7,settled:False,state:txn-state(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) Accepting to-be-rolled-back messageId: msg8 [05:20:17.667] SEND (ch=0) disposition(role:True,first:8,settled:False,state:txn-state(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) Accepting to-be-rolled-back messageId: msg9 [05:20:17.669] SEND (ch=0) disposition(role:True,first:9,settled:False,state:txn-state(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) Close txn scope without calling complete [05:20:17.671] SEND (ch=1) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 48 after rollback, messages should be still acquired Receiving a single message Releasing last message received, the extra one [05:20:17.677] SEND (ch=0) disposition(role:True,first:10,settled:True,state:released()) Creating txn scope to accept 2nd half for real this time Accepting to-be-committed messageId msg5 [05:20:17.683] SEND (ch=1) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 7 [05:20:17.709] RECV (ch=0) disposition(role:False,first:5,last:5,settled:True,state:txn-state(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:17.719] RECV (ch=0) disposition(role:False,first:6,last:6,settled:True,state:txn-state(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:17.720] RECV (ch=0) disposition(role:False,first:7,last:7,settled:True,state:txn-state(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:17.721] RECV (ch=0) disposition(role:False,first:8,last:8,settled:True,state:txn-state(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:17.729] RECV (ch=0) disposition(role:False,first:9,last:9,settled:True,state:txn-state(txn-id:61663061663861312D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:17.732] RECV (ch=1) disposition(role:True,first:3,last:3,settled:True,state:accepted()) [05:20:17.734] RECV (ch=0) transfer(handle:1,delivery-id:11,delivery-tag:62,message-format:0) payload 89 [05:20:17.735] RECV (ch=0) transfer(handle:1,delivery-id:12,delivery-tag:63,message-format:0) payload 89 [05:20:17.736] RECV (ch=0) transfer(handle:1,delivery-id:13,delivery-tag:64,message-format:0) payload 89 [05:20:17.738] RECV (ch=0) transfer(handle:1,delivery-id:14,delivery-tag:65,message-format:0) payload 89 [05:20:17.747] RECV (ch=0) transfer(handle:1,delivery-id:15,delivery-tag:66,message-format:0) payload 89 [05:20:17.748] RECV (ch=1) disposition(role:True,first:4,last:4,settled:True,state:declared(txn-id:61663137326461322D646463622D313165362D623939662D346365623432633765646139)) Accepting to-be-committed messageId msg6 Accepting to-be-committed messageId msg7 Accepting to-be-committed messageId msg8 Accepting to-be-committed messageId msg9 Txn scope Complete() [05:20:17.776] SEND (ch=1) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 48 [05:20:17.827] RECV (ch=1) disposition(role:True,first:5,last:5,settled:True,state:accepted()) Receive last message again ERROR: MessageId: msg5 does not match expected msg10 [05:20:17.840] SEND (ch=0) detach(handle:1,closed:True) [05:20:17.895] RECV (ch=0) detach(handle:1,closed:True) [05:20:17.896] SEND (ch=0) detach(handle:0,closed:True) [05:20:17.949] RECV (ch=0) detach(handle:0,closed:True) [05:20:17.949] SEND (ch=0) end() [05:20:18.001] RECV (ch=0) end() [05:20:18.002] SEND (ch=0) close() [05:20:18.053] RECV (ch=0) close() [05:20:18.107] SEND AMQP 3 1 0 0 [05:20:18.108] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:ER14) [05:20:18.166] RECV AMQP 3 1 0 0 [05:20:18.167] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS]) [05:20:18.169] RECV sasl-outcome(code:0) [05:20:18.171] SEND AMQP 0 1.0.0 [05:20:18.171] SEND (ch=0) open(container-id:15990aa1-a96a-4633-a22f-1bdd9f8ed185,host-name:ER14,max-frame-size:262144,channel-max:256) [05:20:18.180] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:18.180] RECV AMQP 0 1 0 0 [05:20:18.181] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:20:18.193] 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:20:18.224] RECV (ch=0) open(container-id:0.0.0.0,max-frame-size:4294967295,channel-max:65535,idle-time-out:30000,offered-capabilities:[sole-connection-for-container,DELAYED_DELIVERY,SHARED-SUBS],properties:[product:apache-activemq-artemis,version:1.5.1.amq-700001-redhat-1]) [05:20:18.237] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:18.238] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,snd-settle-mode:2,rcv-settle-mode:0,source:source(address:q1),target:target(),incomplete-unsettled:False,initial-delivery-count:0) [05:20:18.247] RECV (ch=0) transfer(handle:0,delivery-id:0,delivery-tag:30,message-format:0) payload 89 [05:20:18.248] RECV (ch=0) transfer(handle:0,delivery-id:1,delivery-tag:31,message-format:0) payload 89 DIAG: Drained leftover message with Id: msg5 [05:20:18.252] RECV (ch=0) transfer(handle:0,delivery-id:2,delivery-tag:32,message-format:0) payload 89 [05:20:18.259] RECV (ch=0) transfer(handle:0,delivery-id:3,delivery-tag:33,message-format:0) payload 89 [05:20:18.260] RECV (ch=0) transfer(handle:0,delivery-id:4,delivery-tag:34,message-format:0) payload 89 [05:20:18.258] SEND (ch=0) disposition(role:True,first:0,settled:True,state:accepted()) [05:20:18.262] RECV (ch=0) transfer(handle:0,delivery-id:5,delivery-tag:35,message-format:0) payload 78 DIAG: Drained leftover message with Id: msg6 [05:20:18.265] SEND (ch=0) disposition(role:True,first:1,settled:True,state:accepted()) DIAG: Drained leftover message with Id: msg7 [05:20:18.267] SEND (ch=0) disposition(role:True,first:2,settled:True,state:accepted()) DIAG: Drained leftover message with Id: msg8 [05:20:18.269] SEND (ch=0) disposition(role:True,first:3,settled:True,state:accepted()) DIAG: Drained leftover message with Id: msg9 [05:20:18.271] SEND (ch=0) disposition(role:True,first:4,settled:True,state:accepted()) DIAG: Drained leftover message with Id: msg10 [05:20:18.282] SEND (ch=0) disposition(role:True,first:5,settled:True,state:accepted()) [05:20:19.283] SEND (ch=0) detach(handle:0,closed:True) [05:20:19.364] RECV (ch=0) detach(handle:0,closed:True) [05:20:19.365] SEND (ch=0) end() [05:20:19.419] RECV (ch=0) end() [05:20:19.419] SEND (ch=0) close() [05:20:19.471] RECV (ch=0) close() ERROR: Messages left in broker at end of test. TransactedRetiring exiting with status FAIL Test: TransactedRetiringAndPosting nMsgs= 10 Pretest - draining target queue... [05:20:19.544] SEND AMQP 3 1 0 0 [05:20:19.544] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:ER14) [05:20:19.604] RECV AMQP 3 1 0 0 [05:20:19.604] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS]) [05:20:19.606] RECV sasl-outcome(code:0) [05:20:19.607] SEND AMQP 0 1.0.0 [05:20:19.609] SEND (ch=0) open(container-id:b49237d9-d84a-4cc7-880b-ca272263f064,host-name:ER14,max-frame-size:262144,channel-max:256) [05:20:19.610] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:19.610] RECV AMQP 0 1 0 0 [05:20:19.611] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:20:19.613] 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:20:19.667] RECV (ch=0) open(container-id:0.0.0.0,max-frame-size:4294967295,channel-max:65535,idle-time-out:30000,offered-capabilities:[sole-connection-for-container,DELAYED_DELIVERY,SHARED-SUBS],properties:[product:apache-activemq-artemis,version:1.5.1.amq-700001-redhat-1]) [05:20:19.671] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:19.672] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,snd-settle-mode:2,rcv-settle-mode:0,source:source(address:q1),target:target(),incomplete-unsettled:False,initial-delivery-count:0) [05:20:20.614] SEND (ch=0) detach(handle:0,closed:True) [05:20:20.669] RECV (ch=0) detach(handle:0,closed:True) [05:20:20.669] SEND (ch=0) end() [05:20:20.721] RECV (ch=0) end() [05:20:20.721] SEND (ch=0) close() [05:20:20.773] RECV (ch=0) close() [05:20:20.827] SEND AMQP 3 1 0 0 [05:20:20.828] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:ER14) [05:20:20.887] RECV AMQP 3 1 0 0 [05:20:20.888] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS]) [05:20:20.889] RECV sasl-outcome(code:0) [05:20:20.889] SEND AMQP 0 1.0.0 [05:20:20.891] SEND (ch=0) open(container-id:5a700a8a-6f2d-4999-b868-8d906c2be27a,host-name:ER14,max-frame-size:262144,channel-max:256) [05:20:20.893] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:20.893] 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:20:20.893] RECV AMQP 0 1 0 0 [05:20:20.947] RECV (ch=0) open(container-id:0.0.0.0,max-frame-size:4294967295,channel-max:65535,idle-time-out:30000,offered-capabilities:[sole-connection-for-container,DELAYED_DELIVERY,SHARED-SUBS],properties:[product:apache-activemq-artemis,version:1.5.1.amq-700001-redhat-1]) [05:20:20.949] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:20.950] RECV (ch=0) attach(name:sender-TransactedRetiringAndPosting,handle:0,role:True,snd-settle-mode:2,rcv-settle-mode:0,source:source(),target:target(address:q1)) [05:20:20.951] RECV (ch=0) flow(next-in-id:4294967293,in-window:2147483647,next-out-id:1,out-window:2147483647,handle:0,delivery-count:0,link-credit:100) [05:20:20.953] SEND (ch=0) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 60 [05:20:21.008] RECV (ch=0) disposition(role:True,first:0,last:0,settled:True,state:accepted()) Sending message with Id msg1 [05:20:21.011] SEND (ch=0) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 60 [05:20:21.064] RECV (ch=0) disposition(role:True,first:1,last:1,settled:True,state:accepted()) Sending message with Id msg2 [05:20:21.066] SEND (ch=0) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 60 [05:20:21.119] RECV (ch=0) disposition(role:True,first:2,last:2,settled:True,state:accepted()) Sending message with Id msg3 [05:20:21.121] SEND (ch=0) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 60 [05:20:21.174] RECV (ch=0) disposition(role:True,first:3,last:3,settled:True,state:accepted()) Sending message with Id msg4 [05:20:21.176] SEND (ch=0) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 60 [05:20:21.231] RECV (ch=0) disposition(role:True,first:4,last:4,settled:True,state:accepted()) Sending message with Id msg5 [05:20:21.233] SEND (ch=0) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 60 [05:20:21.283] RECV (ch=0) disposition(role:True,first:5,last:5,settled:True,state:accepted()) Sending message with Id msg6 [05:20:21.286] SEND (ch=0) transfer(handle:0,delivery-id:6,delivery-tag:00000006,message-format:0,settled:False,batchable:True) payload 60 [05:20:21.338] RECV (ch=0) disposition(role:True,first:6,last:6,settled:True,state:accepted()) Sending message with Id msg7 [05:20:21.341] SEND (ch=0) transfer(handle:0,delivery-id:7,delivery-tag:00000007,message-format:0,settled:False,batchable:True) payload 60 [05:20:21.393] RECV (ch=0) disposition(role:True,first:7,last:7,settled:True,state:accepted()) Sending message with Id msg8 [05:20:21.396] SEND (ch=0) transfer(handle:0,delivery-id:8,delivery-tag:00000008,message-format:0,settled:False,batchable:True) payload 60 [05:20:21.448] RECV (ch=0) disposition(role:True,first:8,last:8,settled:True,state:accepted()) Sending message with Id msg9 [05:20:21.452] SEND (ch=0) transfer(handle:0,delivery-id:9,delivery-tag:00000009,message-format:0,settled:False,batchable:True) payload 60 [05:20:21.506] RECV (ch=0) disposition(role:True,first:9,last:9,settled:True,state:accepted()) Receive two messages [05:20:21.510] SEND (ch=0) attach(name:receiver-TransactedRetiringAndPosting,handle:1,role:True,source:source(address:q1),target:target()) [05:20:21.511] SEND (ch=0) flow(next-in-id:1,in-window:2048,next-out-id:7,out-window:2147483637,handle:1,delivery-count:0,link-credit:2,drain:False) [05:20:21.566] RECV (ch=0) attach(name:receiver-TransactedRetiringAndPosting,handle:1,role:False,snd-settle-mode:2,rcv-settle-mode:0,source:source(address:q1),target:target(),incomplete-unsettled:False,initial-delivery-count:0) [05:20:21.568] RECV (ch=0) transfer(handle:1,delivery-id:0,delivery-tag:30,message-format:0) payload 87 Received message1 id:msg0 [05:20:21.569] RECV (ch=0) transfer(handle:1,delivery-id:1,delivery-tag:31,message-format:0) payload 87 Received message2 id:msg1 ack message1 and send a new message in a txn [05:20:21.574] SEND (ch=1) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:21.575] SEND (ch=1) attach(name:controller-link-8c724,handle:0,role:False,source:source(),target:coordinator(),initial-delivery-count:0) [05:20:21.632] RECV (ch=1) begin(remote-channel:1,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:21.632] RECV (ch=1) attach(name:controller-link-8c724,handle:0,role:True,snd-settle-mode:2,rcv-settle-mode:0,source:source(),target:coordinator(capabilities:[amqp:local-transactions,amqp:multi-txns-per-ssn,amqp:multi-ssns-per-txn])) [05:20:21.634] RECV (ch=1) flow(next-in-id:4294967293,in-window:2147483647,next-out-id:1,out-window:2147483647,handle:0,delivery-count:0,link-credit:100) [05:20:21.636] SEND (ch=1) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 7 [05:20:21.686] RECV (ch=1) disposition(role:True,first:0,last:0,settled:True,state:declared(txn-id:62313731653638372D646463622D313165362D623939662D346365623432633765646139)) [05:20:21.687] SEND (ch=0) disposition(role:True,first:0,settled:False,state:txn-state(txn-id:62313731653638372D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:21.691] SEND (ch=0) transfer(handle:0,delivery-id:10,delivery-tag:0000000A,message-format:0,settled:False,state:txn-state(txn-id:62313731653638372D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 61 [05:20:21.739] RECV (ch=0) disposition(role:False,first:0,last:0,settled:True,state:txn-state(txn-id:62313731653638372D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:21.743] RECV (ch=0) disposition(role:True,first:10,last:10,settled:True,state:accepted()) Sent message id: msg10 Transaction Complete() [05:20:21.747] SEND (ch=1) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 48 [05:20:21.799] RECV (ch=1) disposition(role:True,first:1,last:1,settled:True,state:accepted()) ack message2 and send a new message in a txn but abort the txn [05:20:21.801] SEND (ch=1) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 7 [05:20:21.855] RECV (ch=1) disposition(role:True,first:2,last:2,settled:True,state:declared(txn-id:62313862363166382D646463622D313165362D623939662D346365623432633765646139)) [05:20:21.855] SEND (ch=0) disposition(role:True,first:1,settled:False,state:txn-state(txn-id:62313862363166382D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:21.858] SEND (ch=0) transfer(handle:0,delivery-id:11,delivery-tag:0000000B,message-format:0,settled:False,state:txn-state(txn-id:62313862363166382D646463622D313165362D623939662D346365623432633765646139),batchable:True) payload 87 [05:20:21.908] RECV (ch=0) disposition(role:False,first:1,last:1,settled:True,state:txn-state(txn-id:62313862363166382D646463622D313165362D623939662D346365623432633765646139,outcome:accepted())) [05:20:21.911] RECV (ch=0) disposition(role:True,first:11,last:11,settled:True,state:accepted()) Sent message id: msg11 [05:20:21.913] SEND (ch=1) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 48 Release message 2 Receive and Accept all messages. Expect msg1..msg(N+1) [05:20:21.918] SEND (ch=0) flow(next-in-id:3,in-window:2048,next-out-id:9,out-window:2147483635,handle:1,delivery-count:2,link-credit:10,drain:False) [05:20:21.967] RECV (ch=1) disposition(role:True,first:3,last:3,settled:True,state:accepted()) [05:20:21.972] RECV (ch=0) transfer(handle:1,delivery-id:2,delivery-tag:32,message-format:0) payload 99 [05:20:21.972] RECV (ch=0) transfer(handle:1,delivery-id:3,delivery-tag:33,message-format:0) payload 87 [05:20:21.973] RECV (ch=0) transfer(handle:1,delivery-id:4,delivery-tag:34,message-format:0) payload 87 [05:20:21.976] RECV (ch=0) transfer(handle:1,delivery-id:5,delivery-tag:35,message-format:0) payload 87 [05:20:21.976] RECV (ch=0) transfer(handle:1,delivery-id:6,delivery-tag:36,message-format:0) payload 87 [05:20:21.977] RECV (ch=0) transfer(handle:1,delivery-id:7,delivery-tag:37,message-format:0) payload 87 [05:20:21.972] SEND (ch=0) disposition(role:True,first:2,settled:True,state:accepted()) receive: msg1 [05:20:21.981] SEND (ch=0) disposition(role:True,first:3,settled:True,state:accepted()) receive: msg2 [05:20:21.983] SEND (ch=0) disposition(role:True,first:4,settled:True,state:accepted()) [05:20:21.979] RECV (ch=0) transfer(handle:1,delivery-id:8,delivery-tag:38,message-format:0) payload 87 [05:20:21.984] RECV (ch=0) transfer(handle:1,delivery-id:9,delivery-tag:39,message-format:0) payload 87 [05:20:21.985] RECV (ch=0) transfer(handle:1,delivery-id:10,delivery-tag:61,message-format:0) payload 87 receive: msg3 [05:20:21.987] SEND (ch=0) disposition(role:True,first:5,settled:True,state:accepted()) receive: msg4 [05:20:21.991] SEND (ch=0) disposition(role:True,first:6,settled:True,state:accepted()) receive: msg5 [05:20:21.999] SEND (ch=0) disposition(role:True,first:7,settled:True,state:accepted()) receive: msg6 [05:20:22.009] SEND (ch=0) disposition(role:True,first:8,settled:True,state:accepted()) receive: msg7 [05:20:22.019] SEND (ch=0) disposition(role:True,first:9,settled:True,state:accepted()) [05:20:22.025] RECV (ch=0) transfer(handle:1,delivery-id:11,delivery-tag:62,message-format:0) payload 88 receive: msg8 [05:20:22.038] SEND (ch=0) disposition(role:True,first:10,settled:True,state:accepted()) receive: msg9 [05:20:22.052] SEND (ch=0) disposition(role:True,first:11,settled:True,state:accepted()) receive: msg10 [05:20:22.062] SEND (ch=0) close() [05:20:22.115] RECV (ch=0) close() [05:20:22.169] SEND AMQP 3 1 0 0 [05:20:22.169] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:ER14) [05:20:22.232] RECV AMQP 3 1 0 0 [05:20:22.232] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS]) [05:20:22.233] RECV sasl-outcome(code:0) [05:20:22.235] SEND AMQP 0 1.0.0 [05:20:22.237] SEND (ch=0) open(container-id:1803fc04-0f28-4e37-9eff-71f2e2cb5a88,host-name:ER14,max-frame-size:262144,channel-max:256) [05:20:22.245] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295) [05:20:22.245] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target()) [05:20:22.246] 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:20:22.245] RECV AMQP 0 1 0 0 [05:20:22.290] RECV (ch=0) open(container-id:0.0.0.0,max-frame-size:4294967295,channel-max:65535,idle-time-out:30000,offered-capabilities:[sole-connection-for-container,DELAYED_DELIVERY,SHARED-SUBS],properties:[product:apache-activemq-artemis,version:1.5.1.amq-700001-redhat-1]) [05:20:22.302] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535) [05:20:22.302] RECV (ch=0) attach(name:DrainTarget,handle:0,role:False,snd-settle-mode:2,rcv-settle-mode:0,source:source(address:q1),target:target(),incomplete-unsettled:False,initial-delivery-count:0) [05:20:23.248] SEND (ch=0) detach(handle:0,closed:True) [05:20:23.566] RECV (ch=0) detach(handle:0,closed:True) [05:20:23.566] SEND (ch=0) end() [05:20:23.618] RECV (ch=0) end() [05:20:23.618] SEND (ch=0) close() [05:20:23.675] RECV (ch=0) close() TransactedRetiringAndPosting exiting with status PASS D:\Users\crolke\git\amqpnetlite\TransactionTestProgram\bin\Debug> Broker shows: | _ \ ___ __| | | | | | __ _| |_ / \ | \/ |/ _ \|___ | | |_) / _ \/ _` | | |_| |/ _` | __| / _ \ _____| |\/| | | | | / / | _ < __/ (_| | | _ | (_| | |_ / ___ \_____| | | | |_| | / / |_| \_\___|\__,_| |_| |_|\__,_|\__| /_/ \_\ |_| |_|\__\_\/_/ Red Hat A-MQ7 7.0.0.ER14-redhat-1 17:15:03,467 INFO [org.apache.activemq.artemis.integration.bootstrap] AMQ101000: Starting ActiveMQ Artemis Server 17:15:03,492 INFO [org.apache.activemq.artemis.core.server] AMQ221000: live Message Broker is starting with configuration Broker Configuration (clustered=false,journalDirectory=./data/journal,bindingsDirectory=./data/bindings,largeMessagesDirectory=./data/large-messages,pagingDirectory=./data/paging) 17:15:03,520 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-server]. Adding protocol support for: CORE 17:15:03,522 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-amqp-protocol]. Adding protocol support for: AMQP 17:15:03,523 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-hornetq-protocol]. Adding protocol support for: HORNETQ 17:15:03,524 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-mqtt-protocol]. Adding protocol support for: MQTT 17:15:03,524 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-openwire-protocol]. Adding protocol support for: OPENWIRE 17:15:03,525 INFO [org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found: [artemis-stomp-protocol]. Adding protocol support for: STOMP 17:15:03,593 INFO [org.apache.activemq.artemis.core.server] AMQ221003: Deploying queue DLQ 17:15:03,624 INFO [org.apache.activemq.artemis.core.server] AMQ221003: Deploying queue ExpiryQueue 17:15:03,626 INFO [org.apache.activemq.artemis.core.server] AMQ221003: Deploying queue MyQ 17:15:03,629 INFO [org.apache.activemq.artemis.core.server] AMQ221003: Deploying queue amq.topic 17:15:03,631 INFO [org.apache.activemq.artemis.core.server] AMQ221003: Deploying queue q1 17:15:03,633 INFO [org.apache.activemq.artemis.core.server] AMQ221003: Deploying queue service_queue 17:15:03,635 INFO [org.apache.activemq.artemis.core.server] AMQ221003: Deploying queue my-queue 17:15:04,049 INFO [org.apache.activemq.artemis.core.server] AMQ221020: Started Acceptor at 0.0.0.0:61616 for protocols [CORE,MQTT,AMQP,STOMP,HORNETQ,OPENWIRE] 17:15:04,051 INFO [org.apache.activemq.artemis.core.server] AMQ221020: Started Acceptor at 0.0.0.0:5445 for protocols [HORNETQ,STOMP] 17:15:04,057 INFO [org.apache.activemq.artemis.core.server] AMQ221020: Started Acceptor at 0.0.0.0:5672 for protocols [AMQP] 17:15:04,059 INFO [org.apache.activemq.artemis.core.server] AMQ221020: Started Acceptor at 0.0.0.0:1883 for protocols [MQTT] 17:15:04,060 INFO [org.apache.activemq.artemis.core.server] AMQ221020: Started Acceptor at 0.0.0.0:61613 for protocols [STOMP] 17:15:04,061 INFO [org.apache.activemq.artemis.core.server] AMQ221007: Server is now live 17:15:04,061 INFO [org.apache.activemq.artemis.core.server] AMQ221001: Apache ActiveMQ Artemis Message Broker version 1.5.1.amq-700001-redhat-1 [0.0.0.0, nodeID=8f5ee87e-ddcb-11e6-b99f-4ceb42c7eda9] SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". SLF4J: Defaulting to no-operation (NOP) logger implementation SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details. INFO | main | Initialized artemis-plugin plugin INFO | main | Initialized dispatch-hawtio-console plugin 17:15:04,904 INFO [org.apache.activemq.artemis] AMQ241001: HTTP Server started at http://localhost:8161 17:15:04,905 INFO [org.apache.activemq.artemis] AMQ241002: Artemis Jolokia REST API available at http://localhost:8161/jolokia 17:15:50,889 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 17:15:52,430 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 17:15:53,931 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 17:15:55,466 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 17:15:57,019 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 17:15:58,436 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 17:15:59,739 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 17:16:01,079 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT] 17:16:02,636 WARN [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure has been detected: null [code=REMOTE_DISCONNECT]