cartodb/app/helpers/message_broker_helper.rb

module MessageBrokerHelper

  def message_broker
    Carto::Common::MessageBroker.new(logger: Rails.logger)
  end

  def cartodb_central_topic
    message_broker.get_topic(:cartodb_central)
  end

end