lib/propono.rb in propono-0.9.1 vs lib/propono.rb in propono-0.10.0
- old
+ new
@@ -65,10 +65,11 @@
# @param [String] topic The name of the topic to publish to.
# @param [String] message The message to post.
# @param [Hash] options
# * protocol: :udp
def self.publish(topic, message, options = {})
- Publisher.publish(topic, message, options)
+ suffixed_topic = "#{topic}#{Propono.config.queue_suffix}"
+ Publisher.publish(suffixed_topic, message, options)
end
# Creates a new SNS-SQS subscription on the specified topic.
#
# This is implicitly called by {#listen_to_queue}.