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}.