1 May 2011 15:28
[PATCH/mcollective 1/1] 7246 - add the ability to add the priority to JMS messages
R.I.Pienaar <rip <at> devco.net>
2011-05-01 13:28:22 GMT
2011-05-01 13:28:22 GMT
Add a plugin.stomp.priority option that will be used by recent
versions of ActiveMQ to prioritize our messages over others.
Signed-off-by: R.I.Pienaar <rip <at> devco.net>
---
Local-branch: feature/master/7246_stomp_priority
plugins/mcollective/connector/stomp.rb | 19 +++++++++++++++++--
website/changelog.md | 1 +
website/reference/plugins/connector_stomp.md | 9 +++++++++
3 files changed, 27 insertions(+), 2 deletions(-)
diff --git a/plugins/mcollective/connector/stomp.rb b/plugins/mcollective/connector/stomp.rb
index 17ef337..2806ed4 100644
--- a/plugins/mcollective/connector/stomp.rb
+++ b/plugins/mcollective/connector/stomp.rb
<at> <at> -51,6 +51,13 <at> <at> module MCollective
# plugin.stomp.pool.max_reconnect_attempts = 0
# plugin.stomp.pool.randomize = false
# plugin.stomp.pool.timeout = -1
+ #
+ # For versions of ActiveMQ that supports message priorities
+ # you can set a priority, this will cause a "priority" header
+ # to be emitted if present:
+ #
+ # plugin.stomp.priority = 4
+ #
class Stomp<Base
attr_reader :connection
<at> <at> -72,6 +79,7 <at> <at> module MCollective
(Continue reading)
RSS Feed