D:\Users\crolke\git\amqpnetlite\TransactionTestProgram\bin\Debug>TransactionTestProgram.exe amqp://admin:password@10.10.59.93:5672 q1

Test: TransactedRetiring

nMsgs= 10

Pretest - draining target queue...

[11:47:05.112] SEND AMQP 3 1 0 0
[11:47:05.122] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:10.10.59.93)
[11:47:05.167] RECV AMQP 3 1 0 0
[11:47:05.173] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS])
[11:47:05.180] RECV sasl-outcome(code:0)
[11:47:05.182] SEND AMQP 0 1.0.0
[11:47:05.183] SEND (ch=0) open(container-id:25f528b9-ae6e-432c-a3ef-1992c4728867,host-name:10.10.59.93,max-frame-size:262144,channel-max:256)
[11:47:05.187] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295)
[11:47:05.191] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target())
[11:47:05.195] 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)
[11:47:05.197] RECV AMQP 0 1 0 0
[11:47:05.238] 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])
[11:47:05.250] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535)
[11:47:05.252] 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)
[11:47:06.198] SEND (ch=0) detach(handle:0,closed:True)
[11:47:06.360] RECV (ch=0) detach(handle:0,closed:True)
[11:47:06.364] SEND (ch=0) end()
[11:47:06.417] RECV (ch=0) end()
[11:47:06.418] SEND (ch=0) close()
[11:47:06.472] RECV (ch=0) close()
[11:47:06.527] SEND AMQP 3 1 0 0
[11:47:06.527] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:10.10.59.93)
[11:47:06.632] RECV AMQP 3 1 0 0
[11:47:06.632] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS])
[11:47:06.632] RECV sasl-outcome(code:0)
[11:47:06.632] SEND AMQP 0 1.0.0
[11:47:06.633] SEND (ch=0) open(container-id:d280e660-83a6-4f94-a110-63764fa5edf2,host-name:10.10.59.93,max-frame-size:262144,channel-max:256)
[11:47:06.633] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295)
[11:47:06.634] SEND (ch=0) attach(name:sender-TransactedRetiring,handle:0,role:False,source:source(),target:target(address:q1),initial-delivery-count:0)
[11:47:06.634] RECV AMQP 0 1 0 0

Send N+1 with no transaction scope

Sending message with Id msg0
[11:47:06.685] 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])
[11:47:06.690] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535)
[11:47:06.692] 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))
[11:47:06.696] 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)
[11:47:06.705] SEND (ch=0) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 50
[11:47:06.762] RECV (ch=0) disposition(role:True,first:0,last:0,settled:True,state:accepted())
Sending message with Id msg1
[11:47:06.786] SEND (ch=0) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 50
[11:47:06.840] RECV (ch=0) disposition(role:True,first:1,last:1,settled:True,state:accepted())
Sending message with Id msg2
[11:47:06.860] SEND (ch=0) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 50
[11:47:06.913] RECV (ch=0) disposition(role:True,first:2,last:2,settled:True,state:accepted())
Sending message with Id msg3
[11:47:06.934] SEND (ch=0) transfer(handle:0,delivery-id:3,delivery-tag:00000003,message-format:0,settled:False,batchable:True) payload 50
[11:47:06.987] RECV (ch=0) disposition(role:True,first:3,last:3,settled:True,state:accepted())
Sending message with Id msg4
[11:47:07.007] SEND (ch=0) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 50
[11:47:07.059] RECV (ch=0) disposition(role:True,first:4,last:4,settled:True,state:accepted())
Sending message with Id msg5
[11:47:07.080] SEND (ch=0) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 50
[11:47:07.136] RECV (ch=0) disposition(role:True,first:5,last:5,settled:True,state:accepted())
Sending message with Id msg6
[11:47:07.176] SEND (ch=0) transfer(handle:0,delivery-id:6,delivery-tag:00000006,message-format:0,settled:False,batchable:True) payload 50
[11:47:07.285] RECV (ch=0) disposition(role:True,first:6,last:6,settled:True,state:accepted())
Sending message with Id msg7
[11:47:07.301] SEND (ch=0) transfer(handle:0,delivery-id:7,delivery-tag:00000007,message-format:0,settled:False,batchable:True) payload 50
[11:47:07.354] RECV (ch=0) disposition(role:True,first:7,last:7,settled:True,state:accepted())
Sending message with Id msg8
[11:47:07.377] SEND (ch=0) transfer(handle:0,delivery-id:8,delivery-tag:00000008,message-format:0,settled:False,batchable:True) payload 50
[11:47:07.430] RECV (ch=0) disposition(role:True,first:8,last:8,settled:True,state:accepted())
Sending message with Id msg9
[11:47:07.449] SEND (ch=0) transfer(handle:0,delivery-id:9,delivery-tag:00000009,message-format:0,settled:False,batchable:True) payload 50
[11:47:07.504] RECV (ch=0) disposition(role:True,first:9,last:9,settled:True,state:accepted())
Sending message with Id msg10
[11:47:07.524] SEND (ch=0) transfer(handle:0,delivery-id:10,delivery-tag:0000000A,message-format:0,settled:False,batchable:True) payload 51
[11:47:07.577] RECV (ch=0) disposition(role:True,first:10,last:10,settled:True,state:accepted())
[11:47:07.578] 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

[11:47:07.627] 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)
[11:47:07.630] 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)
[11:47:07.680] RECV (ch=0) transfer(handle:1,delivery-id:0,delivery-tag:30,message-format:0) payload 77
[11:47:07.686] RECV (ch=0) transfer(handle:1,delivery-id:1,delivery-tag:31,message-format:0) payload 77
[11:47:07.688] RECV (ch=0) transfer(handle:1,delivery-id:2,delivery-tag:32,message-format:0) payload 77
Received: msg0
[11:47:07.690] RECV (ch=0) transfer(handle:1,delivery-id:3,delivery-tag:33,message-format:0) payload 77
Received: msg1
Received: msg2
Received: msg3
[11:47:07.692] RECV (ch=0) transfer(handle:1,delivery-id:4,delivery-tag:34,message-format:0) payload 77
[11:47:07.696] RECV (ch=0) transfer(handle:1,delivery-id:5,delivery-tag:35,message-format:0) payload 77
[11:47:07.698] RECV (ch=0) transfer(handle:1,delivery-id:6,delivery-tag:36,message-format:0) payload 77
Received: msg4
Received: msg5
Received: msg6
[11:47:07.699] RECV (ch=0) transfer(handle:1,delivery-id:7,delivery-tag:37,message-format:0) payload 77
[11:47:07.702] RECV (ch=0) transfer(handle:1,delivery-id:8,delivery-tag:38,message-format:0) payload 77
[11:47:07.703] RECV (ch=0) transfer(handle:1,delivery-id:9,delivery-tag:39,message-format:0) payload 77
[11:47:07.705] RECV (ch=0) transfer(handle:1,delivery-id:10,delivery-tag:61,message-format:0) payload 78
Received: msg7
Received: msg8
Received: msg9

Create txn scope and accept half the messages

Accepting to-be-committed messageId: msg0
[11:47:07.717] SEND (ch=1) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295)
[11:47:07.718] SEND (ch=1) attach(name:controller-link-9f8dd,handle:0,role:False,source:source(),target:coordinator(),initial-delivery-count:0)
[11:47:07.775] RECV (ch=1) begin(remote-channel:1,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535)
[11:47:07.776] RECV (ch=1) attach(name:controller-link-9f8dd,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]))
[11:47:07.777] 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)
[11:47:07.778] SEND (ch=1) transfer(handle:0,delivery-id:0,delivery-tag:00000000,message-format:0,settled:False,batchable:True) payload 7
[11:47:07.832] RECV (ch=1) disposition(role:True,first:0,last:0,settled:True,state:declared(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139))
[11:47:07.835] SEND (ch=0) disposition(role:True,first:0,settled:False,state:txn-state(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
Accepting to-be-committed messageId: msg1
[11:47:07.837] SEND (ch=0) disposition(role:True,first:1,settled:False,state:txn-state(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
Accepting to-be-committed messageId: msg2
[11:47:07.846] SEND (ch=0) disposition(role:True,first:2,settled:False,state:txn-state(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
Accepting to-be-committed messageId: msg3
[11:47:07.855] SEND (ch=0) disposition(role:True,first:3,settled:False,state:txn-state(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
Accepting to-be-committed messageId: msg4
[11:47:07.863] SEND (ch=0) disposition(role:True,first:4,settled:False,state:txn-state(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
Txn scope complete
[11:47:07.882] SEND (ch=1) transfer(handle:0,delivery-id:1,delivery-tag:00000001,message-format:0,settled:False,batchable:True) payload 48
[11:47:07.889] RECV (ch=0) disposition(role:False,first:0,last:0,settled:True,state:txn-state(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
[11:47:07.892] RECV (ch=0) disposition(role:False,first:1,last:1,settled:True,state:txn-state(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
[11:47:07.899] RECV (ch=0) disposition(role:False,first:2,last:2,settled:True,state:txn-state(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
[11:47:07.910] RECV (ch=0) disposition(role:False,first:3,last:3,settled:True,state:txn-state(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
[11:47:07.914] RECV (ch=0) disposition(role:False,first:4,last:4,settled:True,state:txn-state(txn-id:32343038643033362D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
[11:47:07.943] 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
[11:47:07.948] SEND (ch=1) transfer(handle:0,delivery-id:2,delivery-tag:00000002,message-format:0,settled:False,batchable:True) payload 7
[11:47:08.003] RECV (ch=1) disposition(role:True,first:2,last:2,settled:True,state:declared(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139))
[11:47:08.003] SEND (ch=0) disposition(role:True,first:5,settled:False,state:txn-state(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
Accepting to-be-rolled-back messageId: msg6
[11:47:08.006] SEND (ch=0) disposition(role:True,first:6,settled:False,state:txn-state(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
Accepting to-be-rolled-back messageId: msg7
[11:47:08.009] SEND (ch=0) disposition(role:True,first:7,settled:False,state:txn-state(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
Accepting to-be-rolled-back messageId: msg8
[11:47:08.012] SEND (ch=0) disposition(role:True,first:8,settled:False,state:txn-state(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
Accepting to-be-rolled-back messageId: msg9
[11:47:08.014] SEND (ch=0) disposition(role:True,first:9,settled:False,state:txn-state(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
Close txn scope without calling complete
[11:47:08.016] 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
[11:47:08.023] 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
[11:47:08.040] SEND (ch=1) transfer(handle:0,delivery-id:4,delivery-tag:00000004,message-format:0,settled:False,batchable:True) payload 7
[11:47:08.057] RECV (ch=0) disposition(role:False,first:5,last:5,settled:True,state:txn-state(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
[11:47:08.060] RECV (ch=0) disposition(role:False,first:6,last:6,settled:True,state:txn-state(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
[11:47:08.065] RECV (ch=0) disposition(role:False,first:7,last:7,settled:True,state:txn-state(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
[11:47:08.066] RECV (ch=0) disposition(role:False,first:8,last:8,settled:True,state:txn-state(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
[11:47:08.067] RECV (ch=0) disposition(role:False,first:9,last:9,settled:True,state:txn-state(txn-id:32343232346261372D646439642D313165362D383564652D346365623432633765646139,outcome:accepted()))
[11:47:08.069] RECV (ch=1) disposition(role:True,first:3,last:3,settled:True,state:accepted())
[11:47:08.076] RECV (ch=0) transfer(handle:1,delivery-id:11,delivery-tag:62,message-format:0) payload 89
[11:47:08.084] RECV (ch=0) transfer(handle:1,delivery-id:12,delivery-tag:63,message-format:0) payload 89
[11:47:08.093] RECV (ch=0) transfer(handle:1,delivery-id:13,delivery-tag:64,message-format:0) payload 89
[11:47:08.094] RECV (ch=0) transfer(handle:1,delivery-id:14,delivery-tag:65,message-format:0) payload 89
[11:47:08.095] RECV (ch=0) transfer(handle:1,delivery-id:15,delivery-tag:66,message-format:0) payload 89
[11:47:08.096] RECV (ch=1) disposition(role:True,first:4,last:4,settled:True,state:declared(txn-id:32343330376337382D646439642D313165362D383564652D346365623432633765646139))
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()
[11:47:08.123] SEND (ch=1) transfer(handle:0,delivery-id:5,delivery-tag:00000005,message-format:0,settled:False,batchable:True) payload 48
[11:47:08.177] 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
[11:47:08.182] SEND (ch=0) detach(handle:1,closed:True)
[11:47:08.234] RECV (ch=0) detach(handle:1,closed:True)
[11:47:08.236] SEND (ch=0) detach(handle:0,closed:True)
[11:47:08.291] RECV (ch=0) detach(handle:0,closed:True)
[11:47:08.292] SEND (ch=0) end()
[11:47:08.344] RECV (ch=0) end()
[11:47:08.345] SEND (ch=0) close()
[11:47:08.397] RECV (ch=0) close()
[11:47:08.452] SEND AMQP 3 1 0 0
[11:47:08.452] SEND sasl-init(mechanism:PLAIN,initial-response:0061646D696E0070617373776F7264,hostname:10.10.59.93)
[11:47:08.512] RECV AMQP 3 1 0 0
[11:47:08.512] RECV sasl-mechanisms(sasl-server-mechanisms:[PLAIN,ANONYMOUS])
[11:47:08.514] RECV sasl-outcome(code:0)
[11:47:08.516] SEND AMQP 0 1.0.0
[11:47:08.516] SEND (ch=0) open(container-id:12dfdf71-160c-43f0-9a3e-8a373d3a4601,host-name:10.10.59.93,max-frame-size:262144,channel-max:256)
[11:47:08.524] SEND (ch=0) begin(next-outgoing-id:4294967293,incoming-window:2048,outgoing-window:2048,handle-max:4294967295)
[11:47:08.524] RECV AMQP 0 1 0 0
[11:47:08.525] SEND (ch=0) attach(name:DrainTarget,handle:0,role:True,source:source(address:q1),target:target())
[11:47:08.534] 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)
[11:47:08.570] 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])
[11:47:08.582] RECV (ch=0) begin(remote-channel:0,next-outgoing-id:1,incoming-window:2147483647,outgoing-window:2147483647,handle-max:65535)
[11:47:08.582] 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)
[11:47:08.587] RECV (ch=0) transfer(handle:0,delivery-id:0,delivery-tag:30,message-format:0) payload 89
[11:47:08.591] RECV (ch=0) transfer(handle:0,delivery-id:1,delivery-tag:31,message-format:0) payload 89
[11:47:08.592] RECV (ch=0) transfer(handle:0,delivery-id:2,delivery-tag:32,message-format:0) payload 89
[11:47:08.593] RECV (ch=0) transfer(handle:0,delivery-id:3,delivery-tag:33,message-format:0) payload 89
[11:47:08.594] RECV (ch=0) transfer(handle:0,delivery-id:4,delivery-tag:34,message-format:0) payload 89
[11:47:08.595] RECV (ch=0) transfer(handle:0,delivery-id:5,delivery-tag:35,message-format:0) payload 78
DIAG: Drained leftover message with Id: msg5
[11:47:08.607] SEND (ch=0) disposition(role:True,first:0,settled:True,state:accepted())
DIAG: Drained leftover message with Id: msg6
[11:47:08.616] SEND (ch=0) disposition(role:True,first:1,settled:True,state:accepted())
DIAG: Drained leftover message with Id: msg7
[11:47:08.618] SEND (ch=0) disposition(role:True,first:2,settled:True,state:accepted())
DIAG: Drained leftover message with Id: msg8
[11:47:08.626] SEND (ch=0) disposition(role:True,first:3,settled:True,state:accepted())
DIAG: Drained leftover message with Id: msg9
[11:47:08.644] SEND (ch=0) disposition(role:True,first:4,settled:True,state:accepted())
DIAG: Drained leftover message with Id: msg10
[11:47:08.654] SEND (ch=0) disposition(role:True,first:5,settled:True,state:accepted())
[11:47:09.655] SEND (ch=0) detach(handle:0,closed:True)
[11:47:09.719] RECV (ch=0) detach(handle:0,closed:True)
[11:47:09.720] SEND (ch=0) end()
[11:47:09.772] RECV (ch=0) end()
[11:47:09.772] SEND (ch=0) close()
[11:47:09.824] RECV (ch=0) close()
ERROR: Messages left in broker at end of test.
TransactedRetiring exiting with status FAIL

D:\Users\crolke\git\amqpnetlite\TransactionTestProgram\bin\Debug>