diff options
author | James Turnbull <james@lovedthanlost.net> | 2011-04-20 02:35:40 +1000 |
---|---|---|
committer | Josh Cooper <josh@puppetlabs.com> | 2011-04-19 15:30:59 -0700 |
commit | c87d6c98ec1a315d435be38e7eb2258984c7d88c (patch) | |
tree | d7e7255721198e391f916379912dc6c1bc9410ea /lib/puppet/util | |
parent | 40a5bca736a31784d341aef389edfdde915938ec (diff) | |
download | puppet-c87d6c98ec1a315d435be38e7eb2258984c7d88c.tar.gz puppet-c87d6c98ec1a315d435be38e7eb2258984c7d88c.tar.xz puppet-c87d6c98ec1a315d435be38e7eb2258984c7d88c.zip |
Fixed #7166 - Replaced deprecated stomp "send" method with "publish"
The "send" method in the stomp gem has been deprecated since:
http://gitorious.org/stomp/mainline/commit/d542a976028cb4c5badcbb69e3383e746721e44c
It's been replaced with the "publish" method.
Also renamed the send_message method to publish_message more in
keeping with language used in queuing.
Diffstat (limited to 'lib/puppet/util')
-rw-r--r-- | lib/puppet/util/queue.rb | 2 | ||||
-rw-r--r-- | lib/puppet/util/queue/stomp.rb | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/lib/puppet/util/queue.rb b/lib/puppet/util/queue.rb index 02357742a..636bdcf2e 100644 --- a/lib/puppet/util/queue.rb +++ b/lib/puppet/util/queue.rb @@ -30,7 +30,7 @@ require 'puppet/util/instance_loader' # # The client plugins are expected to implement an interface similar to that of Stomp::Client: # * <tt>new</tt> should return a connected, ready-to-go client instance. Note that no arguments are passed in. -# * <tt>send_message(queue, message)</tt> should send the _message_ to the specified _queue_. +# * <tt>publish_message(queue, message)</tt> should publish the _message_ to the specified _queue_. # * <tt>subscribe(queue)</tt> _block_ subscribes to _queue_ and executes _block_ upon receiving a message. # * _queue_ names are simple names independent of the message broker or client library. No "/queue/" prefixes like in Stomp::Client. module Puppet::Util::Queue diff --git a/lib/puppet/util/queue/stomp.rb b/lib/puppet/util/queue/stomp.rb index c18edae6a..cabc56627 100644 --- a/lib/puppet/util/queue/stomp.rb +++ b/lib/puppet/util/queue/stomp.rb @@ -28,8 +28,8 @@ class Puppet::Util::Queue::Stomp end end - def send_message(target, msg) - stomp_client.send(stompify_target(target), msg, :persistent => true) + def publish_message(target, msg) + stomp_client.publish(stompify_target(target), msg, :persistent => true) end def subscribe(target) |