mattrpav commented on code in PR #1326:
URL: https://github.com/apache/activemq/pull/1326#discussion_r1809280575
##########
activemq-client/src/main/java/org/apache/activemq/util/ProducerThread.java:
##########
@@ -40,6 +40,8 @@ public class ProducerThread extends Thread {
long msgTTL = 0L;
String msgGroupID=null;
int transactionBatchSize;
+ int priority = 4;
Review Comment:
This should use the Jakarta Messaging API constant instead of fix value.
jakarta.jms.Message.DEFAULT_PRIORITY
##########
activemq-console/src/main/java/org/apache/activemq/console/command/ProducerCommand.java:
##########
@@ -45,6 +45,8 @@ public class ProducerCommand extends AbstractCommand {
String msgGroupID=null;
int transactionBatchSize;
private int parallelThreads = 1;
+ int priority = 4; // Default priority
Review Comment:
1. This should use the Jakarta Messaging API constant instead of fix value.
jakarta.jms.Message.DEFAULT_PRIORITY
2. Remove comment
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: gitbox-unsubscr...@activemq.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: gitbox-unsubscr...@activemq.apache.org
For additional commands, e-mail: gitbox-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact
