Skip to content

Commit 0c81558

Browse files
Drop the immediate flag
1 parent b02af70 commit 0c81558

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

src/main/java/com/rabbitmq/perf/Producer.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,6 @@ public class Producer extends ProducerConsumerBase implements Runnable, ReturnLi
3636
private final String id;
3737
private final boolean randomRoutingKey;
3838
private final boolean mandatory;
39-
private final boolean immediate;
4039
private final boolean persistent;
4140
private final int txSize;
4241
private final int msgLimit;
@@ -61,7 +60,6 @@ public Producer(Channel channel, String exchangeName, String id, boolean randomR
6160
this.id = id;
6261
this.randomRoutingKey = randomRoutingKey;
6362
this.mandatory = flags.contains("mandatory");
64-
this.immediate = flags.contains("immediate");
6563
this.persistent = flags.contains("persistent");
6664
this.txSize = txSize;
6765
this.rateLimit = rateLimit;
@@ -165,7 +163,7 @@ private void publish(MessageBodySource.MessageBodyAndContentType messageBodyAndC
165163

166164
unconfirmedSet.add(channel.getNextPublishSeqNo());
167165
channel.basicPublish(exchangeName, randomRoutingKey ? UUID.randomUUID().toString() : id,
168-
mandatory, immediate,
166+
mandatory, false,
169167
propertiesBuilder.build(),
170168
messageBodyAndContentType.getBody());
171169
}

0 commit comments

Comments
 (0)