Hello,
I create queues on the fly meaning they get created as soon as I start
publishing messages. That's fine now the problem is that I can't find the
way to specify the constantPendingMessageLimitStrategy as I need these
queues to be of a specific size (messages should be discarded).
e.g.
this does not work
String queueName = "queue01";
int queueSize = "15";
final String QUEUE_NAME_PATTERN =
"milestone2-topic-{0}?consumer.constantPendingMessageLimit={1}";
Topic topic = session.createTopic(MessageFormat.format(QUEUE_NAME_PATTERN,
queueName, queueSize));
can someone please clarify what this parameter
"consumer.constantPendingMessageLimit" name should be or if it actually
works at all to pass it during the call to session.createTopic(...)
Many thanks in advance,
Best regards,
Giovanni
--
View this message in context:
http://www.nabble.com/createTopic-on-the-fly-specifying-constantPendingMessageLimitStrategy-tp25937566p25937566.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
