File tree Expand file tree Collapse file tree 1 file changed +21
-0
lines changed
test/src/com/rabbitmq/client/test/functional Expand file tree Collapse file tree 1 file changed +21
-0
lines changed Original file line number Diff line number Diff line change @@ -169,6 +169,27 @@ public void testCommitAcks()
169
169
assertNull (basicGet ());
170
170
}
171
171
172
+ /*
173
+ */
174
+ public void testCommitAcksOutOfOrder ()
175
+ throws IOException
176
+ {
177
+ basicPublish ();
178
+ basicPublish ();
179
+ basicPublish ();
180
+ basicPublish ();
181
+ txSelect ();
182
+ GetResponse resp1 = basicGet ();
183
+ GetResponse resp2 = basicGet ();
184
+ GetResponse resp3 = basicGet ();
185
+ GetResponse resp4 = basicGet ();
186
+ channel .basicNack (resp4 .getEnvelope ().getDeliveryTag (), false , false );
187
+ channel .basicNack (resp3 .getEnvelope ().getDeliveryTag (), false , false );
188
+ channel .basicAck (resp2 .getEnvelope ().getDeliveryTag (), false );
189
+ channel .basicAck (resp1 .getEnvelope ().getDeliveryTag (), false );
190
+ txCommit ();
191
+ }
192
+
172
193
/*
173
194
rollback rolls back acks
174
195
and a rolled back ack can be re-issued
You can’t perform that action at this time.
0 commit comments