Skip to content

Commit 5effc26

Browse files
author
Alexandru Scvortov
committed
allow consumer tx with confirms
1 parent eef5cdc commit 5effc26

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

test/src/com/rabbitmq/examples/MulticastMain.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -86,9 +86,9 @@ public static void main(String[] args) {
8686
int frameMax = intArg(cmd, 'M', 0);
8787
int heartbeat = intArg(cmd, 'b', 0);
8888

89-
if ((producerTxSize + consumerTxSize > 0) && confirm) {
89+
if ((producerTxSize > 0) && confirm) {
9090
throw new ParseException("Cannot select both producerTxSize"+
91-
"/consumerTxSize and confirm");
91+
" and confirm");
9292
}
9393

9494
//setup

0 commit comments

Comments
 (0)