Skip to content

Commit

Permalink
fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
p-bakker committed Aug 18, 2020
1 parent 946be6d commit 73ce258
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ public class ConfigHandler {
private final static String AUTO_DELETE = "autodelete";

private final static String CONSUMER_TAG = "consumertag";
final static String AUTO_ACK = "autoAck";
final static String AUTO_ACK = "autoack";
final static String ACK_MULTIPLE = "ack.multiple";
final static String NACK_MULTIPLE = "nack.multiple";
final static String NACK_REQUEUE = "nack.requeue";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,10 +43,10 @@ public ScriptMethodMessageConsumer(Channel channel, HeadlessClientPool pool, Str
this.solutionName = solutionName;

this.autoAck = (Boolean) config.getOrDefault(ConfigHandler.AUTO_ACK, true);
this.ackMultiple = (Boolean) config.getOrDefault(ConfigHandler.ACK_MULTIPLE, true);
this.nackMultiple = (Boolean) config.getOrDefault(ConfigHandler.NACK_MULTIPLE, true);
this.nackRequeue = (Boolean) config.getOrDefault(ConfigHandler.NACK_REQUEUE, true);
this.rejectRequeue = (Boolean) config.getOrDefault(ConfigHandler.REJECT_REQUEUE, true);
this.ackMultiple = (Boolean) config.getOrDefault(ConfigHandler.ACK_MULTIPLE, false);
this.nackMultiple = (Boolean) config.getOrDefault(ConfigHandler.NACK_MULTIPLE, false);
this.nackRequeue = (Boolean) config.getOrDefault(ConfigHandler.NACK_REQUEUE, false);
this.rejectRequeue = (Boolean) config.getOrDefault(ConfigHandler.REJECT_REQUEUE, false);
}

@Override
Expand Down

0 comments on commit 73ce258

Please sign in to comment.